サンプルプログラム（自動給水システム）

# -*- coding: utf-8 -*-
import time
import os
import RPi.GPIO as GPIO
from datetime import datetime
import base64
import json
import urllib.request

# データ送信先
URL = "https://beta.sensingapp.io/api/data/"
USER_ID = "XXXXXXXXXXXXX" 
ITEM = 'MOISTURE'

SPICLK = 11
SPIMOSI = 10
SPIMISO = 9
SPICS = 8
SENSOR_NUM = 1  # 使用するセンサーの個数（CH0から順番に使用する）

# 給水ポンプ制御
MOISTURE_LIMIT = 300    # 乾燥閾値（土壌湿度センサーがこの数値を下回ったらポンプで給水する）
SUPPLY_TIME = 3         # 給水時間（秒）
RELAY_PIN = 26


def readadc(adcnum, clockpin, mosipin, misopin, cspin):
    if adcnum > 7 or adcnum < 0:
        return -1
    GPIO.output(cspin, GPIO.HIGH)
    GPIO.output(clockpin, GPIO.LOW)
    GPIO.output(cspin, GPIO.LOW)
    commandout = adcnum
    commandout |= 0x18
    commandout <<= 3
    for i in range(5):
        if commandout & 0x80:
            GPIO.output(mosipin, GPIO.HIGH)
        else:
            GPIO.output(mosipin, GPIO.LOW)
        commandout <<= 1
        GPIO.output(clockpin, GPIO.HIGH)
        GPIO.output(clockpin, GPIO.LOW)
    adcout = 0
    for i in range(13):
        GPIO.output(clockpin, GPIO.HIGH)
        GPIO.output(clockpin, GPIO.LOW)
        adcout <<= 1
        if i>0 and GPIO.input(misopin)==GPIO.HIGH:
            adcout |= 0x1
    GPIO.output(cspin, GPIO.HIGH)
    return adcout


# センシングデータをサーバに送信
def send_data(item_num, data):
    obj = {
        "user_id": USER_ID,
        "item": ITEM,
        "item_num": item_num,
        "regist_date": datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
        "sensing_data": str(data),
    }
    json_data = json.dumps(obj).encode("utf-8")
    print(json_data) # for debug
    # httpリクエストを準備してPOST
    request = urllib.request.Request(URL, data=json_data, method="POST", headers={"Content-Type": "application/json", })
    with urllib.request.urlopen(request) as response:
        response_body = response.read().decode("utf-8")
    if "Error" in response_body:
        print("response_body Error") # for debug
    else:
        interval_time = int(response_body)  # インターバルをクラウドから取得した数値を入れる

    print(interval_time) # for debug
    return(interval_time)


# 給水ポンプを起動
def supply_water():
    print("給水開始 "+str(SUPPLY_TIME)+"秒間")  # for debug
    GPIO.output(RELAY_PIN, True)
    time.sleep(SUPPLY_TIME)
    GPIO.output(RELAY_PIN, False)
    time.sleep(0.5)


# 決められた時間間隔でのセンシング
def main():
    GPIO.setwarnings(False)  # GPIOのWarning非表示
    GPIO.setmode(GPIO.BCM)
    GPIO.setup(SPICLK, GPIO.OUT)
    GPIO.setup(SPIMOSI, GPIO.OUT)
    GPIO.setup(SPIMISO, GPIO.IN)
    GPIO.setup(SPICS, GPIO.OUT)
    GPIO.setup(RELAY_PIN, GPIO.OUT)
    pin_count = 0  # CH0から使用するセンサー分をカウントする
    try:
        while True:
            moisture_data = readadc(pin_count, SPICLK, SPIMOSI, SPIMISO, SPICS)
            if moisture_data < MOISTURE_LIMIT:
                supply_water()
            print(datetime.now().strftime('%Y/%m/%d,%H:%M:%S, ') + str(moisture_data))  # for debug
            interval_time = send_data(pin_count+1, moisture_data)
            time.sleep(interval_time)
            pin_count += 1
            print("pin_count="+str(pin_count))  # for debug
            if pin_count == SENSOR_NUM:
                pin_count = 0
    except KeyboardInterrupt:
        pass
    finally:
        GPIO.cleanup()

if __name__ == '__main__':
    main()