Raspberry Pi Zero上のEclipse Mosquittoとpaho MQTTで、Grove Base HAT for Raspberry PiとGroveボタンのイベントを送受信する

Raspberry Pi Zero上のEclipse Mosquittoとpaho MQTTで、Grove Base HAT for Raspberry PiとGroveボタンのイベントを送受信するには、以下の手順を実行します。

実装手順

1. grove.pyとpaho-mqttモジュールをインストール
以下のコマンドでgrove.pyとpaho-mqttモジュールをインストールします。

curl -sL https://github.com/Seeed-Studio/grove.py/raw/master/install.sh | sudo bash -s -

pip3 install paho-mqtt

2. paho MQTTでメッセージを受信するプログラムを作成する
以下のプログラムで受け取ったボタンのイベントを表示します。

mosquitto_sub_grove_button.py

import paho.mqtt.client as mqtt

topic = "mosquitto/test"
host = "localhost"
port = 1883
secs_keep_alive=60

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    client.subscribe(topic)

def on_message(client, userdata, msg):
    print("received: {}".format(msg.topic))
    print(str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(host, port, secs_keep_alive)

client.loop_forever()

・実行方法
以下のコマンドで受信プログラムを実行します。止める場合はCtrl+Cで止めてください。

python3 mosquitto_sub_grove_button.py

3. ボタンのイベントの送信
以下のプログラムでボタンのイベントを送信します。止める場合はCtrl+Cで止めます。

mosquitto_pub_grove_button.py

import paho.mqtt.publish as publish
from grove.grove_button import GroveButton
import time

PIN_D16 = 16
button = GroveButton(PIN_D16)

topic = "mosquitto/test"
host = "localhost"
port = 1883
secs_keep_alive=60

def on_press(duration):
  publish.single(topic, "pressed: after released {:.2f}s".format(duration), hostname=host, port=port, keepalive=secs_keep_alive)


def on_release(duration):
  publish.single(topic, "released: after pressed {:.2f}s".format(duration), hostname=host, port=port, keepalive=secs_keep_alive)


button.on_press = on_press
button.on_release = on_release

print("press grove button...")
while True:
  time.sleep(1)

・実行方法
以下のコマンドで送信プログラムを実行します。

python3 mosquitto_pub_grove_button.py

関連情報

・Groveデバイスまとめ

・Raspberry Pi Zeroと小型ターンテーブルをREST APIで制御する