サンプルアプリからQuickstartへpublish

16874 ワード
wiotp wiotp309 watsoniotplatform mqtt IoT mqtt テキストリンク

初めてWatson IoT Platformを使ってみよう、というかたのためのガイドです。
Watson IoT Platformを使ってみるでIoTアプリを準備しました。

サンプルアプリからQuickstartへpublish

  • 以下のアプリを使用してQuickstartへpublishします
  • python pub.pyで実行します
pub.py
#!/usr/bin/python
# -*- coding: utf-8 -*-

import time
import paho.mqtt.client as mqtt
import random
import sys

MQTT_BROKER="quickstart.messaging.internetofthings.ibmcloud.com"

MQTT_PORT=1883
MQTT_TIMEOUT=60

MQTT_PUB_TOPIC="iot-2/evt/status/fmt/json"

latTuple = (36.065269, 36.045284, 36.058608, 36.178417, 36.305790, 36.293616, 36.238253, 36.172874, 35.976411, 35.878552, 35.987524)
longTuple = (-112.123288, -112.263364, -112.428159, -112.511929, -112.399319, -112.216672, -112.051877, -111.850003, -111.703061, -111.856870, -112.128781)

def on_connect(client, userdata, flags, rc):
    print("on connect")

def on_disconnect(client, userdata, rc):
    print("on disconnect")
    client.unsubscribe(MQTT_SUB_TOPIC)

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

def mqttConnect():
    print("mqttConnect")
    try:
        global client
        client = mqtt.Client("d:quickstart:myThing:001122334455")
        client.on_connect = on_connect
        client.on_message = on_message
        client.on_disconnect = on_disconnect
        client.connect(MQTT_BROKER,MQTT_PORT,MQTT_TIMEOUT)
        print("connected")
    except KeyboardInterrupt, kex:
        sys.exit()
    except Exception, ex:
        print("mqttConnect error")

def mqttPublish():
    while client.loop() == 0:
        for lat in latTuple:
            index = latTuple.index(lat)
            long =longTuple[index]
            temp = random.randrange(250,450)/10.0
            humid = random.randrange(500,1000)/10.0
            print "#" + str(index) + ", temp = " + str(temp) + ", humid = " + str(humid) + ", lat = " + str(lat) + ", long = " + str(long)
            msg = " {\"d\": {\"temperature\": " + str(temp) +",\"humidity\": " + str(humid) +", \"latitude\": " + str(lat) +", \"longitude\": " + str(long) + "} }";
            client.publish(MQTT_PUB_TOPIC, msg, 0, True)
            try:
                print raw_input("[Enter] to send another request")
            except:
                sys.exit()

def mqttPublishAuto():
    while client.loop() == 0:
        for lat in latTuple:
            try:
                index = latTuple.index(lat)
                long =longTuple[index]
                temp = random.randrange(250,450)/10.0
                humid = random.randrange(500,1000)/10.0
                print "#" + str(index) + ", temp = " + str(temp) + ", humid = " + str(humid) + ", lat = " + str(lat) + ", long = " + str(long)
                msg = " {\"d\": {\"Temperature\": " + str(temp) +",\"Humidity\": " + str(humid) +", \"latitude\": " + str(lat) +", \"longitude\": " + str(long) + "} }";
                client.publish(MQTT_PUB_TOPIC, msg, 0, True)
                time.sleep(2)
            except:
                sys.exit()

if __name__ == "__main__":
    print("--- started ---")
    mqttConnect()
    mqttPublishAuto()

    print("--- program ended ---")
  • Node-RED側ではDevice IDに上記の001122334455を指定して受信します。