【Xi IoTで映えるデモがしたい第13回】BrickPiにIoTさせる為のお作法

BrickPiははじめから LEGO のセンサーやモーターと動かすことはできますが、外部（Xi IoT Edge OSやら）と接続するにはIoTに特化したプロトコルでやりとりしてやる必要があります

プロトコルの選択

Xi IoTが現在対応しているのは

MQTT
RTSP
gigEvision

ここではそれぞれのプロトコルについては詳しくは説明しませんが（だってよく分からないのでググって）、今回のLEGOスマートファクトリーで行いたいのは、画像の送信と判定結果のやり取りなので、MQTT（Message Queuing Telemetry Transport）で Pub/Sub しちゃおうと思います

BrickPi上でMQTTで扱えるように、pythonモジュールをインストールします

pi@dex:~ $ sudo pip3 install paho-mqtt
Collecting paho-mqtt
  Downloading https://www.piwheels.org/simple/paho-mqtt/paho_mqtt-1.4.0-py3-none-any.whl (48kB)
    100% |████████████████████████████████| 51kB 97kB/s 
Installing collected packages: paho-mqtt
Successfully installed paho-mqtt-1.4.0

これで、pythonコード上でPub/Subできますよっ（超シンプル版）

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected on Edge with result code "+str(rc))
    # Subするトピック名
    client.subscribe("factory/#")

def on_message(client, userdata, msg):
    print(msg.topic+" - "+str(msg.payload))

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

mqclient.tls_set(ca_certs="mqtt-cert/CACertificate.crt", certfile="mqtt-cert/certificate.crt", keyfile="mqtt-cert/privateKey.key")
mqclient.tls_insecure_set(True)

mqclient.connect('<i>受け取るIPアドレス</i>', <i>受け取るポート</i>, 60)
mqclient.loop_start()

#Pubするトピック名とメッセージ
mqclient.publish("image",payload=xxxx)