電子發(fā)燒友網(wǎng)>電子資料下載>電子資料>重訪The Things Industries (TTI) V3 Azure IoT連接器

重訪The Things Industries (TTI) V3 Azure IoT連接器

1946861 2023-06-14 | zip | 0.00 MB | 次下載 | 免費

資料介紹

描述

早在 2020 年 11 月，我就發(fā)布了我的 The Things Network V2 Azure IoT Hubs & IoT Central Gateway。該項目是關(guān)于構(gòu)建物聯(lián)網(wǎng) (TTN)HTTP 應(yīng)用程序集成，它啟用Azure IoT 中心和Azure IoT Central與Azure IoT 中心設(shè)備供應(yīng)服務(wù) (DPS)供應(yīng)支持的連接。

該項目使用了“符合流行語”的Microsoft Azure服務(wù)選擇，但它不支持云到設(shè)備 (C2D) 消息，存在消息排序問題，并且部署和設(shè)置復(fù)雜。（還有其他問題，但不值得在這里重新討論）

然后在 2021 年 3 月，我再次嘗試使用我的 The Things Industries(TTI) V3 Azure IoT 連接器，它是一個TTI（消息隊列遙測傳輸）MQTT 集成，也使用了 TTI應(yīng)用程序和終端設(shè)備 API 。

此版本使用MQTTNet （這是一個很棒的庫）和在應(yīng)用程序啟動時連接到Azure IoT Hub或Azure IoT Central的 TTI 設(shè)備。即使我使用多個線程并對 Application 和 EndDevice 請求進(jìn)行分頁，這個過程也很慢。

該應(yīng)用程序更容易調(diào)試，因為我可以在桌面上運行它，并且更容易配置，因為我將配置轉(zhuǎn)移回appsettings.json文件（我可能會重新考慮放棄Azure Key Vault支持的決定）。

此版本具有基本的Azure 數(shù)字孿生定義語言 (DTDL)支持，因此可以在Azure IoT Central中“自動”預(yù)配設(shè)備。

我還添加了對Azure IoT Hubs和Azure IoT Central的C2D 支持，并基于下行鏈路消息有效負(fù)載確認(rèn)標(biāo)志跟蹤消息傳遞。我發(fā)現(xiàn)TTI 交付進(jìn)度更新的順序可能有問題。

在生產(chǎn)環(huán)境中使用基于MQTT的集成后，我發(fā)現(xiàn)它過于“有狀態(tài)”并且無法從意外事件中很好地恢復(fù)。（還有其他問題，但不值得在這里重新討論）

然后在 2021 年 10 月，我決定我的“學(xué)習(xí)之旅”還沒有結(jié)束，我將構(gòu)建另一個TTI 連接器，該連接器將 Azure 存儲隊列用于 C2D 和 D2C 消息。

試用該應(yīng)用程序后，我意識到消息排序和部署復(fù)雜性可能是一個問題（我忘記了我的 TTN V2 網(wǎng)關(guān)學(xué)習(xí)），所以我暫停了項目。（雖然我確實認(rèn)為這個項目可能對一些集成項目有用）

此時，我回顧了從多個 TTI 集成項目中學(xué)到的知識，并決定再次嘗試使用The Things Stack(TTS) 網(wǎng)絡(luò)掛鉤集成。

我的“The Things Industries(TTI) V3 connector revisited”項目是一個身份轉(zhuǎn)換云網(wǎng)關(guān)，它將LoRaWAN EndDevices映射到Azure IoT Hub Devices 。

連接器為每個LoRaWAN設(shè)備創(chuàng)建一個DeviceClient ，并且可以使用Azure 設(shè)備連接字符串或Azure 設(shè)備預(yù)配服務(wù) (DPS) 。

The Things Industries Azure IoT 集成架構(gòu)

在我所有的集成中，TTI 一直是設(shè)備配置的單一事實來源 (SSOT) ，因為LoRaWAN配置設(shè)置的數(shù)量和復(fù)雜性會使從其他應(yīng)用程序管理它成為一個難題。（我還考慮過使用TTSEndDevice 模板來創(chuàng)建我可能會回來的設(shè)備）

當(dāng)前版本的一個限制是，EndDevice 將連接到Azure IoT Hub （提供應(yīng)用程序配置連接字符串或Azure IoT Hub DPS ），并且只有在收到 TTI 上行鏈路或Azure IoT Hub D2C 消息后才會處理 C2D 消息。一體化。

Azure IoT Hub 設(shè)備在第一個 TTI 上行鏈路上連接

這可能是一個問題（尤其是在重新啟動集成后）或配置了新設(shè)備。我考慮過添加幾個Azure HTTP 觸發(fā)器函數(shù)，應(yīng)用程序調(diào)用這些函數(shù)可以檢查設(shè)備的連接狀態(tài)并可選擇啟動連接。（短期內(nèi)從 TTI EndDevice 用戶界面或 API 模擬上行鏈路應(yīng)該可以工作）

我從D2C 消息傳遞開始，然后添加了C2D 消息傳遞，然后添加了支持DTDLV2 的 Device Provisioning(DPS) ，然后擴展了C2D 消息傳遞，最后實現(xiàn)了Azure IoT Central D2C和C2D （使用少參數(shù)、單值和JavaScript 對象表示法（JSON ）有效載荷命令）

Azure IoT Central 儀表板，用于我的測試環(huán)境中的 Seeeduino LoRaWAN 傳感器

該應(yīng)用程序的核心是五個Azure HTTP 觸發(fā)函數(shù)（已發(fā)送函數(shù)當(dāng)前未使用）和一個為 C2D 調(diào)用的方法（與SetReceiveMessageHandlerAsync方法連接）消息。

Azure 門戶功能列表

Azure IoT 中心可以調(diào)用方法（同步）或將消息（異步）發(fā)送到設(shè)備進(jìn)行處理。Azure IoT 中心 DeviceClient有兩個方法SetMethodDefaultHandlerAsync和SetReceiveMessageHandlerAsync ，它們可以處理直接方法和消息。

在對以前的 TTI 連接器進(jìn)行了一些實驗之后，我發(fā)現(xiàn)DirectMethods的同步特性不適用于LoRAWAN通常“不規(guī)則”的上行鏈路，因此目前不支持它們。

該集成廣泛使用了Microsoft.Extensions.Logging功能和Azure Application Insights ，因此調(diào)試、監(jiān)控和故障查找更省時。

Azure Application Insights（說明搜索功能）

我已將有用的“元數(shù)據(jù)”添加到各個日志項中，因此更容易跟蹤為處理事件而執(zhí)行的所有步驟，例如 ReceiveMessageCallback 、AbandonAsync 、CompleteAsync和RejectAsync C2D 消息處理中使用的 LockToken。

應(yīng)用程序配置概述

可以使用appsettings.json文件配置應(yīng)用程序（對桌面開發(fā)和調(diào)試很有用）

{
   "Values": {
      "AzureWebJobsStorage": "DefaultEndpointsProtocol=https;AccountName=...",
      "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
      "APPINSIGHTS_INSTRUMENTATIONKEY": "..."
      },
      "TheThingsIndustries": {
      "WebhookBaseURL": "https://....eu1.cloud.thethings.industries/api/v3/as/applicat      ions",
      "Applications": {
         "seeeduinolorawan": {
         "webhookId": "azure-iot-hub-connector",
         "APIKey": "..."
         },
         "Wisnode Devices": {
         "webhookId": "azure-iot-hub-connector",
         "APIKey": "..."
         },
         "dragino-lht65": {
         "webhookId": "azure-iot-hub-connector",
         "APIKey": "..."
         },
         "SeeeduinoLoRaWAN100": {
         "webhookId": "azure-iot-hub-connector",
         "APIKey": "..."
         },
         "rak3172": {
            "webhookId": "azure-iot-hub-connector",
            "APIKey": "..."
         },
       "application1": {
          "webhookId": "azure-iot-hub-connector",
          "APIKey": "..."
        }
      }
   },
   "AzureIoT": {
      "DeviceClientCacheSlidingExpiration": "P2H30M",
      "IoTHub": {
         "IoTHubConnectionString": "HostName=...",
         "Applications": {
            "SeeeduinoLoRaWAN": {
            "DtdlModelId": "dtmi:ttnv3connectorclient:SeeeduinoLoRaWAN4cz;1"
            },
            "Wisnode Devices": {
            },
            "Dragino LHT65": {
            }
         }
      },
      "DeviceProvisioningService": {
         "IdScope": "0ne..",
         "Applications": {
         "seeeduinolorawan": {
            "DtdlModelId": "dtmi:ttnv3connectorclient:SeeeduinoLoRaWAN4cz;1",
            "GroupEnrollmentKey": "...",
         },
         "Wisnode Devices": {
            "GroupEnrollmentKey": "..."
         },
         "dragino-lht65": {
            "GroupEnrollmentKey": "..."
         },
         "rak3172": {
            "GroupEnrollmentKey": "..."
         },
      "application1": {
         "DtdlModelId": "dtmi:ttnv3connectorclient:FezduinoWisnodeV14x8;4",
         "GroupEnrollmentKey": "..."
      }
   }
},
"IoTCentral": {
   "methods": {
      "LightsGoOn": {
         "Port": 10,
         "Payload": "{"value_1": 1}"
      },
      "LightsGoOff": {
         "Port": 10,
         "Payload": "{"value_1": 0}"
      },
      "value_0": {
         "Port": 20
      },
      "value_1": {
         "Port": 21
      },
      "value_2": {
         "Port": 22
      },
      "TemperatureOOBAlertMinimumAndMaximum": {
         "Port": 23
      },
   }
}

暫存和生產(chǎn)部署的首選方法）是使用Azure 門戶Azure 功能配置刀片

Azure 門戶 Azure Function 配置

Things Industries Webhook 集成配置

要發(fā)送下行鏈路和接收上行鏈路消息，必須配置 TTI 應(yīng)用程序和TTI 連接器并配置 API 密鑰。

注意 – TTN URL 和 Azure IoT 中心設(shè)備標(biāo)識符區(qū)分大小寫

Azure Function 配置 TTI webhook 配置設(shè)置

TTI 連接器需要webhookbaseURL ，然后是每個 TTI 應(yīng)用程序和一個API 密鑰，以及 WebhookId

Azure 功能配置應(yīng)用程序密鑰

當(dāng)調(diào)用 Azure Functions 時，Azure Function Host Key會在名為“x-functions-key”的HTTP 標(biāo)頭中傳遞

Azure Function API Key TTI Webhook 消息處理進(jìn)度配置

使用TTI App Key保護下行鏈路消息處理

顯示所需權(quán)限的 TTI 應(yīng)用程序密鑰創(chuàng)建

當(dāng)調(diào)用TTI webhook 下行鏈路端點時， TTI 應(yīng)用程序密鑰在標(biāo)準(zhǔn)HTTP 授權(quán)標(biāo)頭中傳遞。

使用 Azure Function 端點作為基本 URL 創(chuàng)建 TTI Webhook 集成

Azure IoT 中心連接配置

TTI 連接器需要共享訪問簽名 (SAS) 設(shè)備策略連接字符串才能連接到Azure IoT 中心。

突出顯示 Azure IoT 中心配置的 Azure 函數(shù)配置

Azure IoT 中心設(shè)備策略連接字符串配置刀片

Azure IoT Hub設(shè)備必須手動或通過Azure IoT Hub REST API進(jìn)行預(yù)配。我已經(jīng)試用了一個Azure 邏輯應(yīng)用程序，它管理設(shè)備配置并且可以在操作失敗時穩(wěn)健地處理所需的補償事務(wù)。

Azure IoT 中心設(shè)備

如果同時配置了Azure IoT 中心/Azure IoT 中心設(shè)備預(yù)配 (DPS) 支持，則 TTI 連接器應(yīng)用程序?qū)⒉粫印?/font>

請注意：Azure IoT 中心設(shè)備 ID 是一個區(qū)分大小寫的字符串（最長 128 個字符），由 ASCII 7 位字母數(shù)字字符加上某些特殊字符組成：-。+ % _ # * ? ！( ), : = @$ '

Azure IoT 中心設(shè)備預(yù)配服務(wù) (DPS) 配置

TTI 連接器支持用于獨立Azure IoT 中心應(yīng)用程序的Azure IoT 中心設(shè)備預(yù)配服務(wù) (DPS) 。TTI 連接器實現(xiàn)還支持用于設(shè)備配置的Azure IoT Central 數(shù)字孿生定義語言( DTDL V2 )。

Azure IoT 中心設(shè)備預(yù)配服務(wù)支持使用X.509證書、可信平臺模塊 (TPM)和使用共享訪問簽名(SAS) 安全令牌的對稱密鑰進(jìn)行設(shè)備證明。

Things Industries(TTI) V3 Azure IoT 連接器僅支持對稱密鑰設(shè)備證明。

如果Azure IoT 中心/ Azure IoT 中心設(shè)備預(yù)配 (DPS)支持兩者/兩者均未配置，則 TTI 連接器應(yīng)用程序?qū)⒉粫印?/font>

Azure 功能配置與 Azure IoT 中心設(shè)備預(yù)配服務(wù)配置

Azure IoT 中心設(shè)備預(yù)配服務(wù) (DPS)具有確定設(shè)備分配方式的服務(wù)級別設(shè)置。有四種支持的分配策略：

均勻加權(quán)分布：鏈接的物聯(lián)網(wǎng)中心同樣可能有設(shè)備配置給它們。默認(rèn)設(shè)置。如果您僅將設(shè)備預(yù)配到一個 IoT 中心，則可以保留此設(shè)置。
最低延遲：將設(shè)備預(yù)配到設(shè)備延遲最低的 IoT 中心。如果多個鏈接的 IoT 集線器將提供相同的最低延遲，則供應(yīng)服務(wù)會在這些集線器之間散列設(shè)備
通過注冊列表進(jìn)行靜態(tài)配置：注冊列表中所需 IoT 中心的規(guī)范優(yōu)先于服務(wù)級別分配策略。
自定義（使用 Azure 函數(shù)）：自定義分配策略使您可以更好地控制如何將設(shè)備分配給 IoT 中心。這是通過使用 Azure 函數(shù)中的自定義代碼將設(shè)備分配給 IoT 中心來實現(xiàn)的。設(shè)備預(yù)配服務(wù)調(diào)用您的 Azure 函數(shù)代碼，提供有關(guān)設(shè)備和代碼注冊的所有相關(guān)信息。您的函數(shù)代碼將執(zhí)行并返回用于預(yù)配設(shè)備的 IoT 中心信息。

在我的測試環(huán)境中，我使用均勻加權(quán)分布，當(dāng)我預(yù)置 1000 臺設(shè)備時，它們分布在我的五個Azure IoT 中心。

Azure IoT 中心設(shè)備預(yù)配服務(wù) Azure IoT 中心配置

Azure IoT Hub DPS 設(shè)備分發(fā)

Azure IoT Central DPS 配置

TTI 連接器支持Azure IoT Central應(yīng)用程序所需的Azure IoT 中心設(shè)備預(yù)配服務(wù) (DPS) （有一種預(yù)配單個設(shè)備的方法）。TTI 連接器實現(xiàn)還支持用于“自動”設(shè)備預(yù)配的Azure IoT Central 數(shù)字孿生定義語言( DTDL V2 )。

如果同時配置了Azure IoT 中心/Azure IoT 中心設(shè)備預(yù)配 (DPS) 支持，則 TTI 連接器應(yīng)用程序?qū)⒉粫印?/font>

Azure 功能配置與 Azure IoT 中心設(shè)備預(yù)配服務(wù)配置

第一步是配置Azure IoT Central 注冊組（確保“自動連接該組中的設(shè)備”為“零接觸”配置）并將IDScope和組注冊密鑰復(fù)制到 TTI 連接器配置

RAK3172 設(shè)備連接配置

然后，我為我的RAK3172 分線板基于 .Net Core 供電的測試設(shè)備創(chuàng)建了一個 Azure IoT Central 模板。

RAK3172 設(shè)備模板

RAK3172 設(shè)備注冊組

將設(shè)備組與組注冊配置關(guān)聯(lián)

復(fù)制 RAK3172 DTDL V2 模板 ID

還可以使用在 TTI 連接器配置中指定的可選 dtdlmodelid 為 TTI 應(yīng)用程序設(shè)置設(shè)備模板 @Id。

Azure IoT Hub 設(shè)備到云 (D2C)

LoRaWAN設(shè)備使用共享訪問簽名 (SAS) 設(shè)備策略連接字符串連接到Azure IoT 中心。我正在使用Device Twin Explorer顯示遙測數(shù)據(jù)并向我的傳感器節(jié)點發(fā)送消息。

顯示來自我的 Seeeduinolorawan2 設(shè)備的遙測數(shù)據(jù)的設(shè)備資源管理器

如果有效負(fù)載已被有效負(fù)載格式化程序解碼，則將對其進(jìn)行后處理，然后包含在消息有效負(fù)載中。

try
{
	JObject telemetryEvent = new JObject
	{
		{ "ApplicationID", applicationId },
		{ "DeviceEUI" , payload.EndDeviceIds.DeviceEui},
		{ "DeviceID", deviceId },
		{ "Port", port },
		{ "Simulated", payload.Simulated },
		{ "ReceivedAtUtc", payload.UplinkMessage.ReceivedAtUtc.ToString("s", CultureInfo.InvariantCulture) },
		{ "PayloadRaw", payload.UplinkMessage.PayloadRaw }
	};

	// If the payload has been decoded by payload formatter, put it in the message body.
	if (payload.UplinkMessage.PayloadDecoded != null)
	{
		EnumerateChildren(telemetryEvent, payload.UplinkMessage.PayloadDecoded);
	}

	// Send the message to Azure IoT Hub
	using (Message ioTHubmessage = new Message(Encoding.ASCII.GetBytes(JsonConvert.SerializeObject(telemetryEvent))))
	{
		// Ensure the displayed time is the acquired time rather than the uploaded time. 
		ioTHubmessage.Properties.Add("iothub-creation-time-utc", payload.UplinkMessage.ReceivedAtUtc.ToString("s", CultureInfo.InvariantCulture));
		ioTHubmessage.Properties.Add("ApplicationId", applicationId);
		ioTHubmessage.Properties.Add("DeviceEUI", payload.EndDeviceIds.DeviceEui);
		ioTHubmessage.Properties.Add("DeviceId", deviceId);
		ioTHubmessage.Properties.Add("port", port.ToString());
		ioTHubmessage.Properties.Add("Simulated", payload.Simulated.ToString());

		await deviceClient.SendEventAsync(ioTHubmessage);

		logger.LogInformation("Uplink-DeviceID:{deviceId} SendEventAsync success", deviceId);
	}
}
catch( Exception ex)
{
	logger.LogError(ex, "Uplink-DeviceID:{deviceId} SendEventAsync failure", deviceId);

	// If retries etc fail remove from the cache and it will get tried again on the next message
	_DeviceClients.Remove(deviceId);
}