Python到Json反序列化错误

2024-06-03 02:01:37 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试使用IOTHub遥测从PLC读取值,并使用azure将它们流式传输到PowerBI

当我运行代码时,我能够连接到PLC并读取值,并且能够看到集线器接收到消息。但是,流给了我一个错误,上面写着“InputDeserializerError.InvalidData”。我不确定哪里出了错。请看一下下面的代码,并建议如何序列化它。当我删除字符串值并只运行整数&;漂浮,溪流把它收集起来

# Define the JSON message to send to IoT Hub.
MSG_TXT = "{\"Bin1Load\": %s,\"Bin1Grower\": %s,\"Bin1Variety\": %s,\"Bin1StatedTn\": %.2f,\"Bin1S\": %.3f,\"Bin1CalcV\": %.2f}"

def send_confirmation_callback(message, result, user_context):
    print ( "IoT Hub responded to message with status: %s" % (result) )

def iothub_client_init():
    # Create an IoT Hub client
    client = IoTHubClient(CONNECTION_STRING, PROTOCOL)
    return client

def iothub_client_telemetry_sample_run():

    try:
        client = iothub_client_init()
        print ( "IoT Hub device sending periodic messages, press Ctrl-C to exit" )

   
        while True:
            # Build the message with simulated telemetry values.    
            b1load =  comm.Read('Bin01.Content.Load')
            b1grower =  comm.Read('Bin01.Content.Grower')
            b1variety =  comm.Read('Bin01.Content.Variety')
            b1statedton =  comm.Read('Bin01.Content.Stated_Tn')            
            b1s =  comm.Read('Bin01.Content.SG')
            b1calcvol =  comm.Read('Bin01.Content.Calc_Vol')
            msg_txt_formatted = MSG_TXT % (b1loads, b1growers, b1varietys, b1statedton, b1s, b1calcvol)
            message = IoTHubMessage(msg_txt_formatted)``` 

Tags: theto代码clientsendmessagereaddef