여러 구독에 대한 Paho mqtt 콜백

Question

paho.mqtt를 사용하여 여러 (약 4) 개의 주제에 가입했습니다.

각 주제에서 메시지를 수신하면 메시지를 버퍼링하여 임계 값에 도달 한 다음 나중에 대량 메시지를 MySQL 데이터베이스에 삽입합니다 .1000 개의 메시지를 수집하고 임계 값이 1000보다 크고 마지막으로 특정 시간 간격 (매 1 분마다)에 데이터베이스에 삽입하십시오.

각 항목마다 해당 테이블이 데이터베이스에 있습니다. 어느 콜백 함수를 use on_message() 콜백 또는 message_callback_add() 콜백해야합니까? 어떤 시나리오에서 더 낫지?

Answer 1

"더 나은"것은 무엇을 의미합니까?

on_message()으로 등록 된 콜백은 모든 구독에 대해 모든 메시지를 받게되지만, message_callback_add으로 등록하면 각 구독자마다 다른 콜백을 가질 수 있습니다.

토픽 이름에 따라 다른 작업을 수행하기 위해 콜백이 필요합니까? 그렇지 않은 경우 on_message을 사용하고 그렇지 않은 경우 message_callback_add을 사용합니다.