1.概要
SONY MESHの温度・湿度タグで取得した値をクラウドに送信してグラフ化できるようにします。
クラウドはAWSのAmazon Elasticsearchを使用して、kibanaでデータを可視化します。
前提としてAWS環境はなるべく無料枠で収まる設定になるようにし、送信データ量も個人で試してみるレベルという想定で書いています。
全体のシステム構成としては以下のイメージになります。
2.環境
実施時の環境は以下の通りです。
2.1.AWS環境
Elasticsearchのバージョン 5.3
Kibana Version: 5.3.2
2.2.MESHアプリ利用環境
Ipad iOS 10.3.2
MESHアプリ ver. 1.8.0
3.手順
3.1.AWS環境
※AWSアカウントは開設済みとします
3.1.1. Amazon Elasticsearch環境の準備
Amazon Elasticsearch serviceを開き「新しいドメインの作成」を選択。
任意のドメイン名を入力する。ここでは「mydomain」と入力することにする。またElasticsearchのバージョンはデフォルトの5.3のままとする。
ノードの設定ではAWS無料利用枠に収まるようにインスタンスタイプを「t2.small.elasticsearch」にする。インスタンス数は1、ストレージタイプはEBSでデフォルトのまま。
EBSボリュームサイズは最小の「10」（デフォルト）とする。
アクセスポリシーの設定ではテンプレートの中から「特定のIPからのドメインのアクセスを許可」を選択。自身が使用しているグローバルIPアドレスを入力する。今回はあくまで個人で試すのが目的のため、利用想定としては自分の家からのみアクセスできればよしとする。なお複数のIPアドレスをリスト上で記載することも可能。
最後に設定内容に間違いがないか確認したら「確認」ボタンを押して完了。
3.1.2. Amazon Elasticsearchを利用する
Amazon Elasticsearch Serviceを開くと以下のように作成済みのドメインが表示される。
さきほど作成した「mydomain」をクリックすると、以下の画面に遷移し「エンドポイント」にElasticsearchのURLが「Kibana」にデータを可視化してくれるKibanaのURLが書いてある。「エンドポイント」のURLはMESHから温湿度データを送信する際にアクセスするURL。Kibanaはブラウザから温湿度のグラフを見たい時にアクセスするURL。
3.1.3. Amazon ElasticSearchにデータを送信する
上記のエンドポイントに対してhttpでPOSTメッセージを送るとAmazonES(Elasticsearch)にデータを蓄えることができる。試してみたい場合、例えば以下のようにJSON形式でデータを送ればよい。
curl -XPOST https://search-mydomain-xxx.ap-northeast-1.es.amazonaws.com/indexname/typename/ ¥
-d '{"temp":26.5, "humid":63, "@timestamp":"2017-07-08T10:27:00+0900"}'
※温度をtemp、湿度をhumid、送信日時を@timestampとして格納する場合
3.1.4. AmazonESに送信したデータをKibanaで確認する
上記「Kibana」のURLにブラウザでアクセスすると、初回以下のような画面が表示される。
※表示されない場合はメニューの「Management」を選択
ここでさきほどcurlコマンドで送信した時に指定したindex（今回は"indexname"）を指定すると「Time-field name」で「@timestamp」が以下のように選択できる。
そして「Create」する。
その後はメニューの「Discover」を選択することで送信されたデータ1つ1つを確認することができる。
以上でAWS側の準備は完了です。
3.2.MESHアプリ
次はMESHアプリ側での作業です。
MESHやMESHアプリの基本については以下を参照ください。
MESH
https://meshprj.com/jp/
MESH SDK マニュアル ※要SONY MESH SDKユーザーアカウント
https://meshprj.com/sdk/doc/ja/
MESHの温度・湿度タグを使い、MESH SDKを活用してカスタムタグを作成してAmazonESに温湿度データを送信します。
手順としては以下のようになります。
3.2.1. MESHアカウントで以下MESH開発サイトにサインインする
3.2.2. サインインしたら「Create New Tag」を選択
3.2.3. 湿度データ送信用のカスタムタグを作成
任意のカスタムタグの名前をつけます。ここではHumidMonitorとしました。
「New Function」の左側にある三角を押して詳細設定を開いて、「Execute (0)」をクリック ※New Functionという記載は任意の名前に変更する。ここでは「sendToES」とします。
ここにカスタムタグ実行時のプログラムを書きます
温度・湿度タグから受け取った湿度データをAmazonESに送信するコードは以下になります。
//endpoint
var endPointURL = "https://search-mydomain-xxxx.ap-northeast-1.es.amazonaws.com/indexname/typename/";
var nowdate=new Date();
//年・月・日・曜日を取得する
var year = nowdate.getFullYear();
var month = nowdate.getMonth()+1;
var day = nowdate.getDate();
var hour = nowdate.getHours();
var minute = nowdate.getMinutes();
var second = nowdate.getSeconds();
if ( month < 10 ) {
month = "0" + month;
}
if ( day < 10 ) {
day = "0" + day;
}
if ( hour < 10 ) {
hour = "0" + hour;
}
if ( minute < 10 ) {
minute = "0" + minute;
}
if ( second < 10 ) {
second = "0" + second;
}
var nowtime = year + "-" + month + "-" + day + "T" + hour + ":" +
minute + ":" + second + "+0900";
log(nowtime + " " + messageValues.humidity);
//APIを叩く際のパラメータ
//プロパティの値を渡す
var jsonData = {
"humid" : messageValues.humidity,
"@timestamp":nowtime
};
var sendData = JSON.stringify(jsonData);
log(sendData);
ajax ({
url : endPointURL,
type : "post",
data : sendData,
contentType : "application/json",
dataType : "json",
timeout : 5000,
success : function ( contents ) {
log("POST success");
log(JSON.stringify(contents));
callbackSuccess( {
resultType : "continue"
} );
},
error : function ( request, errorMessage ) {
log("POST error");
log("detail: " + JSON.stringify(request));
callbackSuccess( {
resultType : "continue"
} );
}
});
return {
resultType : "pause"
};
3.2.4. 温度データ送信用のカスタムタグを作成
同様に再度「Create New Tag」から実施し、温度データを送信するプログラムを書きます。以下がコードです。
//endpoint
var endPointURL = "https://search-mydomain-xxxx.ap-northeast-1.es.amazonaws.com/dataindex/thtype/";
var nowdate=new Date();
//年・月・日・曜日を取得する
var year = nowdate.getFullYear();
var month = nowdate.getMonth()+1;
var day = nowdate.getDate();
var hour = nowdate.getHours();
var minute = nowdate.getMinutes();
var second = nowdate.getSeconds();
if ( month < 10 ) {
month = "0" + month;
}
if ( day < 10 ) {
day = "0" + day;
}
if ( hour < 10 ) {
hour = "0" + hour;
}
if ( minute < 10 ) {
minute = "0" + minute;
}
if ( second < 10 ) {
second = "0" + second;
}
var nowtime = year + "-" + month + "-" + day + "T" + hour + ":" + minute + ":" + second + "+0900";
log(nowtime + " " + messageValues.temperature);
//APIを叩く際のパラメータ
//プロパティの値を渡す
var jsonData = {
"temp" : messageValues.temperature,
"@timestamp":nowtime
};
var sendData = JSON.stringify(jsonData);
log(sendData);
ajax ({
url : endPointURL,
type : "post",
data : sendData,
contentType : "application/json",
dataType : "json",
timeout : 5000,
success : function ( contents ) {
log("POST success");
log(JSON.stringify(contents));
callbackSuccess( {
resultType : "continue"
} );
},
error : function ( request, errorMessage ) {
log("POST error");
log("detail: " + JSON.stringify(request));
callbackSuccess( {
resultType : "continue"
} );
}
});
return {
resultType : "pause"
};
3.2.5. iOSのMESHアプリ上で設定する
以下のようにタイマータグと組み合わせて、以下のようにMESHタグを構成する。
タイマーは1分間隔としています。データ量と精度のバランスを見て間隔は調整してください。
作成したカスタムタグはMESHアプリ上でメニューからダウンロードできます。
※詳細はMESH SDKマニュアルを参照
以上でMESH側の作業は完了です。
3.3. Kibanaでグラフ化された温湿度データを確認する
上記AmazonESの「Kibana」のURLにブラウザでアクセスする。
「Visualize」を選択。
今回は「Area chart」を選択。
作成したindex（indexname）を選択し、グラフの詳細設定画面を開きます。
まずY軸（Y-Axis）を設定します。「Aggregation」は「Average」を選択肢、「Field」は「humid」とする。続いてX軸（X-Axis）を設定します。
「Aggregation」は「Date Historgram」を選択肢、「Field」は「@timestamp」とする。
そして上部にある再生ボタン？（右向き三角形のボタン）を押すと以下のようにグラフが表示されます。
同様に温度の方もVisualizeの設定をします。
2つのグラフが作成できたら、最後にDashboardに作成したグラフを並べて一覧できるようにします。
Kibanaのメニューから「Dashboard」を選択し、「Add」から上記で作成したVisualizeを選択して、Dashboardに表示していきます。
これでKibanaのDashboardで温度と湿度のデータを一覧できるようになりました。
このDashboardのURLにアクセスすればいつでもグラフを確認できます。
4.まとめ
本稿ではMESHの温度・湿度タグのデータをAWSのAmazon Elasticsearchに送信し、Kibanaでグラフ化したデータをブラウザから閲覧できるようにする手順を書きました。
5.参考
Interface 2017年 7月号「IOTセンシング初体験」