多个订阅的 Paho mqtt 回调
Paho mqtt callbacks on multiple subscription
我已经使用 paho.mqtt 订阅了多个（大约 4 个）主题。
从每个主题接收消息时，我想缓冲消息直到达到某个阈值，然后再将批量消息插入 MySQL database.I 想收集大约 1000 条消息并检查是否threshold 大于 1000 然后最后在特定时间间隔（每 1 分钟）插入数据库。
对于每个主题，数据库中都有相应的table。我应该use on_message()回调还是message_callback_add()回调哪个回调函数？在这种情况下哪个更好？
"is better" 对您来说意味着什么？
使用 on_message() 注册的回调将获取您所有订阅的所有消息，而使用 message_callback_add 您可以为订阅的每个主题设置不同的回调。
您是否需要回调根据主题名称做不同的事情？如果不是，你使用 on_message，否则你使用 message_callback_add.
我已经使用 paho.mqtt 订阅了多个（大约 4 个）主题。
从每个主题接收消息时，我想缓冲消息直到达到某个阈值，然后再将批量消息插入 MySQL database.I 想收集大约 1000 条消息并检查是否threshold 大于 1000 然后最后在特定时间间隔（每 1 分钟）插入数据库。
对于每个主题，数据库中都有相应的table。我应该use on_message()回调还是message_callback_add()回调哪个回调函数？在这种情况下哪个更好？
"is better" 对您来说意味着什么？
使用 on_message() 注册的回调将获取您所有订阅的所有消息，而使用 message_callback_add 您可以为订阅的每个主题设置不同的回调。
您是否需要回调根据主题名称做不同的事情？如果不是，你使用 on_message，否则你使用 message_callback_add.