IoT-For-Beginners/translations/mo/1-getting-started/lessons/4-connect-internet

將您的設備連接到互聯網

手繪筆記由 Nitya Narasimhan 提供。點擊圖片查看更大版本。

本課程是 Microsoft Reactor 的 Hello IoT 系列 的一部分。課程分為兩個視頻進行教學——一個1小時的課程和一個1小時的辦公時間，深入探討課程的部分內容並回答問題。

🎥 點擊上方圖片觀看視頻

課前測驗

課前測驗

簡介

IoT 中的 I 代表 Internet（互聯網）——雲端連接和服務使 IoT 設備的許多功能得以實現，例如從連接到設備的傳感器收集測量數據，或發送消息以控制執行器。IoT 設備通常使用標準通信協議連接到單一的雲端 IoT 服務，而該服務則與您的 IoT 應用的其他部分相連，例如 AI 服務用於根據數據做出智能決策，或網頁應用用於控制或報告。

🎓 從傳感器收集並發送到雲端的數據稱為遙測。

IoT 設備可以接收來自雲端的消息。這些消息通常包含命令——即指示執行某些操作的指令，無論是內部操作（例如重啟或更新固件），還是使用執行器（例如打開燈光）。

本課程介紹了 IoT 設備用於連接雲端的一些通信協議，以及它們可能發送或接收的數據類型。您還將親自操作，為您的夜燈添加互聯網控制，將 LED 控制邏輯移至本地運行的“服務器”代碼。

在本課程中，我們將涵蓋：

• 通信協議
• 消息隊列遙測傳輸（MQTT）
• 遙測
• 命令

通信協議

IoT 設備用於與互聯網通信的流行通信協議有很多。其中最流行的是基於某種代理的發布/訂閱消息。IoT 設備連接到代理並發布遙測數據，同時訂閱命令。雲端服務也連接到代理，訂閱所有遙測消息並發布命令，這些命令可以針對特定設備或設備組。

MQTT 是 IoT 設備最流行的通信協議，本課程將介紹它。其他協議包括 AMQP 和 HTTP/HTTPS。

消息隊列遙測傳輸（MQTT）

MQTT 是一種輕量級的開放標準消息協議，可在設備之間傳遞消息。它於1999年設計用於監控石油管道，15年後由 IBM 作為開放標準發布。

MQTT 有一個單一的代理和多個客戶端。所有客戶端都連接到代理，代理根據需要將消息路由到相關客戶端。消息通過命名主題進行路由，而不是直接發送到個別客戶端。客戶端可以發布到某個主題，任何訂閱該主題的客戶端都會收到消息。

✅ 做些研究。如果您有大量 IoT 設備，如何確保您的 MQTT 代理能夠處理所有消息？

將您的 IoT 設備連接到 MQTT

為夜燈添加互聯網控制的第一步是將其連接到 MQTT 代理。

任務

將您的設備連接到 MQTT 代理。

在本課程的這部分，您將把 IoT 夜燈連接到互聯網，以便遠程控制。稍後在本課程中，您的 IoT 設備將通過 MQTT 向公共 MQTT 代理發送光線水平的遙測消息，該消息將由您編寫的服務器代碼接收。此代碼將檢查光線水平並向設備發送命令消息，指示其打開或關閉 LED。

這種設置的實際應用場景可能是從多個光線傳感器收集數據後再決定是否打開燈光，例如在有大量燈光的地方，如體育場。這樣可以避免僅因一個傳感器被雲層或鳥遮擋而打開燈光，而其他傳感器檢測到足夠的光線。

✅ 還有哪些情況需要在發送命令之前評估多個傳感器的數據？

為了簡化本次作業中 MQTT 代理的設置，您可以使用一個運行 Eclipse Mosquitto 的公共測試服務器，這是一個開源的 MQTT 代理。此測試代理可在 test.mosquitto.org 公開使用，且不需要設置帳戶，是測試 MQTT 客戶端和服務器的絕佳工具。

💁 此測試代理是公開且不安全的。任何人都可以監聽您發布的內容，因此不應用於需要保密的數據。

按照以下相關步驟將您的設備連接到 MQTT 代理：

• Arduino - Wio Terminal
• 單板計算機 - Raspberry Pi/虛擬 IoT 設備

深入了解 MQTT

主題可以有層次結構，客戶端可以使用通配符訂閱不同層次的主題。例如，您可以將溫度遙測消息發送到 /telemetry/temperature 主題，將濕度消息發送到 /telemetry/humidity 主題，然後在您的雲端應用中訂閱 /telemetry/* 主題以接收溫度和濕度的遙測消息。

消息可以設置服務質量（QoS），以確定消息接收的保證程度。

• 最多一次 - 消息僅發送一次，客戶端和代理不採取額外步驟確認交付（即發送後不再關注）。
• 至少一次 - 發送方多次重試消息，直到收到確認（即確認交付）。
• 恰好一次 - 發送方和接收方進行兩級握手，以確保僅接收一份消息（即保證交付）。

✅ 哪些情況可能需要保證交付的消息，而不是發送後不再關注的消息？

雖然 MQTT 的名稱中有消息隊列（Message Queueing），但它實際上並不支持消息隊列。這意味著如果客戶端斷開連接，然後重新連接，它不會接收到斷開期間發送的消息，除非這些消息已通過 QoS 過程開始處理。消息可以設置保留標誌。如果設置了此標誌，MQTT 代理將存儲該主題上最後發送的消息，並將其發送給後來訂閱該主題的客戶端。這樣，客戶端將始終獲得最新消息。

MQTT 還支持保持連接功能，在消息之間的長時間間隔期間檢查連接是否仍然有效。

🦟 Eclipse Foundation 的 Mosquitto 提供了一個免費的 MQTT 代理，您可以自行運行以實驗 MQTT，還有一個公共 MQTT 代理可用於測試您的代碼，托管於 test.mosquitto.org。

MQTT 連接可以是公開和開放的，也可以通過用戶名和密碼或證書進行加密和安全保護。

💁 MQTT 通過 TCP/IP 進行通信，這與 HTTP 使用的底層網絡協議相同，但使用不同的端口。您還可以通過 Websockets 使用 MQTT 與在瀏覽器中運行的網頁應用通信，或者在防火牆或其他網絡規則阻止標準 MQTT 連接的情況下使用。

遙測

遙測一詞源於希臘語，意為遠程測量。遙測是從傳感器收集數據並將其發送到雲端的行為。

💁 最早的遙測設備之一於1874年在法國發明，通過物理電線將蒙特布朗的即時天氣和積雪深度數據傳送到巴黎。當時尚未有無線技術。

讓我們回顧一下課程1中的智能溫控器示例。

溫控器具有溫度傳感器以收集遙測數據。它很可能內置一個溫度傳感器，並可能通過無線協議（例如 Bluetooth Low Energy）連接到多個外部溫度傳感器。

它可能發送的遙測數據示例如下：

名稱	值	描述
thermostat_temperature	18°C	由溫控器內置溫度傳感器測量的溫度
livingroom_temperature	19°C	由遠程溫度傳感器測量的溫度，該傳感器已命名為 livingroom 以識別其所在房間
bedroom_temperature	21°C	由遠程溫度傳感器測量的溫度，該傳感器已命名為 bedroom 以識別其所在房間

雲端服務可以使用這些遙測數據來決定發送哪些命令以控制加熱。

從您的 IoT 設備發送遙測數據

為夜燈添加互聯網控制的下一步是將光線水平的遙測數據發送到 MQTT 代理的遙測主題。

任務 - 從您的 IoT 設備發送遙測數據

將光線水平的遙測數據發送到 MQTT 代理。

數據以 JSON 格式編碼——JSON 是 JavaScript Object Notation 的縮寫，是一種使用鍵/值對以文本形式編碼數據的標準。

✅ 如果您之前未接觸過 JSON，可以在 JSON.org 文檔 中了解更多。

按照以下相關步驟從您的設備向 MQTT 代理發送遙測數據：

• Arduino - Wio Terminal
• 單板計算機 - Raspberry Pi/虛擬 IoT 設備

從 MQTT 代理接收遙測數據

如果沒有接收端，發送遙測數據就沒有意義。光線水平的遙測數據需要有接收端來處理這些數據。該“服務器”代碼是您將作為更大 IoT 應用的一部分部署到雲端服務的代碼，但在這裡，您將在本地計算機上運行此代碼（或者如果您直接在 Raspberry Pi 上編碼，也可以在 Pi 上運行）。服務器代碼由一個 Python 應用組成，該應用通過 MQTT 接收光線水平的遙測消息。稍後在本課程中，您將使其回覆命令消息，指示打開或關閉 LED。

✅ 做些研究：如果沒有接收端，MQTT 消息會發生什麼？

安裝 Python 和 VS Code

如果您本地尚未安裝 Python 和 VS Code，您需要安裝它們以編寫服務器代碼。如果您使用虛擬 IoT 設備或在 Raspberry Pi 上工作，則可以跳過此步驟，因為您應該已經安裝並配置好。

任務 - 安裝 Python 和 VS Code

安裝 Python 和 VS Code。

1. 安裝 Python。請參考 Python 下載頁面 以獲取安裝最新版本 Python 的說明。

2. 安裝 Visual Studio Code (VS Code)。這是您將用來用 Python 編寫虛擬設備代碼的編輯器。請參考 VS Code 文檔 以獲取安裝 VS Code 的說明。 💁 您可以自由選擇任何 Python IDE 或編輯器來完成這些課程，如果您有偏好的工具，但課程中的指導將基於使用 VS Code。

3. 安裝 VS Code 的 Pylance 擴充套件。這是一個為 VS Code 提供 Python 語言支援的擴充套件。請參考 Pylance 擴充套件文件 以了解如何在 VS Code 中安裝此擴充套件。

配置 Python 虛擬環境

Python 的一個強大功能是能夠安裝 pip 套件——這些是由其他人撰寫並發布到網路上的程式碼套件。你可以使用一個指令將 pip 套件安裝到你的電腦上，然後在程式碼中使用該套件。接下來你將使用 pip 安裝一個用於 MQTT 通訊的套件。

預設情況下，當你安裝一個套件時，它會在你的電腦上全域可用，這可能會導致套件版本的問題，例如某個應用程式依賴於某個版本的套件，但當你為另一個應用程式安裝新版本時，可能會導致問題。為了解決這個問題，你可以使用 Python 虛擬環境，它本質上是 Python 的一個副本，存放在專用的資料夾中，當你安裝 pip 套件時，它們只會安裝到該資料夾中。

任務 - 配置 Python 虛擬環境

配置 Python 虛擬環境並安裝 MQTT 的 pip 套件。

1. 在終端或命令列中，執行以下指令以在你選擇的位置建立並進入一個新目錄：

   mkdir nightlight-server
   cd nightlight-server
   

2. 現在執行以下指令，在 .venv 資料夾中建立虛擬環境：

   python3 -m venv .venv
   

   💁 你需要明確呼叫 python3 來建立虛擬環境，以防你的系統同時安裝了 Python 2 和 Python 3（最新版本）。如果安裝了 Python 2，呼叫 python 可能會使用 Python 2 而不是 Python 3。

3. 啟動虛擬環境：

   • 在 Windows 上：

     • 如果你使用命令提示字元，或透過 Windows Terminal 使用命令提示字元，執行以下指令：

       .venv\Scripts\activate.bat
       

     • 如果你使用 PowerShell，執行以下指令：

       .\.venv\Scripts\Activate.ps1
       

   • 在 macOS 或 Linux 上，執行以下指令：

     source ./.venv/bin/activate
     

   💁 這些指令應該在你執行建立虛擬環境的指令的同一位置執行。你永遠不需要進入 .venv 資料夾，應該始終在建立虛擬環境的資料夾中執行啟動指令以及任何安裝套件或執行程式碼的指令。

4. 啟動虛擬環境後，預設的 python 指令將執行用於建立虛擬環境的 Python 版本。執行以下指令以檢查版本：

   python --version
   

   輸出類似以下內容：

   (.venv) ➜  nightlight-server python --version
   Python 3.9.1
   

   💁 你的 Python 版本可能不同——只要是 3.6 或更高版本即可。如果不是，請刪除此資料夾，安裝更新版本的 Python，然後重試。

5. 執行以下指令以安裝 Paho-MQTT 的 pip 套件，這是一個流行的 MQTT 庫。

   pip install paho-mqtt
   

   此 pip 套件僅會安裝在虛擬環境中，且在虛擬環境外不可用。

撰寫伺服器程式碼

現在可以使用 Python 撰寫伺服器程式碼。

任務 - 撰寫伺服器程式碼

撰寫伺服器程式碼。

1. 在虛擬環境中，透過終端或命令列執行以下指令以建立名為 app.py 的 Python 檔案：

   • 在 Windows 上執行：

     type nul > app.py
     

   • 在 macOS 或 Linux 上執行：

     touch app.py
     

2. 在 VS Code 中開啟目前資料夾：

   code .
   

3. 當 VS Code 啟動時，它會啟動 Python 虛擬環境。這會顯示在底部狀態列中：

   

4. 如果 VS Code 的終端在啟動時已經在執行，它可能不會啟動虛擬環境。最簡單的解決方法是使用 終止活動終端實例 按鈕終止終端：

   

5. 透過選擇 終端 -> 新終端 或按下 CTRL+` 啟動新的 VS Code 終端。新的終端會載入虛擬環境，並在終端中顯示啟動指令。虛擬環境的名稱（.venv）也會顯示在提示符中：

   ➜  nightlight-server source .venv/bin/activate
   (.venv) ➜  nightlight 
   

6. 從 VS Code 的檔案瀏覽器中開啟 app.py 檔案，並加入以下程式碼：

   import json
   import time
   
   import paho.mqtt.client as mqtt
   
   id = '<ID>'
   
   client_telemetry_topic = id + '/telemetry'
   client_name = id + 'nightlight_server'
   
   mqtt_client = mqtt.Client(client_name)
   mqtt_client.connect('test.mosquitto.org')
   
   mqtt_client.loop_start()
   
   def handle_telemetry(client, userdata, message):
       payload = json.loads(message.payload.decode())
       print("Message received:", payload)
   
   mqtt_client.subscribe(client_telemetry_topic)
   mqtt_client.on_message = handle_telemetry
   
   while True:
       time.sleep(2)
   

   將第 6 行的 <ID> 替換為你在建立裝置程式碼時使用的唯一 ID。

   ⚠️ 此 ID 必須與你在裝置上使用的 ID 相同，否則伺服器程式碼將無法訂閱或發布到正確的主題。

   此程式碼建立了一個具有唯一名稱的 MQTT 客戶端，並連接到 test.mosquitto.org broker。接著它啟動了一個處理迴圈，該迴圈在背景執行緒中運行，監聽任何已訂閱主題的訊息。

   客戶端接著訂閱了 telemetry 主題的訊息，並定義了一個函數，當接收到訊息時會被呼叫。當接收到 telemetry 訊息時，handle_telemetry 函數會被呼叫，並將接收到的訊息打印到控制台。

   最後，一個無限迴圈保持應用程式運行。MQTT 客戶端在背景執行緒中監聽訊息，並在主應用程式運行期間始終保持運行。

7. 從 VS Code 的終端執行以下指令以運行你的 Python 應用程式：

   python app.py
   

   應用程式將開始監聽來自 IoT 裝置的訊息。

8. 確保你的裝置正在運行並發送 telemetry 訊息。調整你的實體或虛擬裝置檢測的光線水平。接收到的訊息將打印到終端。

   (.venv) ➜  nightlight-server python app.py
   Message received: {'light': 0}
   Message received: {'light': 400}
   

   nightlight 虛擬環境中的 app.py 檔案必須正在運行，nightlight-server 虛擬環境中的 app.py 檔案才能接收到發送的訊息。

💁 你可以在 code-server/server 資料夾中找到此程式碼。

應該多久發送一次 telemetry？

關於 telemetry 的一個重要考量是應該多久測量並發送一次數據？答案是——視情況而定。如果頻繁測量，你可以更快地對測量變化做出反應，但這會消耗更多電力、更多頻寬，生成更多數據，並需要更多的雲端資源來處理。你需要測量得足夠頻繁，但不能過於頻繁。

對於溫控器，每隔幾分鐘測量一次可能已經足夠，因為溫度不會頻繁變化。如果你一天只測量一次，那麼可能會在晴天的中午因夜間溫度而加熱房屋；而如果你每秒測量一次，則會生成數千個不必要的重複溫度測量，這會影響使用者的網速和頻寬（對於有限頻寬計劃的使用者來說是個問題），消耗更多電力，這對於像遠端感測器這樣的電池供電裝置可能是個問題，並增加雲端計算資源的處理和存儲成本。

如果你在監控工廠中某台機器的數據，而該機器如果故障可能會造成災難性損失和數百萬美元的收入損失，那麼可能需要每秒多次測量。浪費頻寬總比錯過顯示機器需要停止並修復的 telemetry 更好。

💁 在這種情況下，你可能會考慮使用邊緣裝置來先處理 telemetry，以減少對網路的依賴。

連線中斷

網路連線可能不穩定，斷線是常見的情況。在這種情況下，IoT 裝置應該怎麼做——丟失數據，還是存儲數據直到連線恢復？答案同樣是視情況而定。

對於溫控器，數據可能可以在新的溫度測量完成後丟失。加熱系統不會在意 20 分鐘前的溫度是 20.5°C，如果現在的溫度是 19°C，那麼現在的溫度才是決定加熱是否開啟的關鍵。

對於機器，你可能希望保留數據，特別是如果這些數據用於趨勢分析。有些機器學習模型可以通過查看一段時間內的數據（例如過去一小時）來檢測數據流中的異常，並識別異常數據。這通常用於預測性維護，尋找可能即將發生故障的跡象，以便在故障發生前進行修理或更換。你可能希望每一個機器的 telemetry 都被發送，以便進行異常檢測，因此一旦 IoT 裝置重新連線，它將發送所有在網路中斷期間生成的 telemetry。

IoT 裝置設計者還應考慮 IoT 裝置在網路中斷或因位置導致信號丟失時是否仍能使用。一個智能溫控器應該能在無法將 telemetry 發送到雲端的情況下做出有限的決策來控制加熱。

為了讓 MQTT 處理連線中斷，裝置和伺服器程式碼需要負責確保訊息的傳遞，例如要求所有發送的訊息都需要在回覆主題上收到回覆訊息，如果沒有收到回覆，則手動排隊以便稍後重播。

指令

指令是由雲端發送到裝置的訊息，用於指示裝置執行某些操作。大多數情況下，這涉及通過致動器輸出某些內容，但也可能是對裝置本身的指令，例如重新啟動或收集額外的 telemetry 並將其作為指令的回應返回。

例如，溫控器可能會接收到來自雲端的指令以開啟加熱。根據所有感測器的 telemetry 數據，如果雲端服務決定應該開啟加熱，它就會發送相關指令。

向 MQTT broker 發送指令

接下來，我們的網路控制夜燈需要伺服器程式碼向 IoT 裝置發送指令，以根據感測到的光線水平控制燈光。

1. 在 VS Code 中開啟伺服器程式碼

2. 在 client_telemetry_topic 宣告之後新增以下一行，以定義要發送指令的主題：

   server_command_topic = id + '/commands'
   

3. 在 handle_telemetry 函數的結尾新增以下程式碼：

   command = { 'led_on' : payload['light'] < 300 }
   print("Sending message:", command)
   
   client.publish(server_command_topic, json.dumps(command))
   

   此程式碼向指令主題發送一個 JSON 訊息，其中 led_on 的值根據光線是否小於 300 設定為 true 或 false。如果光線小於 300，則發送 true 以指示裝置開啟 LED。

4. 如前所述運行程式碼

5. 調整你的實體或虛擬裝置檢測的光線水平。接收到的訊息和發送的指令將顯示在終端：

   (.venv) ➜  nightlight-server python app.py
   Message received: {'light': 0}
   Sending message: {'led_on': True}
   Message received: {'light': 400}
   Sending message: {'led_on': False}
   

💁 telemetry 和指令分別在單一主題上發送。這意味著來自多個裝置的 telemetry 會出現在同一 telemetry 主題上，而發送給多個裝置的指令會出現在同一指令主題上。如果你希望向特定裝置發送指令，可以使用多個主題，並以唯一的裝置 ID 命名，例如 /commands/device1、/commands/device2。這樣裝置就可以只監聽針對該裝置的訊息。

💁 你可以在 code-commands/server 資料夾中找到此程式碼。

在 IoT 裝置上處理指令

現在伺服器已經開始發送指令，你可以在 IoT 裝置上新增程式碼來處理指令並控制 LED。

按照以下相關步驟來監聽來自 MQTT broker 的指令：

• Arduino - Wio Terminal
• 單板電腦 - Raspberry Pi/虛擬 IoT 裝置

一旦程式碼撰寫完成並運行，嘗試改變光線水平。觀察伺服器和裝置的輸出，並在改變光線水平時觀察 LED 的反應。

連線中斷

如果雲端服務需要向離線的 IoT 裝置發送指令，應該怎麼做？答案同樣是視情況而定。

如果最新的指令覆蓋了早期的指令，那麼早期的指令可能可以忽略。如果雲端服務發送了一個開啟加熱的指令，然後又發送了一個關閉加熱的指令，那麼可以忽略開啟指令並不重新發送。

如果指令需要按順序處理，例如移動機器手臂向上，然後關閉抓取器，那麼需要在連線恢復後按順序發送。

✅ 如何讓裝置或伺服器程式碼確保指令在 MQTT 上始終按順序發送並處理？

---

🚀 挑戰

在過去三節課的挑戰是列出你家中、學校或工作場所中的所有 IoT 裝置，並判斷它們是基於微控制器還是單板電腦，或者是兩者的混合，並思考它們使用了哪些感測器和致動器。 對於這些設備，思考它們可能正在發送或接收什麼消息。它們發送了哪些遙測數據？可能接收到哪些消息或指令？你認為它們的安全性如何？

課後測驗

課後測驗

回顧與自學

在 MQTT 維基百科頁面上閱讀更多有關 MQTT 的內容。

嘗試自己運行一個 MQTT broker，使用 Mosquitto，並從你的 IoT 設備和伺服器代碼連接到它。

💁 提示 - Mosquitto 預設不允許匿名連接（即無需使用者名稱和密碼的連接），也不允許來自運行它的電腦外部的連接。 你可以通過使用 mosquitto.conf 配置文件進行修正，內容如下：

listener 1883 0.0.0.0
allow_anonymous true

作業

比較並對比 MQTT 與其他通信協議

---

免責聲明：
本文件已使用 AI 翻譯服務 Co-op Translator 進行翻譯。雖然我們致力於提供準確的翻譯，但請注意，自動翻譯可能包含錯誤或不準確之處。原始文件的母語版本應被視為權威來源。對於關鍵信息，建議使用專業人工翻譯。我們對因使用此翻譯而引起的任何誤解或誤釋不承擔責任。