paho.mqtt를 사용하여 여러 (약 4) 개의 주제에 가입했습니다.여러 구독에 대한 Paho mqtt 콜백
각 주제에서 메시지를 수신하면 메시지를 버퍼링하여 임계 값에 도달 한 다음 나중에 대량 메시지를 MySQL 데이터베이스에 삽입합니다 .1000 개의 메시지를 수집하고 임계 값이 1000보다 크고 마지막으로 특정 시간 간격 (매 1 분마다)에 데이터베이스에 삽입하십시오.
각 항목마다 해당 테이블이 데이터베이스에 있습니다. 어느 콜백 함수를 use on_message()
콜백 또는 message_callback_add()
콜백해야합니까? 어떤 시나리오에서 더 낫지?
** ** 매우 주관적입니다. – hardillb