adafruit-circuitpython-azureiot 2.6.0

Azure IoT Hub

要与 Azure IoT Hub 交互，您需要创建一个中心，并在其中注册一个设备。有一个免费层可用，这个免费层每天允许最多 8,000 条消息，所以如果您使用这个层，请不要频繁发送消息。

• 打开 Azure Portal。

• 按照 Microsoft Docs 中的说明创建 Azure IoT Hub 并注册设备。

• 复制设备的 Primary 或 secondary 连接字符串，并将其添加到您的 secrets.py 文件中。

您可以在 Azure Portal 中选择 IoT Hub，选择 Explorer -> IoT 设备，然后选择您的设备来找到设备连接字符串。

在 IoT 中心标签页中定位设备

然后使用旁边的复制按钮复制 primary 或 secondary 连接字符串。

复制 primary 连接字符串

将您的设备连接到 Azure IoT Hub

from adafruit_azureiot import IoTHubDevice

device = IoTHubDevice(wifi, secrets["device_connection_string"])
device.connect()

一旦设备连接，您将需要定期运行一个 loop 来轮询来自云的消息。

while True:
    device.loop()
    time.sleep(1)

向云发送设备消息

message = {"Temperature": temp}
device.send_device_to_cloud_message(json.dumps(message))

接收来自云的设备消息

def cloud_to_device_message_received(body: str, properties: dict):
    print("Received message with body", body, "and properties", json.dumps(properties))

# Subscribe to cloud to device messages
device.on_cloud_to_device_message_received = cloud_to_device_message_received

接收直接方法

def direct_method_invoked(method_name: str, payload) -> IoTResponse:
    print("Received direct method", method_name, "with data", str(payload))
    # return a status code and message to indicate if the direct method was handled correctly
    return IoTResponse(200, "OK")

# Subscribe to direct methods
device.on_direct_method_invoked = direct_method_invoked

在设备孪生上更新报告属性

此功能在基本层 IoT 中心上不受支持，仅在免费和标准层上支持。

patch = {"Temperature": temp}
device.update_twin(patch)

订阅设备孪生上期望的属性更改

此功能在基本层 IoT 中心上不受支持，仅在免费和标准层上支持。

def device_twin_desired_updated(desired_property_name: str, desired_property_value, desired_version: int):
    print("Property", desired_property_name, "updated to", str(desired_property_value), "version", desired_version)

# Subscribe to desired property changes
device.on_device_twin_desired_updated = device_twin_desired_updated

Azure IoT Central

要使用 Azure IoT Central，您需要创建一个 Azure IoT Central 应用程序，创建一个设备模板，并将设备注册到该模板。

• 前往 Azure IoT Central

• 按照 Microsoft Docs 中的说明创建应用程序。每个层最多支持 2 个设备的免费使用。

• 按照 Microsoft Docs 中的说明创建设备模板。

• 根据模板创建一个设备，并选择 连接 以获取设备连接详情。将 ID Scope、设备 ID 以及 primary 或 secondary 设备 SAS 密钥存储在您的 secrets.py 文件中。

连接按钮

连接详情对话框

secrets = {
    # WiFi settings
    "ssid": "",
    "password": "",

    # Azure IoT Central settings
    "id_scope": "",
    "device_id": "",
    "device_sas_key": ""
}

将您的设备连接到 Azure IoT Central 应用程序

from adafruit_azureiot import IoTCentralDevice

device = IoTCentralDevice(wifi, secrets["id_scope"], secrets["device_id"], secrets["device_sas_key"])
device.connect()

一旦设备连接，您将需要定期运行一个 loop 来轮询来自云的消息。

while True:
    device.loop()
    time.sleep(1)

发送遥测数据

message = {"Temperature": temp}
device.send_telemetry(json.dumps(message))

监听命令

def command_executed(command_name: str, payload) -> IoTResponse:
    print("Command", command_name, "executed with payload", str(payload))
    # return a status code and message to indicate if the command was handled correctly
    return IoTResponse(200, "OK")

# Subscribe to commands
device.on_command_executed = command_executed

更新属性

device.send_property("Desired_Temperature", temp)

监听属性更新

def property_changed(property_name, property_value, version):
    print("Property", property_name, "updated to", str(property_value), "version", str(version))

# Subscribe to property updates
device.on_property_changed = property_changed

了解更多关于Azure IoT服务的信息

如果您想了解更多关于设置或使用Azure IoT服务的信息，请查看以下资源

• Microsoft Docs上的Azure IoT文档

• Microsoft Learn上的IoT学习路径和模块 - 免费在线，自我指导的Azure IoT服务实践学习