Docker上に構築したMeshbluへArduinoからセンシングデータを送信してみます。前回起動したコンテナではMongoDBを使わない設定なので、POSTしたデータはNeDBにJSONファイルとして保存されます。大気圧センサーモジュールはBMP180を使います。前回Intel Edisonでこのモジュールを使ったときはcylon-i2cやmraaが使えず、bmp085パッケージを使いました。Arduinoの場合cylon-firmataが動作するようです。Cylon.jsを使ってセンシングデータを取得してMeshbluにデータをPOSTしてみます。
cylon-skynetが古い
Cylon.jsからMeshbluのAPIを使う場合、Skynetモジュールを使います。名前が古いようにdependenciesのパッケージも古くなっています。
clone
とりあえずリポジトリをcloneしてmasato/cylon-skynetしました。lib/adaptor.jsとpackage.jsonを修正します。
$ git diff HEAD^^
diff --git a/lib/adaptor.js b/lib/adaptor.js
index 4f8a361..18aecb9 100644
--- a/lib/adaptor.js
+++ b/lib/adaptor.js
@@ -8,7 +8,8 @@
"use strict";
-var Skynet = require("skynet"),
+//var Skynet = require("skynet"),
+var Skynet = require("meshblu"),
Cylon = require("cylon");
var Adaptor = module.exports = function Adaptor(opts) {
@@ -48,7 +49,8 @@ Adaptor.prototype.connect = function(callback) {
this.connector = Skynet.createConnection({
uuid: this.uuid,
token: this.token,
- host: this.host,
+ //host: this.host,
+ server: this.host,
port: this.portNumber,
forceNew: this.forceNew
});
@@ -102,3 +104,7 @@ Adaptor.prototype.message = function(data) {
Adaptor.prototype.subscribe = function(data) {
return this.connector.subscribe(data);
};
+
+Adaptor.prototype.data = function(data,fn) {
+ return this.connector.data(data,fn);
+};
diff --git a/package.json b/package.json
index d076c05..6c0a386 100644
--- a/package.json
+++ b/package.json
@@ -29,6 +29,6 @@
"dependencies": {
"cylon": "~0.22.0",
- "skynet": "latest"
+ "meshblu": "latest"
}
}
Node.jsプログラムのデバイス/サービス登録
MeshbluではIoTプラットフォームにつながる、人、モノ、サービスをすべてUUIDとTOKENで管理します。そのため操作する人も、コネクテッドデバイスも、連携するWebサービスも対等にUUIDとTOKENを発行する必要があります。今回はOSXのNode.jsプログラムをサービスとして登録します。MESHBLU_URLはTLS/SSL通信するMeshbluサーバーです。オレオレ証明書を使っているので--insecureフラグが必要です。
$ export MESHBLU_URL=https://{Meshbluのドメイン名}:4443
$ curl -X POST \
-d "name=iot-http" \
--insecure \
"$MESHBLU_URL/devices"
{"uuid":"xxx","online":false,"timestamp":"2015-03-23T03:46:19.254Z","name":"mqtt-osx","type":"host","ipAddress":"172.17.42.1","token":"xxx"}
BMP180のサンプル
プロジェクトを作成します。
$ mkdir -p ~/node_apps/firmata-bmp180-meshblu/
$ cd !$
package.jsonのcylon-skynetはcloneして修正したリポジトリを指定します。
{
"name": "firmata-bmp180-meshblu",
"version": "0.0.1",
"private": true,
"dependencies": {
"cylon-firmata": "0.19.0",
"cylon-skynet": "masato/cylon-skynet"
},
"scripts": {"start": "node app.js"}
}
app.js
Arduinoのデバイスファイルは、MacBook Proの右側のUSBポートにを挿したので/dev/tty.usbmodem1421になりました。host、uuid、tokenはそれぞれ上記のデバイス登録で取得した値を使います。
"use strict";
var Cylon = require("cylon");
var host = "wss://{Meshbluのドメイン名}";
var portNumber = 4443;
var uuid = "{Node.jsプログラムのUUID}}";
var token = "{Node.jsプログラムのTOKEN}}";
Cylon.robot({
connections: {
arduino: { adaptor: "firmata", port: "/dev/tty.usbmodem1421" },
skynet: { adaptor: 'skynet',
host: host,
portNumber: portNumber,
uuid: uuid,
token: token}
},
devices: {
yellow: { driver: 'led', pin: 13, connection: 'arduino' },
bmp180: { driver: "bmp180" }
},
work: function(my) {
my.skynet.on("message", function(data) {
console.log('data: ' + JSON.stringify(data));
if(data.payload.yellow === "on") {
my.yellow.turnOn();
} else if(data.payload.yellow === "off") {
my.yellow.turnOff();
}
});
every((5).seconds(), function() {
my.bmp180.getAltitude(1, null, function(err, val) {
if (err) {
console.log(err);
return;
}
my.skynet.data({
"temperature": val.temp,
"pressure": val.press,
"altitude": val.alt
},function(data){
console.log(data);
});
});
});
}
}).start();
connectionsディレクティブにはArduinoとMeshblu(Skynet)の2つを定義します。devicesにはMeshbluからメッセージをsubscribeしてLチカするLEDと、大気圧センサーモジュールのBMP180を定義します。Arduinoがonのメッセージを受信するとLEDが点灯し、offで消灯します。BMP180からは5秒間隔でセンシングします。温度(temperature)、大気圧(pressure)、標高(altitude)のデータをJSON形式にフォーマットして、Meshbluに送ります。
サンプルの起動
Node.jsのサンプルプログラムを起動します。my.skynet.data()のコールバックで実装している標準出力が表示されます。
$ nvm use 0.10
Now using node v0.10.37
$ npm start
...
{ timestamp: '2015-03-23T06:33:15.610Z',
temperature: '28.6',
pressure: '100153',
altitude: '98.03716036353367' }
{ timestamp: '2015-03-23T06:33:20.615Z',
temperature: '28.6',
pressure: '100146',
altitude: '98.62549086806833' }
{ timestamp: '2015-03-23T06:33:25.619Z',
temperature: '28.6',
pressure: '100150',
altitude: '98.2892979312604' }
Meshblu側のデータベース
今回のMeshbluの構成ではMongoDBの利用をコメントアウトしているので、センシングデータはNode.jsの組み込みデータベースのNeDBにJSONファイルとして保存されました。
Meshbluコンテナを動かしているDockerホストにログインして、ボリュームにアタッチしている作業ディレクトリに移動します。
$ cd ~docker_apps/meshblu-dev
センシングデータはdata.dbファイルに生のJSONとして保存されています。
$ tail data.db
{"timestamp":"2015-03-23T06:33:15.610Z","temperature":"28.6","pressure":"100153","altitude":"98.03716036353367","_id":"krDon5OH6Frs17ic"}
{"timestamp":"2015-03-23T06:33:20.615Z","temperature":"28.6","pressure":"100146","altitude":"98.62549086806833","_id":"JGdcd8c4ycXXlKEk"}
{"timestamp":"2015-03-23T06:33:25.619Z","temperature":"28.6","pressure":"100150","altitude":"98.2892979312604","_id":"lMj4o7MaYB3RmLrW"}
Pub/Subのテスト
次はメッセージのPub/Subのテストをします。テストに使う環境変数を作成します。
$ export MESHBLU_URL=https://{Meshbluのドメイン名}:4443
$ export PUB_DEV_UUID={Node.jsプログラムのUUID}
$ export PUB_DEV_TOKEN={Node.jsプログラムのTOKEN}
--headerには認証情報としてNode.jsプログラムのUUID/TOKENを指定します。送信データのdevicesキーに、メッセージ送信先デバイスのUUIDを指定します。今回は認証UUIDと送信先UUIDが同じなので自分自身にメッセージを送るサンプルになります。payloadキーにはデバイスに送信するメッセージの本文をJSON形式で指定します。onをデバイスが受信するとLEDを点灯(my.yellow.turnOn();)します。
$ curl --insecure -X POST \
"$MESHBLU_URL/messages" \
-d '{"devices": ["'"$PUB_DEV_UUID"'"], "payload": {"yellow":"on"}}' \
--header "meshblu_auth_uuid: $PUB_DEV_UUID" \
--header "meshblu_auth_token: $PUB_DEV_TOKEN"
{"devices":["xxx"],"payload":{"yellow":"on"}}
offのメッセージを受信するとLEDを消灯(my.yellow.turnOff();)します。
$ curl --insecure -X POST \
"$MESHBLU_URL/messages" \
-d '{"devices": ["'"$PUB_DEV_UUID"'"], "payload": {"yellow":"off"}}' \
--header "meshblu_auth_uuid: $PUB_DEV_UUID" \
--header "meshblu_auth_token: $PUB_DEV_TOKEN"
{"devices":["xxx"],"payload":{"yellow":"off"}}