如何使用Python发送Device twin的动态报告属性

Question

我想定期更新IoT设备所需的属性。我发送的所需属性如下：

desired = {
"para1" : {"time": [11,22,33]},
"para2" : {"site":"demo.com"}
}

以下是根据本文档在设备内部运行的脚本

import time
import threading
from azure.iot.device import IoTHubModuleClient
CONNECTION_STRING = "IOTHUB Device Connection String"

def twin_update_listener(client):
while True:
patch = client.receive_twin_desired_properties_patch()  # blocking call
print("Twin patch received:")
print(patch)
def iothub_client_init():
client = IoTHubModuleClient.create_from_connection_string(CONNECTION_STRING)
return client
def iothub_client_sample_run():
try:
client = iothub_client_init()
twin_update_listener_thread = threading.Thread(target=twin_update_listener, args=(client,))
twin_update_listener_thread.daemon = True
twin_update_listener_thread.start()
# Send reported
print ( "Sending data as reported property..." )
reported_patch = {"connectivity": "cellular"}
client.patch_twin_reported_properties(reported_patch)
print ( "Reported properties updated" )
while True:
time.sleep(1000000)
except KeyboardInterrupt:
print ( "IoT Hub Device Twin device sample stopped" )
if __name__ == '__main__':
print ( "Starting the Python IoT Hub Device Twin device sample..." )
print ( "IoTHubModuleClient waiting for commands, press Ctrl-C to exit" )
iothub_client_sample_run()

在这里，它将reported_properties更新为静态值(reported_patch = {"connectivity": "cellular"})，但我不想上传与所需值相同的报告值：

{
"para1" : {"time": [11,22,33]},
"para2" : {"site":"demo.com"}
}

请让我知道如何做到这一点。

Answer 1

试试这个，一旦desired值发生变化，就将desired值上传到reported：

import time
import threading
from azure.iot.device import IoTHubModuleClient
CONNECTION_STRING = ""

def twin_update_listener(client):
while True:
patch = client.receive_twin_desired_properties_patch()  # blocking call
print("Twin patch received")

patch.pop('$version',None)
print ( "Sending Twin as reported property..." )
print(patch)
client.patch_twin_reported_properties(patch)
print ( "Reported properties updated" )

def iothub_client_init():
client = IoTHubModuleClient.create_from_connection_string(CONNECTION_STRING)
return client
def iothub_client_sample_run():
try:
client = iothub_client_init()
twin_update_listener_thread = threading.Thread(target=twin_update_listener, args=(client,))
twin_update_listener_thread.daemon = True
twin_update_listener_thread.start()      

while True:
time.sleep(1000)
except KeyboardInterrupt:
print ( "IoT Hub Device Twin device sample stopped" )
if __name__ == '__main__':
print ( "Starting the Python IoT Hub Device Twin device sample..." )
print ( "IoTHubModuleClient waiting for commands, press Ctrl-C to exit" )
iothub_client_sample_run()