當然,以下是一個使用 Paho MQTT 庫的Python範例程式,用於連接到設有帳號密碼保護的MQTT Broker並發送資料。
首先,請確保您已經安裝了 paho-mqtt
庫,您可以使用以下命令進行安裝:
pip install paho-mqtt
接下來,您可以使用以下範例程式碼來連接到MQTT Broker並發送資料:
import paho.mqtt.client as mqtt
# 設定 MQTT Broker 的資訊
broker_address = "your_broker_address" # 替換為您的 Broker 地址
broker_port = 1883 # MQTT Broker 的端口號
username = "your_username" # 您的 MQTT 帳號
password = "your_password" # 您的 MQTT 密碼
# 建立 MQTT 用戶端
client = mqtt.Client()
client.username_pw_set(username, password) # 設定帳號密碼
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to MQTT Broker")
else:
print("Connection failed with code", rc)
def on_publish(client, userdata, mid):
print("Message Published")
client.on_connect = on_connect
client.on_publish = on_publish
# 連接到 Broker
client.connect(broker_address, broker_port)
# 發送資料
topic = "your_topic" # 替換為您的主題
message = "Hello, MQTT!" # 您要發送的訊息
# 發佈訊息
client.loop_start() # 開始處理 MQTT 事件迴圈
client.publish(topic, message) # 發佈訊息
client.loop_stop() # 停止 MQTT 事件迴圈
請將 your_broker_address
、your_username
、your_password
和 your_topic
替換為您的實際資訊。這個範例程式會建立一個 MQTT 用戶端,使用提供的帳號密碼進行連接,然後發送一條訊息到指定的主題。
請注意,這只是一個簡單的範例程式,實際上您可能需要根據您的需求進行更多的處理和錯誤處理。