如何修复 Azure 流分析中的无效数据错误？

Question

我正在尝试创建从我的 IoT 中心到 Power BI 的流分析作业，但我的输入数据接缝无效。开始作业后，我收到此错误代码： InputDeserializerError.InvalidData 。我的事件序列化格式是 JSON。我通过 azure shell 监控了我的消息，它们看起来像这样：

    "event": {
        "origin": "Projektpi",
        "module": "",
        "interface": "",
        "component": "",
        "payload": "{\"Time\": 19/04/2021, 13:22:33, \"Critical vibration\": No, \"Temperature\": 20.812, \"RPM\": 0.0}"
    }

我每 11 秒通过以下代码从我的 pi 发送消息：

client = IoTHubDeviceClient.create_from_connection_string(CONNECTION_STRING)

async def send_to_azure(payload):

    # await internet connection
    awaitConnection()
    # payload looks like this: payload = '{{"Time": {now}, "Critical vibration": {azurevibration}, "Temperature": {azuretemp}, "RPM": {azurerpm}}}'
    message = Message(payload)

    # Send a message to the IoT hub
    print(f"Sending message: {message}")
    try:
         print('Status: Trying to send data to Azure IoT Hub...')
         await client.connect()
         await client.send_message(message)
         print('Status: Data sent ...')
    except:
         print('Status: Problem sending data to Azure IoT Hub...')

我必须如何更改我的代码，以便流分析作业可以使用我的 pi 传感器数据作为输入？如果您知道 python 教程等，那就太好了。我对 azure 和一般编程还很陌生，所以非常感谢你的帮助！

Answer 1

您的负载包含一些无效 JSON。流分析将尝试将您的 JSON 有效负载和运行反序列化为错误。错误的负载是由两个属性引起的：

“时间”
“临界振动”

两者都缺少值周围的双引号，这些是文本字段需要的，而不是数字字段。这应该是正确的格式：

"event": {
        "origin": "Projektpi",
        "module": "",
        "interface": "",
        "component": "",
        "payload": "{\"Time\": \"19/04/2021, 13:22:33\", \"Critical vibration\": \"No\", \"Temperature\": 20.812, \"RPM\": 0.0}"
    }

为清楚起见，我将包括您的负载的未转义版本：

{
   "Time":"19/04/2021, 13:22:33",
   "Critical vibration":"No",
   "Temperature":20.812,
   "RPM":0.0
}

如何修复 Azure 流分析中的无效数据错误？

How to fix Invalid Data Error in Azure Stream Analytics?

azure

azure-stream-analytics

azure-iot-hub