Watson IoT Platform - MQTT - Publish/Subscribeしてみる

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

Publishしてみる

1. 下記のようなプログラムを使ってpublishします。
2. トピック名やClientID、payload(送付するデータ)などを変化させて試してみます。

pub.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

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

topic = "topic/test"
clientID = "pubTester"
broker = "172.16.xxx.xxx"

mqttc = mqtt.Client(clientID)
mqttc.connect(host=broker, port=1883, keepalive=60)
while mqttc.loop() == 0:

    temp = random.randrange(-10,40)
    humidity = random.randrange(20,99)
    print "temp = " + str(temp) + ", humidity = " + str(humidity)
    msg = " {\"d\": {\"temperature\": " + str(temp) +",\"humidity\": " + str(humidity) + "} }";

    mqttc.publish(topic, payload=msg, qos=0, retain=False)
    print "message published"

    time.sleep(1)

Subscribeしてみる

1. 下記のようなプログラムを使ってsubscribeします。
2. トピック名やClientIDなどを変化させて試してみます。

sub.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

import paho.mqtt.client as mqtt

topic = "topic/test"
clientID = "subTester"
broker = "172.16.xxx.xxx"

def on_connect(client, userdata, flags, rc):
    print("connected")
    client.subscribe(topic)

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

mqttc = mqtt.Client(clientID)

mqttc.on_connect = on_connect
mqttc.on_message = on_message

mqttc.connect(host=broker, port=1883, keepalive=60)

mqttc.loop_forever()