enebularを使ってみる #mbed

数年前にTwitterやFacebookの反応をリアル可視化する「ソーシャルツリー」を作りました。このソーシャルツリーはハッシュタグ付きツイートの数をカウントしてLEDでその総量を表現することができるのでイベント等ではWeb上の盛り上がりを表現するのに使ってもらいました。

後にLEDの表現方法を変更したソーシャルスター[動画]

この中身の制御はmbed LPC1768を使っています。ただ直接TwitterAPIをたたいているわけではなく、中間のサーバ経由です。中間サーバでは、指定したハッシュタグを使ってTwitterAPIをたたいて検索し、そのツイート数を数えています。中間サーバにmbedからHTTP GETすると数えた数値が教えてもらえるという仕組みです。
私はWeb側の知識が乏しいので、中間サーバのソフトはWebに詳しい某氏に作ってもらいました。

しかし、Web側も自分でいじれるようになりたかったので、簡単にできないかなと探してみたところenebularというサービスを見つけました。
enebularとは「あらゆるデバイスとクラウドサービスを “つなぐ”IoTのためのデータ連携プラットフォーム」らしいです。

enebularのセットアップ

enebularを説明するよりも実際にセットアップしてるところを紹介したほうが早いと思うので、紹介します。
初めて触りましたが、直感的に扱えました。

まずトップページの右上の無料サインアップをクリックして、WebサービスのIDかメールアドレスで登録ができます。
次に以下のページが表示されるので、「+New Project」をクリックし、プロジェクト名を入力します。とりあえず「test_prj」にしました。

次に以下のページが表示されるので「New Flow」をクリックします。

次に表示されるのがFlowを作るページです。左の一覧から部品を選んで真ん中の空白の部分に配置していきます。

今回はソーシャルツリーと同じ様にTwitterのハッシュタグ付きツイートを検出して、通知する仕組みにしたいので、Twitterの部品を選んで置きます。

配置したtwitter部品をダブルクリックするとTwitterと接続するための設定ができます。
次の様に設定しました。Twitter IDはログインして認証すれば設定できます。
「for」の部分はサーチしたいハッシュタグを設定します。とりあえずテスト用のハッシュタグをセットしました。
「Name」はフローの画面で表示させたい名前だと思います。

mbedとのI/Fは最近Milkcocoaのライブラリを作ったので、outputの中からmilkcocoaを選びました。
twitterとmilkcocoaに変換が必要だと思ったので、functionも配置してます。

ハッシュタグ付きツイートが見つかったときのトリガが取れれば良かったので、milkcocoaにPUSHする内容はとりあえずツイートのタイムスタンプをセットするようにしました。functionの中身は次の様にしています。

milkcocoaの設定は次のようにしました。
「Log in as」のところはApp IDのみ入力してます。

あとはそれぞれのパーツを繋げてきます。
繋ぎ終わったら右上の「Deploy」をクリックします。

enebularの準備はこれだけです。

mbed側の準備

mbedのプログラムはmilkcocoaのサンプルプログラムをベースに次のようにしました。プラットフォームはmbed LPC1768です。JBBを使ってEthernetに繋ぎます。

main.cpp

#include "mbed.h"
#include "MQTTInterface.h"
#include "MQTTClient.h"
#include "Milkcocoa.h"
#include "MClient.h"
#include "EthernetInterface.h"

EthernetInterface eth;
RawSerial pc(USBTX,USBRX);

/************************* Your Milkcocoa Setup *********************************/

#define MILKCOCOA_APP_ID      "...YOUR_MILKCOCOA_APP_ID..."
#define MILKCOCOA_DATASTORE   "mbed_lan"

/************* Milkcocoa Setup (you don't need to change this!) ******************/

#define MILKCOCOA_SERVERPORT  1883

/************ Global State (you don't need to change this!) ******************/
const char MQTT_SERVER[]  = MILKCOCOA_APP_ID ".mlkcca.com";
const char MQTT_CLIENTID[] = __TIME__ MILKCOCOA_APP_ID;

extern void onpush(MQTT::MessageData& md);

int main() {

    pc.baud(9600);
    pc.printf("Milkcocoa mbed os ver demo\n\r\n\r\n\r");

    int ret = eth.connect();
    if (ret != 0) {
        printf("\r\nConnection error\r\n");
        return -1;
    }
    pc.printf("\n\rEthernet connected\n\r");

    Milkcocoa* milkcocoa = new Milkcocoa(&eth, MQTT_SERVER, MILKCOCOA_SERVERPORT, MILKCOCOA_APP_ID, MQTT_CLIENTID);

    milkcocoa->connect();

    pc.printf("%d\n\r",milkcocoa->on(MILKCOCOA_DATASTORE, "push", onpush));

    milkcocoa->setLoopCycle(1000);
    milkcocoa->start();

    while(1) {
        if(befor_conter != counter) {
            pc.printf("new tweet count[%d]\r\n",counter);
            befor_conter = counter;
        }
        Thread::wait(1000);
    }
}

void onpush(MQTT::MessageData& md)
{
    MQTT::Message &message = md.message;
    DataElement de = DataElement((char*)message.payload);
    pc.printf("onpush\n\r");
    pc.printf("%d\n\r",de.getInt("timestamp_ms"));
    counter++;
}

とりあえずmilkcocoaから受け取るとcounterをインクリメントしてシリアルコンソールに表示するようにしています。

テスト

mbedにプログラムを書き込み、Twitterでハッシュタグ付きでツイートしてみます。

するとシリアルコンソールに反応が来ました！

これで、JBBにLEDテープをつなげればソーシャルツリーの様にハッシュタグ付きツイートを検出して、LEDを点灯させられますね。

最後に

所要時間は30分程度で簡単に確認ができました。
これなら苦手なWebサイドのアプリケーションも簡単に組めそうな感じです。