23: Intel Edison実践編 (3) 〜 XDKで開発したプログラムからiotkit-agentにデータを送る

都元と学ぶIoTアドベントカレンダーだった2014

#Intel

#ハードウェア

#Edison

都元ダイスケ

2014.12.23

この記事は公開されてから1年以上経過しています。情報が古い可能性がありますので、ご注意ください。

よく訓練されたアップル信者、都元です。昨日のエントリーはこちらです。今回いよいよ、実際にセンサーから取得した値をIoT Analyticsに送ってみようと思います。

Edison上で動かすnodeアプリケーションから直接IoT Analyticsに接続しても良いのでしょうけど、送信部分を担ってくれるiotkit-agentというものが存在します。Treasure Dataに直接データを流すのではなく、td-agentを介してデータを上げる、というのと同じような考え方でしょう。

iotkit-agent

まず、iotkit-adminで、デバイスのアクティベートが必要ですので、まだの場合は以前の記事を参照して済ませておきましょう。

次に、iotkit-agentはデフォルトでインストール済みではありますが、無効になっていますので、下記コマンドで有効化しておきます。

# systemctl enable iotkit-agent
# systemctl start iotkit-agent

下記ログの通りプロセスが上がり、7070/tcp及び41234/udpでポートが開いた ^*1ようです。

# systemctl status iotkit-agent  -l
● iotkit-agent.service - iotkit-agent
   Loaded: loaded (/lib/systemd/system/iotkit-agent.service; enabled)
   Active: active (running) since Mon 2014-12-22 05:20:25 UTC; 13min ago
 Main PID: 1257 (node)
   CGroup: /system.slice/iotkit-agent.service
           └─1257 node /usr/bin/iotkit-agent

Dec 22 05:20:25 edison systemd[1]: Started iotkit-agent.
Dec 22 05:20:28 edison iotkit-agent[1257]: 2014-12-22T05:20:28.479Z - info: Sending attributes...
Dec 22 05:20:38 edison iotkit-agent[1257]: 2014-12-22T05:20:38.724Z - info: Starting listeners...
Dec 22 05:20:38 edison iotkit-agent[1257]: 2014-12-22T05:20:38.733Z - info: TCP listener started on port:   7070
Dec 22 05:20:38 edison iotkit-agent[1257]: 2014-12-22T05:20:38.755Z - info: UDP listener started on port:  41234

ここでは60秒ごとにセンサー値をIoT Analyticsに送ってみようと思います。TCPできっちり送信するのも良いのですが、ここはオーバーヘッドの軽いUDPで通信してみましょう。ちなみに、各プロトコルでのiotkit-agentとの通信方法は、GitHub上にサンプルコードが上がっています。

コーディング

前半はUDPクライアントを作って、iotkit-agentに対してデータを送信するメソッドsendObservationを定義しています。

コード後半は、以前ご紹介したコードとほぼ同じです。ログ出力するのに加えて、sendObservationメソッドを呼んでいるだけです。また、繰り返し実行周期は60秒としました。

var dgram = require('dgram');
var client = dgram.createSocket('udp4');
var udpOptions = {
    host : '127.0.0.1',
    port : 41234
};

function sendObservation(name, value, on){
    var msg = JSON.stringify({
        n: name,
        v: value,
        on: on
    });

    var sentMsg = new Buffer(msg);
    console.log("Sending observation: " + sentMsg);
    client.send(sentMsg, 0, sentMsg.length, udpOptions.port, udpOptions.host);
}

var groveSensor = require('jsupm_grove'); 
var tempPin = new groveSensor.GroveTemp(0);
var lightPin = new groveSensor.GroveLight(1);

setInterval(function () {
    var date = new Date();
    console.log("==== " + date + " ====");
    var temp = tempPin.value();
    var light = lightPin.value();
    
    console.log(tempPin.name() + ": " + temp);
    sendObservation('temp', temp, date.getTime());

    console.log(lightPin.name() + ": " + light);
    sendObservation('light', light, date.getTime());
}, 60000);