1. import datetime
    3. import paho.mqtt.client as paho
    4. import json
    5. import time
    6. import random
    8. # 设备的访问令牌
    9. accessToken = "T8Uqq3g7sVZoBKfDE8uc"
    10. # thingsboard的服务器IP地址
    11. host = 'thingsboard-local'
    12. # `mqtt`的端口号
    13. port = 1883
    16. def on_publish(client, userdata, result):
    17.     print("时间: {}, client: {}, userdata: {}, result: {}".format(datetime.datetime.now(), client, userdata, result))
    18.     print("publish ...")
    21. def on_connect(client, userdata, flag, rc):
    22.     print(str(rc))
    23.     print("connect ...")
    24.     client.subscribe("v1/devices/me/rpc/request/+", qos=0);
    27. def on_subscribe(client, userdata, mid, granted_qos):
    28.     print("subscribe ...")
    31. def on_message(client, obj, msg):
    32.     print('receive message ...')
    33.     print("msg.payload: {}".format(msg.payload))
    34.     print("json.loads(msg.payload): {}".format(json.loads(msg.payload)))
    35.     # print("平台发布的需要修改的寄存器值是:", json.loads(msg.payload)['params'])
    36.     # 当收到平台发布的数据之后修改PLC的寄存器的值。modbus_tcp 的写操作。
    39. mqtt = paho.Client("device_id_dev_001")
    40. mqtt.on_publish = on_publish
    41. mqtt.on_connect = on_connect
    42. mqtt.on_subscribe = on_subscribe
    43. mqtt.on_message = on_message
    44. mqtt.username_pw_set(accessToken)
    45. mqtt.connect(host, port, keepalive=60)
    46. mqtt.loop_start()
    48. while True:
    49.     # 来自PLC，实际状况中读 modbus TCP的读寄存器值。eg:40001
    50.     data = {
    51.         "ts": int(time.time() * 1000),
    52.         "temperature": random.randint(0, 40),
    53.         "humidity": random.randint(5, 50)
    54.     }
    55.     # 模拟`硬件设备` 上报数据到 `thingsboard`服务端
    56.     mqtt.publish('v1/devices/me/telemetry', payload=json.dumps(data), qos=0)
    57.     time.sleep(1 * 60)  # 5秒发布一次数据