接收时的 MQTT 消息计数器

Question

我尝试搜索与我的问题相关的主题，我认为这是一个很常见的问题。 我想计算在“on_message”上收到消息的次数。全局或局部计数变量都不起作用，如何对收到的消息进行计数？

这是我的 sn-p 代码，我的计数不起作用，因为它每次都会重置。

定义

def on_message(client, userdata, message):
    ts_data = str(message.payload.decode("utf-8"))
    count=count+1
    print(count)

if __name__ == '__main__':
    client = mqtt.Client()
    client.on_message=on_message

你能帮忙吗？

谢谢 亲切的问候 阿伦

Answer 1

我不确定您所说的以下内容是什么意思：

全局或局部计数变量不起作用，

以下应该可以正常工作：

count = 0

def on_message(client, userdata, message):
    global count
    ts_data = str(message.payload.decode("utf-8"))
    count=count+1
    print(count)

if __name__ == '__main__':
    client = mqtt.Client()
    client.on_message=on_message