paho

-2열

1답변

다른 파이썬 모듈에서 콜백 함수를 정의했습니다. paho.mqtt 클라이언트 콜백에 다른 모듈에 정의 된 콜백을 어떻게 첨부합니까? 에 대한. 예를 들어 데이터베이스에 연결하고 데이터베이스 및 mqtt.client() 인스턴스를 만들고 브로커에 연결하여 주제에 가입하는 mqttbroker.py 모듈에 메시지를 저장하는 등의 모든 데이터베이스 작업을 수행하는

0열

1답변

여러 구독에 대한 Paho mqtt 콜백

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

0열

1답변

Eclipse Paho MqttClient 객체 풀

우리는 mqtt 브로커에 메시지를 게시하는 나머지 서비스 끝점 (Spring MVC)이 있습니다. 우리는 모든 요청에 대해 MqttClient를 만들지 않아도되도록 MqttClient를 캐시 할 계획입니다. 가장 좋은 옵션은 무엇입니까? 각 ThreadLocal 객체에 MqttClient를 저장 하시겠습니까? Apache Commons Pool과 같은

0열

2답변

MQTT Python 클라이언트 컴파일시 오류가 발생했습니다.

MQTT 브로커 (Mosquitto)를 Raspberry에 설치하고 클라이언트 (Paho Client Python)를 설치하면 클라이언트가 시작되지만 파일을 컴파일 할 때이 오류가 발생합니다. File "client_mqtt.py", line 38, in <module> client = mqtt.client() AttributeError:

0열

1답변

paho websocked에서 가입 한 주제를 동적으로 변경할 수 있습니까?

모든 주제에서 MQTT 메시지를 받기 위해 paho 웹 소켓 자바 스크립트를 사용하고 있습니다. 런타임에 구독하는 메시지에서 메시지를 가져올 수 있지만 선택 상자를 사용하여 동적으로 항목을 변경하고 선택한 항목에서만 메시지를 수신해야합니다. 나는 여러 가지 해결책을 시도해 왔지만 완전히 성공했지만 아무런 성공도 찾지 못했습니다. <?xml version="

0열

1답변

Paho MQTT (C++) 클라이언트가 Mosquitto에 연결하지 못했습니다.

Paho MQTTPacket Embedded C++ 라이브러리를 사용하여 C++ 코드를 MQTT 브로커에 연결했습니다. 해당 브로커가 io.adafruit.com 일 때 완벽하게 정상적으로 작동합니다. 그러나 제 라즈베리 파이에서 실행중인 내 Mosquitto 인스턴스 인 경우 연결이 실패합니다. 나는 MQTT :: 클라이언트에 MQTTClient.h에서이

1열

1답변

mosquitto 중개인이 adafruit iot portal에 오프라인 메시지를 보내지 않았습니다.

모스 잇토 브로커와 mqtt를 설치 한 나무 딸기 파이가 있습니다. Pi가 센서에 연결되어있어이 데이터를 adafruit IOT protal으로 보내야합니다. 파이가 연결되었을 때 모든 데이터를 보낼 수 있지만 파이가 오프라인이되면 20-30 초 동안 만 데이터를 전송할 수 있습니다. 파이가 2-3 분 이상 오프라인 인 경우 해당 데이터는 포털에 전송되지

0열

1답변

Paho CPP - 정적 실행 파일로 컴파일

Paho CPP를 정적 실행 파일로 컴파일 할 수 있습니까? 그렇다면 어떻게? g++ -DOPENSSL -I.. -I/usr/local/include -D_NDEBUG -Wall -std=c++11 -O2 -o data_publish data_publish.cpp -L../../lib -L/usr/local/lib -lpaho-mqttpp3 -lpaho-m

0열

1답변

pika (python 클라이언트)를 사용하여 RabbitMQ에서 MQTT 메시지 게시/구독

기존 RabittMQ 서버 설정이 있고 MQTT 플러그인이 mqtt 메시지를 게시/구독 할 수 있도록 설정했습니다. 기존 대기열 메시지를 처리 할 pika 클라이언트가 있습니다. 지금 당장은 동일한 pika on_message() 핸들러를 사용하여 mqtt 메시지를 처리하려고합니다. eclipse paho 클라이언트를 통해 mqtt 메시지를 게시하고 구

0열

1답변

Mosquitto MQTT Broker의 액세스 제어

Mosquitto MQTT 브로커에서 선택된 사용자에게만 게시를 제한하려면 어떻게합니까? 일부 사용자는 구독 할 수 있고 일부 다른 사용자는 게시 할 수 있기를 원하며이 두 그룹의 사용자를 구분해야합니다. 사용자 이름 : 암호로 액세스 할 수있는 권한 제어가 있다는 것을 알고 있습니다. 그러나 사용자에게 역할을 할당하는 방법은 분명하지 않습니다. 그러한 역