46 lines
1.2 KiB
Python
46 lines
1.2 KiB
Python
# %%
|
|
from paho.mqtt import client as mqtt_client
|
|
|
|
broker = '123.249.75.235'
|
|
port = 1883
|
|
topic = "python/mqtt"
|
|
client_id = f'python-mqtt-{random.randint(0, 1000)}'
|
|
username = 'TTE0101TC2311000003'
|
|
password = 'qh10579lcb7au8o2'
|
|
|
|
|
|
# %%
|
|
import random
|
|
from paho.mqtt import client as mqtt_client
|
|
|
|
broker = '123.249.75.235'
|
|
port = 1883
|
|
topic = "python/mqtt"
|
|
client_id = f'python-mqtt-{random.randint(0, 1000)}'
|
|
username = 'TTE0101TC2311000003'
|
|
password = 'qh10579lcb7au8o2'
|
|
|
|
|
|
# %%
|
|
def connect_mqtt():
|
|
def on_connect(client, userdata, flags, rc):
|
|
# For paho-mqtt 2.0.0, you need to add the properties parameter.
|
|
# def on_connect(client, userdata, flags, rc, properties):
|
|
if rc == 0:
|
|
print("Connected to MQTT Broker!")
|
|
else:
|
|
print("Failed to connect, return code %d\n", rc)
|
|
# Set Connecting Client ID
|
|
client = mqtt_client.Client(client_id)
|
|
|
|
# For paho-mqtt 2.0.0, you need to set callback_api_version.
|
|
# client = mqtt_client.Client(client_id=client_id, callback_api_version=mqtt_client.CallbackAPIVersion.VERSION2)
|
|
|
|
# client.username_pw_set(username, password)
|
|
client.on_connect = on_connect
|
|
client.connect(broker, port)
|
|
return client
|
|
|
|
|
|
|