MQTT、MongoDB入りのNode-REDの環境をさくっと作ってみる #MongoDB

このエントリは、Node-RED Advent Calendar 2015の20日目のエントリーです。

今年はPaaSが一気にブレークしましたね。しかし、インフラエンジニア（私は既にエンジニアではないんですが・・）としては、どうしてもPaaSを構成する環境に目がいってしまいます。Node-REDに関しても同じなのですが、インフラエンジニアの端くれとしては、まずは黙ってNode-REDの簡単に環境を作ってみたいと思います！といっても、とってもシンプルな環境で恥ずかしいのですが。本当はもう少しいけてるNodeを入れたり、自作のNodeも作って育てたいのですが、それはまた今度できればということで（笑

では、MQTT(Mosquitto)、MongoDBが入ったNode-REDの環境をさくっと作ってみましょう

まず、クラウドでも、PC（WindowsやMac）でも、Raspberry Piでもいいのですが、Node-REDの環境を作る箱を用意します。今回はSoftLayerを使います。また、ウェブポータルからつくると時間がかかるので、コマンドラインでさくっと作りたいと思います。

SoftLayerのアカウントを用意

このあたりを参考に作成してください。
- http://www.ibm.com/cloud-computing/jp/ja/softlayer_freecloud.html
- http://www.slideshare.net/kkitase/softlayer-latest-updates-at-fukuoka-meetup

SoftLayer CLIクライアント(slcli)のインストール

私の環境はMacですので、異なる方は適宜調整ください。
まず、自分のPC（私の場合はMac）に、SoftLayer CLIクライアントを入れます。
APIKeyは、SoftLayerのウェブポータルから確認してください。

作業手順

$ yum install -y git python python-setuptools
$ git clone https://github.com/softlayer/softlayer-python.git
$ cd softlayer-python
$ python setup.py install
$ slcli setup
Username [hogehoge]: 
API Key or Password [hogehogehogehoge]: 
Endpoint (public|private|custom) [public]: 
Timeout [0]: 
:..............:..................................................................:
:         name : value                                                            :
:..............:..................................................................:
:     Username : hogehoge                                                        :
:      API Key : hogehogehogehogehoge :
: Endpoint URL : https://api.softlayer.com/xmlrpc/v3.1/                           :
:      Timeout : not set                                                          :
:..............:..................................................................:
Are you sure you want to write settings to "/Users/hogehoge/.softlayer"? [Y/n]: y

仮想サーバー作成

必要に応じて、SSH公開鍵はあらかじめSoftLayerで登録しておいてください。slcli sshkeyで登録されている公開鍵を確認できます。
slcli vs createでサーバーを作成できます。オプションはslcli vs create-optionsで確認できます。今回は、サンノゼのデータセンターに、1仮想コア、1Gメモリ、CentOS 6、時間課金の仮想サーバーを作成します。
最後に--testオプションをつけて実行すると、実際にサーバーを作成せず確認できます。
プロビジョニングスクリプト（初期構成スクリプト）を用意しましたので活用ください。
slcli vs listでサーバーのステータスを確認できます。
- サーバーが作成されたら、action になにも表示されなくなります。（数分かかります）

作業手順

$ slcli sshkey list
:........:........................:.................................................:.......:
:   id   :         label          :                   fingerprint                   : notes :
:........:........................:.................................................:.......:
: 999999 :      hogehoge          : 99:99:99:99:99:99:99:99:99:99:99:99:99:99:99:99 :   -   :
:........:........................:.................................................:.......:
$ slcli vs create \
--cpu=1 --memory=1024 --os=CENTOS_6_64 --billing=hourly --datacenter=sjc01 \
--disk=25 --hostname=nodered3 --domain=handson.jp \
--postinstall=https://raw.githubusercontent.com/kkitase/softlayer-provisioning-script/master/centos-nodered \
--key <sshkey> --test
:.......................................................:......:
:                                                  Item : cost :
:.......................................................:......:
:                                      1 x 2.0 GHz Core : 0.02 :
:                                                  1 GB : 0.01 :
:                 CentOS 6.x - Minimal Install (64 bit) : 0.00 :
:                                         25 GB (LOCAL) : 0.00 :
:                               Reboot / Remote Console : 0.00 :
:              10 Mbps Public & Private Network Uplinks : 0.00 :
:                                        0 GB Bandwidth : 0.00 :
:                                          1 IP Address : 0.00 :
:                                             Host Ping : 0.00 :
:                                      Email and Ticket : 0.00 :
:                                Automated Notification : 0.00 :
: Unlimited SSL VPN Users & 1 PPTP VPN User per account : 0.00 :
:           Nessus Vulnerability Assessment & Reporting : 0.00 :
:                                     Total hourly cost : 0.03 :
:.......................................................:......:
 -- ! Prices reflected here are retail and do not take account level discounts and are not guaranteed.
$ slcli vs create \
--cpu=1 --memory=1024 --os=CENTOS_6_64 --billing=hourly --datacenter=sjc01 \
--disk=25 --hostname=nodered --domain=handson.jp \
--postinstall=https://raw.githubusercontent.com/kkitase/softlayer-provisioning-script/master/centos-nodered \
--key <sshkey>
This action will incur charges on your account. Continue? [y/N]: y
:.........:......................................:
:    name : value                                :
:.........:......................................:
:      id : 99999999                             :
: created : 2015-12-20T08:27:14+09:00            :
:    guid : 99999999-9999-9999-9999-999999999999 :
:.........:......................................:
$ slcli vs list
:..........:..........:................:................:............:.............:
:    id    : hostname :   primary_ip   :   backend_ip   : datacenter :    action   :
:..........:..........:................:................:............:.............:
: 14729479 : noderede :       -        :       -        :     -      : Assign Host :
:..........:..........:................:................:............:.............:
$ slcli vs list
:..........:..........:................:................:............:........:
:    id    : hostname :   primary_ip   :   backend_ip   : datacenter : action :
:..........:..........:................:................:............:........:
: 99999999 : nodered  : 999.999.999.99 : 10.999.999.999 :   scj01    :   -    :
:..........:..........:................:................:............:........:

作成したサーバーにアクセスします。

サーバーが作成されても、しばらくプロビジョニングスクリプトは実行中ですので、ログインした時に下記のメッセージがでるまでは、ログアウトして作業しないでください。

$ ssh root@ipアドレス
****************************************************************************
  Provisioning was successful
  1) Start mosquitto: /usr/sbin/mosquitto and
     Subscribe and send msg: mosquitto_pub -d -t hello -m Hello world
  2) Comment out bindIp in /etc/mongod.conf and
     restart mongod: service mongod restart
  3) Start node-red: node-red and access http://<IP>:1880
****************************************************************************

MongoDBの設定

必要時応じて、リモートからMongoDBに接続できるようにします

$ vi /etc/mongod.conf
下記をコメントアウト
#  bindIp: 127.0.0.1  # Listen to local interface only, comment to listen on all interfaces.
$ service mongod restart

これで、MongoDB、MQTTゲートウェイ付きの環境ができあがりました。詳細を知りたい方は下記のスクリプトを参照ください。

https://github.com/kkitase/softlayer-provisioning-script/blob/master/centos-nodered

Node-REDを利用

Node-REDに関する説明は Node-REDについてを参考にしてください。
ブラウザを起動して、http://(ipaddress):1880 にアクセスして、Node-REDを楽しみましょう！

Flowのインポート

作成したNode-RED環境に下記の簡単なFlowをImportして、MQTT、MongoDBのIPアドレスやTwitterのアカウントを変更すれば、利用できます。

[{"id":"1ab80a01.e547f6","type":"mqtt-broker","z":"626bd57d.9d942c","broker":"127.0.0.1","port":"1883","clientid":"","usetls":false,"verifyservercert":true,"compatmode":true,"keepalive":"15","cleansession":true,"willTopic":"","willQos":"0","willRetain":"false","willPayload":"","birthTopic":"","birthQos":"0","birthRetain":"false","birthPayload":""},{"id":"8d120694.72edf8","type":"mongodb","z":"626bd57d.9d942c","hostname":"127.0.0.1","port":"27017","db":"tweet2","name":"tweet2"},{"id":"258f959.fda706a","type":"twitter in","z":"626bd57d.9d942c","twitter":"","tags":"cloud","user":"false","name":"tweet cloud","topic":"tweets","x":198,"y":235,"wires":[["6d4b6e18.92b49","a7cd30cf.5832d","c6205c37.39dfa"]]},{"id":"6d4b6e18.92b49","type":"mongodb out","z":"626bd57d.9d942c","mongodb":"8d120694.72edf8","name":"cloud","collection":"cloud","payonly":false,"upsert":false,"multi":false,"operation":"store","x":410,"y":234,"wires":[]},{"id":"a7cd30cf.5832d","type":"debug","z":"626bd57d.9d942c","name":"","active":false,"console":"false","complete":"false","x":429,"y":309,"wires":[]},{"id":"d827b393.27d85","type":"mqtt in","z":"626bd57d.9d942c","name":"iot","topic":"hello","broker":"1ab80a01.e547f6","x":192,"y":114,"wires":[["921b5cef.6de4a"]]},{"id":"921b5cef.6de4a","type":"debug","z":"626bd57d.9d942c","name":"","active":true,"console":"false","complete":"false","x":402,"y":114,"wires":[]},{"id":"acce4311.5331c","type":"mongodb in","z":"626bd57d.9d942c","mongodb":"8d120694.72edf8","name":"cloud","collection":"cloud","operation":"find","x":353,"y":511,"wires":[["d4a66472.2b5998"]]},{"id":"d4a66472.2b5998","type":"http response","z":"626bd57d.9d942c","name":"","x":501,"y":511,"wires":[]},{"id":"f0b0955e.0f4f68","type":"http in","z":"626bd57d.9d942c","name":"show","url":"/show","method":"get","swaggerDoc":"","x":203,"y":511,"wires":[["acce4311.5331c"]]},{"id":"c6205c37.39dfa","type":"sentiment","z":"626bd57d.9d942c","name":"","x":421,"y":392,"wires":[["23f716d1.dc08ea"]]},{"id":"23f716d1.dc08ea","type":"switch","z":"626bd57d.9d942c","name":"score","property":"sentiment.score","rules":[{"t":"gt","v":"0"},{"t":"lte","v":"0"}],"checkall":"true","outputs":2,"x":573,"y":391,"wires":[["a4718efc.5b8e7"],["b1deedc2.4e211"]]},{"id":"34a41fbe.cb5be","type":"debug","z":"626bd57d.9d942c","name":"","active":false,"console":"false","complete":"true","x":844,"y":307,"wires":[]},{"id":"805df1cd.7fa21","type":"debug","z":"626bd57d.9d942c","name":"","active":true,"console":"false","complete":"true","x":832,"y":472,"wires":[]},{"id":"a4718efc.5b8e7","type":"function","z":"626bd57d.9d942c","name":"format","func":"msg =  {\n    \"score\": msg.sentiment.score,\n    \"topic\": msg.topic,\n    \"text\": msg.payload,\n    \"lang\": msg.lang\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":721,"y":309,"wires":[["34a41fbe.cb5be"]]},{"id":"b1deedc2.4e211","type":"function","z":"626bd57d.9d942c","name":"format","func":"msg =  {\n    \"score\": msg.sentiment.score,\n    \"topic\": msg.topic,\n    \"text\": msg.payload,\n    \"lang\": msg.lang\n};\n\nreturn msg;","outputs":1,"noerr":0,"x":710,"y":472,"wires":[["805df1cd.7fa21"]]},{"id":"48597c7.fb7a684","type":"comment","z":"626bd57d.9d942c","name":"MQTTサブスクライバ","info":"MQTTクライアントからメッセージを送信してください。\n例）mosquitto_pub -d -t hello -m \"Hello world\"","x":150,"y":64,"wires":[]}]

このFlowは主に下記の処理を行います。

MQTTのテスト
Twitterの検索データをオープンソースの分析ツールSentimentで判断
Twitterの検索データをMongoDBにストア

コミュニティ

Node-REDユーザー会、SoftLayerユーザー会、Bluemixユーザー会などに入っておくと有用な情報を入手することができますので、是非登録しておきましょう。

Node-RED User Group Japan
- Facebook
SoftLayerユーザー会
- Facebook
- Web
Bluemixユーザー会
- Facebook

参考情報

ご意見等あれば、Facebook | Twitter までお願いします。