タグ別アーカイブ: MQTT

Raspberry PiでMQTTの動作環境を作る(RabbitMQ + Paho + Python)

rasp_matt_2

恥ずかしながら、IoT向けの通信プロトコルでMQTT (Message Queuing Telemetry Transport)というものがあることを最近知りました。知っておいて損はないかなーということで、Sparkの環境構築に使ったRaspberry Pi 2 × 2台を使って動作検証環境を作ることにしました。

MQTTを実現するにはPublisher – Broker – Subscriberの3役が必要なのですが、ここでは以下のように割り振ります。

  • Broker & Subscriber … Raspberry Pi 2 (A)
  • Publisher … Raspberry Pi 2 (B)

Raspberry Piが2台ない場合は(←そっちの方が普通だと思いますが)、全部の役を1台に割り振って動作確認することもできます(SubscriberとPublisherの接続先を”localhost”にすればOK)。

Brokerには、とりあえずよく名前を聞くRabbitMQを使って、PublisherとSubscriberには、これまたよく名前を聞くPahoのPythonパッケージを使うことにします。Pythonを使う理由は「うまくやれば後々Sparkと組み合わせられるかも?」という期待からです。

では、早速。

続きを読む