1234567891011121314151617181920212223242526272829303132333435363738394041424344454647 |
- # -*- coding: utf-8 -*-
- """
- Created on Thu Dec 28 11:41:03 2023
- @author: husts
- """
- import random
- from paho.mqtt import client as mqtt_client
- broker = '119.45.101.222'
- port = 1883
- topic = "zh_testarea_m"
- # generate client ID with pub prefix randomly
- client_id = f'python-mqtt-{random.randint(0, 100)}'
- def connect_mqtt() -> mqtt_client:
- def on_connect(client, userdata, flags, rc):
- if rc == 0:
- print("Connected to MQTT Broker!")
- else:
- print("Failed to connect, return code %d\n", rc)
- client = mqtt_client.Client(client_id)
- client.on_connect = on_connect
- client.connect(broker, port)
- return client
- def subscribe(client: mqtt_client):
- def on_message(client, userdata, msg):
- print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
- client.subscribe(topic)
- client.on_message = on_message
- def run():
- client = connect_mqtt()
- subscribe(client)
- client.loop_forever()
- if __name__ == '__main__':
- run()
|