python使用MQTT协议发送报文消息

python使用mqtt发送消息#!/usr/bin/python# -*- coding: utf-8 -*import timeimport paho.mqtt.publish as publishimport mathimport json# 服务器地址host = '8.8.8.8'# 通信端口port = 1883username = 'emi_box'pa...

余晖下的少爷

1694人浏览 · 2019-12-15 20:35:53

余晖下的少爷 · 2019-12-15 20:35:53 发布

python使用mqtt发送消息

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

import time
import paho.mqtt.publish as publish
import math
import json

# 服务器地址
host = '8.8.8.8'
# 通信端口
port = 1883

username = 'emi_box'
password = 'public'

# 发送的主题
topic = 'emi/iot/tractors/server2'


def send_message():
        push_data = {
            "apiCode": 6666,
            "data": {
                'test': 'data'
            }}
        # 发送一次消息后断开连接
        publish.single(topic=topic, payload=json.dumps(push_data), qos=1, client_id=str(math.floor(time.time())),
                                   auth={"username": username, "password": password}, hostname=host, retain=False)


if __name__ == '__main__':
    send_message()