在 Flask 中導入 Requests 並設置 Flask-MQTT 配置

在這節課中，我們將學習如何在 Flask 應用中導入 Flask 和 requests 庫，並設置 Flask-MQTT 的相關配置，以實現 MQTT 通信功能。這些步驟將幫助您快速建立一個可以與 MQTT Broker 通信的 Flask 應用。

步驟 1：導入必要的庫

首先，我們需要導入 Flask 應用所需的庫，包括 Flask、requests、flask_mqtt，以及其他必要的模組。

from flask import Flask, request, json
from flask.views import MethodView
from flask_mqtt import Mqtt
import requests

解釋：

• Flask：用於創建 Flask Web 應用的核心庫。
• request 和 json：用於處理 HTTP 請求和 JSON 數據的模組。
• MethodView：支持基於類的視圖，讓您可以使用面向對象的方式定義路由處理邏輯。
• Mqtt：Flask-MQTT 擴展，用於集成 MQTT 功能。
• requests：用於發送 HTTP 請求的流行 Python 庫。

步驟 2：初始化 Flask 應用並配置 Flask-MQTT

接下來，我們需要初始化 Flask 應用並配置 Flask-MQTT 的相關參數，以便與 MQTT Broker 通信。

app = Flask(__name__)

# 配置 Flask-MQTT 的參數
app.config['MQTT_BROKER_URL'] = 'broker.emqx.io'  # MQTT Broker 的 URL
app.config['MQTT_BROKER_PORT'] = 1883  # MQTT Broker 的端口號
# 如果 Broker 需要身份驗證，取消以下行的註釋並填寫用戶名和密碼
# app.config['MQTT_USERNAME'] = 'xxxx'
# app.config['MQTT_PASSWORD'] = 'xxxx'
# app.config['MQTT_REFRESH_TIME'] = 1.0  # 刷新連線的時間間隔（秒）

# 初始化 MQTT 擴展
mqtt = Mqtt(app)

• 配置參數解釋：
  • MQTT_BROKER_URL：設置 MQTT Broker 的 URL。在這裡，我們使用公共的 broker.emqx.io 來進行測試。
  • MQTT_BROKER_PORT：設置 MQTT Broker 的端口號。1883 是 MQTT 的默認端口。
  • MQTT_USERNAME 和 MQTT_PASSWORD：如果您的 MQTT Broker 需要身份驗證，請填寫用戶名和密碼並取消註釋。
  • MQTT_REFRESH_TIME：設置 MQTT 客戶端與 Broker 保持連接的刷新時間間隔，單位是秒。

步驟 3：解釋配置與擴展初始化

1. MQTT Broker URL 和端口號：
   • 這兩個參數用於指定您將要連接的 MQTT 代理服務器的地址和端口。這些是 MQTT 客戶端與服務器通信的基本信息。
2. 身份驗證：
   • 如果 MQTT 代理服務器需要身份驗證（即要求用戶名和密碼），您可以通過設置 MQTT_USERNAME 和 MQTT_PASSWORD 來提供這些憑據。這對於需要保護的 MQTT 代理非常重要。
3. 刷新連線的時間間隔：
   • MQTT_REFRESH_TIME 用於設置客戶端與 Broker 之間的心跳間隔。這確保了客戶端保持連接並檢測網絡中斷或服務器斷開的情況。

步驟 4：完成配置並啟動應用

設置完成後，您的 Flask 應用就可以開始與 MQTT Broker 進行通信了。您可以繼續添加路由來處理不同的 MQTT 消息或發送 HTTP 請求。