python - 从 Paho MQTT 发送到云时某些数据丢失

Question

我正在尝试将大约 500 个标签的数据(每秒更改数据)从 Paho MQTT 发送到云。最初接收到所有数据，但一段时间后开始丢失样本。

• 尝试更改“保持事件时间”
• 检查 Wireshark 以监控流量。

我的部分代码

def queue_consumer(queue):
    global TestCount

    global responseList
    while True:
        TestCount=0
        for items in range(0, queue.qsize()):
            responseList.append(queue.get_nowait())
            queue.task_done()
        item1="topicName"
        if item1 is None:
            print("BREAKKK")
            break
        else:
            mqttmessage1 = json.dumps(responseList)
            objClient = ConnectionClient()
            objClient.client.publish("topicName", mqttmessage1 , qos=1)
            responseList=[]
            del objClient
        time.sleep(1)           # time after which the next items in queue
                                # would be processed for publishing

我希望所有数据都带有时间戳发布到云端。

Answer 1

尚不清楚您的 ConnectionClient() 是否每次在主循环周围打开和关闭连接。但是，看起来您每次都关闭连接(通过 del objClient )。如果是这样，我建议您在启动时创建一个 mqtt.Client 并连接到该服务。然后，每次运行主循环时都会发送消息，并且在程序退出之前不要关闭连接。

您还可以检查服务提供商是否没有应用某些限制。每秒 500 个主题似乎相当多，除非您为服务付费。