# 服务器地址
host = '192.168.66.250'
# 通信端口
port = 1883
username = '123'
password = '123'
# 发送的主题
topic = 'emi/cpu/cputemp'
def send_message():
# push_data = cputemp
push_data = {
"cputemp":cputemp,
"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()
就是这样搞个循环不停的发就行了
|