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("connect ...")
    25. def on_subscribe(client, userdata, mid, granted_qos):
    26.     print("subscribe ...")
    29. def on_message(client, obj, msg):
    30.     print('receive message ...')
    31.     print(msg.payload)
    32.     # print("平台发布的需要修改的寄存器值是:", json.loads(msg.payload)['params'])
    33.     # 当收到平台发布的数据之后修改PLC的寄存器的值。modbus_tcp 的写操作。
    36. mqtt = paho.Client("device_id_dev_001")
    37. mqtt.on_publish = on_publish
    38. mqtt.on_connect = on_connect
    39. mqtt.username_pw_set(accessToken)
    40. mqtt.connect(host, port, keepalive=60)
    41. mqtt.loop_start()
    43. while True:
    44.     # 来自PLC，实际状况中读 modbus TCP的读寄存器值。eg:40001
    45.     data = {
    46.         "ts": int(time.time() * 1000),
    47.         "temperature": random.randint(0, 40),
    48.         "humidity": random.randint(5, 50)
    49.     }
    50.     # 模拟`硬件设备` 上报数据到 `thingsboard`服务端
    51.     mqtt.publish('v1/devices/me/telemetry', payload=json.dumps(data), qos=0)
    52.     time.sleep(1 * 60)  # 5秒发布一次数据

    image.png