本案例适用于开发者入门理解Azure Functions/ IoT Hub / Service Bus / Power BI等几款产品。

    设备数据通过Azure Functions 推送到 Power BI 数据大屏进行展示（1.准备工作） - 图1
    主要实战的内容为：

    1. 将设备遥测数据上传到物联网中心，
    2. 将遥测数据路由到消息中间件的Topic中，
    3. 使用Azure Function解析消息中间件Topic中的消息并推送到大屏 。

    本文主要是本案例的准备工作，即（第1条和第2条的内容）：

    1.创建IoT Hub：

    创建IOT hub.mp4 (14.4MB) 2.创建Service Bus：

    创建sb.mp4 (10.09MB)

    1. 创建IoT Hub 消息路由，将遥测消息路由到Service Bus Topic

    iot 路由到 sb.mp4 (20.74MB) 本示例中的Python Device 代码来自于微软官网，请参照：
    https://docs.azure.cn/zh-cn/iot-hub/quickstart-send-telemetry-python

    1. # Copyright (c) Microsoft. All rights reserved.
    2. # Licensed under the MIT license. See LICENSE file in the project root for full license information.
    4. import random
    5. import time
    6. import sys
    8. # Using the Python Device SDK for IoT Hub:
    9. #   https://github.com/Azure/azure-iot-sdk-python
    10. # The sample connects to a device-specific MQTT endpoint on your IoT Hub.
    11. import iothub_client
    12. # pylint: disable=E0611
    13. from iothub_client import IoTHubClient, IoTHubClientError, IoTHubTransportProvider, IoTHubClientResult
    14. from iothub_client import IoTHubMessage, IoTHubMessageDispositionResult, IoTHubError, DeviceMethodReturnValue
    16. # The device connection string to authenticate the device with your IoT hub.
    17. # Using the Azure CLI:
    18. # az iot hub device-identity show-connection-string --hub-name {YourIoTHubName} --device-id MyNodeDevice --output table
    19. CONNECTION_STRING = "your device conn string"
    21. # Using the MQTT protocol.
    22. PROTOCOL = IoTHubTransportProvider.MQTT
    23. MESSAGE_TIMEOUT = 10000
    25. # Define the JSON message to send to IoT Hub.
    26. TEMPERATURE = 20.0
    27. HUMIDITY = 60
    28. MSG_TXT = "{\"temperature\": %.2f,\"humidity\": %.2f}"
    30. def send_confirmation_callback(message, result, user_context):
    31.     print ( "IoT Hub responded to message with status: %s" % (result) )
    33. def iothub_client_init():
    34.     # Create an IoT Hub client
    35.     client = IoTHubClient(CONNECTION_STRING, PROTOCOL)
    36.     return client
    38. def iothub_client_telemetry_sample_run():
    40.     try:
    41.         client = iothub_client_init()
    42.         print ( "IoT Hub device sending periodic messages, press Ctrl-C to exit" )
    44.         while True:
    45.             # Build the message with simulated telemetry values.
    46.             temperature = TEMPERATURE + (random.random() * 15)
    47.             humidity = HUMIDITY + (random.random() * 20)
    48.             msg_txt_formatted = MSG_TXT % (temperature, humidity)
    49.             message = IoTHubMessage(msg_txt_formatted)
    51.             # Add a custom application property to the message.
    52.             # An IoT hub can filter on these properties without access to the message body.
    53.             prop_map = message.properties()
    54.             if temperature > 30:
    55.               prop_map.add("temperatureAlert", "true")
    56.             else:
    57.               prop_map.add("temperatureAlert", "false")
    59.             # Send the message.
    60.             print( "Sending message: %s" % message.get_string() )
    61.             client.send_event_async(message, send_confirmation_callback, None)
    62.             time.sleep(3)
    64.     except IoTHubError as iothub_error:
    65.         print ( "Unexpected error %s from IoTHub" % iothub_error )
    66.         return
    67.     except KeyboardInterrupt:
    68.         print ( "IoTHubClient sample stopped" )
    70. if __name__ == '__main__':
    71.     print ( "IoT Hub Quickstart #1 - Simulated device" )
    72.     print ( "Press Ctrl-C to exit" )
    73.     iothub_client_telemetry_sample_run()

    image.png