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

Question

私は既存のRabittMQサーバーをセットアップしており、MQTTプラグインがmqttメッセージをパブリッシュ/サブスクライブできるようにしました。 既存のキューメッセージを処理するpikaクライアントがあります。今、私は同じpika on_message（）ハンドラを使ってmqttメッセージを処理したいと考えています。 eclipse pahoクライアント上でmqttメッセージを発行して購読することができます。既存のRabittMQクライアント（pika）を使用したいと考えています。 MQTTプラグインは、デフォルトでamq.topic exchangeにパブリッシュされます。自分の取引所に同じメッセージを公開したい。私に教えてください、どのようにこれを取得する。

Answer 1

RabbitMQチームはthis mailing listを監視し、時々StackOverflowに関する質問に答えます。

Pikaライブラリーを使用しているコンシューマーが、MQTTメッセージを受信するためには、コンシューマーはMQTTメッセージが発行される適切なキューにサブスクライブする必要があります。 MQTTとAMQPの相互運用方法に関する包括的なドキュメントはhereです。

次に、「私は自分の交換に同じメッセージを公開したい」と言う。 amq.topicの代わりに独自の取引所を使用する場合は、this documentの「カスタム取引」セクションをご覧ください。 rabbitmq.configファイルに交換の名前を指定し、メッセージを発行する前に交換を作成する必要があります。このカスタム交換はでなければならないことに注意してください。

RabbitMQのドキュメントは良いリソースであり、質問があるときにそこを検索することをお勧めします。