paho

0熱

1答えて

私はpaho.mqttを使用して複数（約4つ）のトピックを購読しています。各トピックからメッセージを受信すると、しきい値に達するまでメッセージをバッファし、その後、一括メッセージをMySQLデータベースに挿入したいと考えています.1000件のメッセージを収集し、しきい値が1000を超え、最後に、特定の時間間隔（1分ごと）でデータベースに挿入します。トピックごとに、対応するテーブルがデータベース

0熱

2答えて

コンパイル時のエラーMQTT Pythonクライアント

MQTTブローカー（Mosquitto）をRaspberryにインストールし、クライアント（Paho Client Python）をインストールしますが、クライアントを起動しようとしましたが、私のファイルをコンパイルするときにこのエラーが発生します。 File "client_mqtt.py", line 38, in <module> client = mqtt.client()

0熱

1答えて

N分ごとにmqtt pahoでリアルタイムストリーミングデータを保存および解析する方法（Python）

リアルタイムデータストリーミングプロジェクトでは、N分ごとにデータを解析して保存しています。私の目的は、データの最初の分（バッファーとして）を捨てて、サーバーから4分ごとにデータを格納することです。データは、クラスター化および計算（関数はここには含まれていません）する他の関数に解析されます。私は 'on_message'という関数で条件を初期化し、データをその関数内で解析しました。私は私の構造化

0熱

1答えて

Paho MQTT（C++）クライアントがMosquittoへの接続に失敗する

MQTTブローカーに接続するためにPaho MQTTPacket組み込みC++ライブラリーを使用するC++コードがあります。そのブローカーがio.adafruit.comの場合、それは完璧に機能します。しかし、私自身のMosquittoインスタンスが自分のRaspberry Piで動作している場合、接続は失敗します。私はMQTT :: Clientで、MQTTClient.hにこのラインにそれを絞

1熱

1答えて

mosquittoブローカーによるadafruit iotポータルにオフラインメッセージが送信されない

私はモスキートブローカーとmqttをインストールしたラズベリーパイを持っています。 Piはセンサーに接続されており、このデータをadafruit IOT protalに送信する必要があります。私はpiが接続されているときにすべてのデータを送信することができますが、piがオフラインになると、私は20-30秒間しかデータを送信できません。 piが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

0熱

1答えて

pika（pythonクライアント）を使用してRabbitMQでMQTTメッセージをパブリッシュ/サブスクライブする

私は既存のRabittMQサーバーをセットアップしており、MQTTプラグインがmqttメッセージをパブリッシュ/サブスクライブできるようにしました。既存のキューメッセージを処理するpikaクライアントがあります。今、私は同じpika on_message（）ハンドラを使ってmqttメッセージを処理したいと考えています。 eclipse pahoクライアント上でmqttメッセージを発行して購読する

0熱

1答えて

Mosquitto MQTT Brokerのアクセス制御

Mosquitto MQTTブローカー上の選択されたユーザーのみに公開を制限する方法はありますか？私はいくつかのユーザーが購読できるようにしたい、いくつかの他のユーザーが公開できるようにしたいと私はこれらの2つのグループのユーザーを分離する必要があります。 username：passwordでアクセスできる許可制御があることは知っています。しかし、ユーザーに役割を割り当てる方法は私には分かりませ

1熱

1答えて

自己署名証明書を使用してAndroid（pahoクライアント）のMqttサーバーに接続するにはどうすればよいですか？

自己署名証明書を使用してmqttサーバーに接続する際に問題が発生しました。私はPahoクライアントを使っていて、を使ってサーバに接続したいと思っています。実際に私はAndroid API 20+で接続に成功しましたが、このバージョンの下では成功しませんでした。 IVEが今まで行って何を：の1-は、PKCS＃12キーストアを作成し、.CRTファイルを入れて、それにパスワードをASSINGし、そ

-2熱

1答えて

Pythonの異なるクラスモジュールのpaho mqttコールバック

別のPythonモジュールでコールバック関数を定義しました。他のモジュールで定義されているそのコールバックをpaho.mqttクライアントコールバックにどのように添付すればよいですか？ために。私はdatabase.pyにデータベースへの接続やメッセージをデータベースとmqttbroker.pyモジュールに格納するなど、すべてのデータベース操作を行うdatabase.pyを持っています。ここでmqt