Go to Qiita Advent Calendar 2024 Top
LoginSignup
8
9

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?

More than 5 years have passed since last update.

@wamisnet

enebularでNefryクラウドつくってみる

Last updated at Posted at 2018-09-12

こんにちは、わみです！
今回は、Nefryでつかったことのある人もいるかも…しれないNefryクラウドを自分で作ってみようと思います。

これを応用するとNefryにライブラリがないサービスとの連携も簡単にできるはずなのでぜひ試してみてください。

enebularとは

enebular（エネブラー）は、IoT製品・サービスづくりを包括的に支援する、開発・運用サービスです。エッジとクラウドにまたがるIoTアプリケーションを開発し、様々なデバイスへ迅速にデプロイ、さらに膨大な量のデータを可視化やAIにより利活用することで、IoTアプリケーションの最適な運用を支援します。
enebularの名前は、星の数（nebular）ほどあるデバイスを、アップデートにより賢くし（enable）、分散しながら協調するアプリケーションの開発から由来しています。

Node-Redが動いており、今回はそれを使ってNefryクラウドを作ります。
個人的にはenebularは可視化がすぐれているのでまた別の機会に紹介したいと思います。

可視化のところについてはドキュメントもあるのでぜひ触ってみてください。
（他にドキュメントあれば教えてください。）
https://docs.enebular.com/ja/infomotion/sampleinfotypes
https://qiita.com/kitazaki/items/3919673acfd9bf7ac193

MQTTブローカー

今回、MQTTを使ってNefryとenebularを繋ぎます。
（NodeRedにMQTTブローカーを立てられるNodeがあるのですが、使えないのでこの方法で説明します。）

いろんなMQTTブローカーサービスがありますが今回はCloudMQTTというサービスを使います。

MQTTブローカーの準備

CloudMQTTにGoogleアカウントなどでログインすると、この画面に移動します。
「Create New Instance」をクリックします。

名前に「Nefry」と入力して、Planは無料の「Cute Cat（Free）」を選びます。
選んだら「Select Region」をクリックします。

ここのサーバはデフォルトのままで大丈夫です。
「Confirm」をクリックします。

確認されるので問題なければ「Create Instance」をクリックします。

リストに戻るので、先ほど名前をつけた「Nefry」をクリックします。

ここで表示されている赤枠の内容が後で説明するNefryとenebularに設定するのでメモしておきましょう。

これでMQTTブローカーの準備はできました！

enebularの準備

ログインをすると、このようなページになります。
まずはProjectを作成します。「Create Project」をクリックします。

「Nefry」と入力して「Submit」をクリックします。

次にAssetを作成します。「Create Asset」をクリックします。

上から順に「Nefry」、「flow」、「nefry_cloud」と入力して「Continue」をクリックします。

正常にAssetが作成できると、このような画面になります。
「Edit Flow」をクリックしてNefry Cloudのコードを設定します。
表示されるまでかなりの時間がかかります、ゆったりとした気持ちで待ってください。

右端にマウスを合わせると下にメニューが表示されます。
「Import」→「Clipboard」をクリックします。

インポートファイル
[{"id":"cb22f033.4e62a","type":"mqtt in","z":"6a204582.6319ec","name":"","topic":"nefry","qos":"2","broker":"","x":130,"y":620,"wires":[["2cd50412.05734c"]]},{"id":"2cd50412.05734c","type":"debug","z":"6a204582.6319ec","name":"","active":true,"console":"false","complete":"false","x":370,"y":620,"wires":[]},{"id":"4d73977f.4fdd38","type":"http in","z":"6a204582.6319ec","name":"","url":"/setdata","method":"get","swaggerDoc":"","x":150,"y":400,"wires":[["ad85572e.3b5728","c0f5a526.fcf308"]]},{"id":"c0f5a526.fcf308","type":"http response","z":"6a204582.6319ec","name":"","x":390,"y":400,"wires":[]},{"id":"c29d9658.b3e728","type":"mqtt out","z":"6a204582.6319ec","name":"","topic":"nefry","qos":"","retain":"","broker":"","x":530,"y":480,"wires":[]},{"id":"ad85572e.3b5728","type":"function","z":"6a204582.6319ec","name":"","func":"delete msg.req;\ndelete msg.res;\nreturn msg;","outputs":1,"noerr":0,"x":390,"y":480,"wires":[["c29d9658.b3e728"]]},{"id":"d51d5f34.d524b","type":"http in","z":"6a204582.6319ec","name":"","url":"/setdata","method":"post","swaggerDoc":"","x":150,"y":480,"wires":[["c0f5a526.fcf308","ad85572e.3b5728"]]},{"id":"724d4825.8d3ea8","type":"comment","z":"6a204582.6319ec","name":"Web → Nefryにメッセージ送信","info":"","x":190,"y":340,"wires":[]},{"id":"2a1ff8b0.532d38","type":"comment","z":"6a204582.6319ec","name":"Nefry → Webにメッセージ送信","info":"","x":190,"y":560,"wires":[]}]

上のJSONファイルをコピーして、enebularの入力欄に貼り付けます。
貼り付けたら、「Import」をクリックします。

上記の方法以外にも公式Twitterで教えていただいた方法でもいけるようです！

インポートできるとこんな感じになります。
初めにクリックしたところに配置されるので左上にマウスをずらしてそこでクリックするとよいでしょう！

さてNefryと繋げるためにMQTTの設定をします。
画像に沿って順にクリックします。

MQTTブローカーの準備の章で取得したサーバーとポートを設定します。

Securityタブに移動し、MQTTブローカーの準備の章で取得したUserとPasswordを設定します。
設定が完了したら「Add」をクリックします。

設定が保存できれば、サーバの欄に先ほど設定したアドレスが表示されます。表示されていることを確認出来たら「Done」をクリックします。

ついでにもう一つあるNodeも設定します。
画像に沿ってクリックすると、先ほど設定したアドレスが選択できるのでそれを選んで「Done」をクリックします。

これで設定が完了したので右上にある「Deploy」と書かれた赤いボタンをクリックします。
しばらくするとデプロイが完了したと表示されるのでそれまで待ちましょう。

最後にnefryと書かれたノードの下に「connected」と出れば準備は完了です！

「connected」と出ない場合は先ほどのMQTTの設定が間違っている可能性が高いので見直してみましょう。

Nefryの準備

ライブラリインストール

まずは、下準備としてひとつライブラリをインストールします。
「スケッチ」→「ライブラリをインクルード」→「ライブラリを管理」を選択します。

2018-09-01_17h54_29.png

ライブラリを管理をクリックするとライブラリマネージャーが表示されます。

マネージャー上部に検索欄があるのでそこに「pubsub」と入力すると下のような状態になります。
画像に沿ってインストールボタンをクリックしてライブラリをインストールしてください。
（ライブラリバージョン2.6.0での動作を確認しています。）

2018-09-01_17h48_08.png

「Installed」と表示され、インストールが完了したらその画面を閉じてください。

2018-09-01_18h07_10.png

プログラム作成

ライブラリのインストールが終わったところでプログラムを作成していきます。

Nefryクラウドと同じようにサーバからNefryに通知を投げる機能を実装していきます。

全体のコードはこちら！

#include <PubSubClient.h>
#include<Nefry.h>

WiFiClient httpsClient;
PubSubClient mqttClient(httpsClient);

void callback(char* topic, byte* payload, unsigned int length){
  Serial.print("Received. topic=");
  Serial.println(topic);
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

void setup() {
  mqttClient.setServer("url", 1883);
  mqttClient.setCallback(callback);
}

void loop() {
if (!mqttClient.connected()) {
    String device = Nefry.getModuleName();
    if (mqttClient.connect(device.c_str(), "User", "password")) {
      Serial.println("Connected.");
      int qos = 0;
      mqttClient.subscribe("#", 0);
      Serial.println("Subscribed.");
    }
  }
  mqttClient.loop();
}

2か所修正します。

  • mqttClient.setServer("server", port); MQTTブローカーの準備の章で取得したサーバーとポートを設定します。
  • mqttClient.connect(device.c_str(), "User", "password")MQTTブローカーの準備の章で取得したUserとPasswordを設定します。

修正ができたらNefryにプログラムを書きこんでみましょう！

Nefryの準備も完了です！

メッセージを投げてみよう

メッセージを投げるためにenebularのURLを取得します。

enebularのサイトに戻り、InformationのアイコンをクリックするとこのようにURLが表示されます。
このURL + /setdataでNefryにメッセージを投げることができます！

この画像の場合「 https://ev2-prod-node-red-8c9b84fa.herokuapp.com/setdata 」という形になります。

皆さんそれぞれのURLをたたくと、Nefryのシリアルモニタに通知がいきます。

自由なメッセージを投げることもできます。

curlコマンドの例を置いておきます。

curl -i -X POST \
   -H "Content-Type:application/json" \
   -d \
'{
	"test": "hello"
}' \
 'https://ev2-prod-node-red-8c9b84fa.herokuapp.com/setdata'

おまけ

上記の例はWeb→Nefryでしたが、もちろんその逆もできます。

NefryクラウドではNefry→Webに対応していないのでおまけとして記載します。

void loop() {
  if (!mqttClient.connected()) {
    String device = Nefry.getModuleName();
    if (mqttClient.connect(device.c_str(), "User", "password")) {
      Serial.println("Connected.");
      int qos = 0;
      mqttClient.subscribe("#", 0);
      Serial.println("Subscribed.");
    }
  }
  if(Nefry.readSW()){
     mqttClient.publish("nefry","push SW");//追加
  }
  mqttClient.loop();
}

このサンプルコードは、NefryのSWを押されたときにenebularにメッセージを送るものです。

このpublish関数を叩くとメッセージをサーバに投げることができるのでさらにいろんな連携ができるのではないでしょうか？

まとめ

NefryとenebularをつかってNefryクラウドをつくってみました。

NodeRedには様々なサービスを簡単に追加して動かすことができる機能もあるので難しくないと思います。

今回のサンプルはメッセージを投げているだけなので様々なサービスを追加してぜひ遊んでみてください！！

8
9
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
8
9

Delete article

Deleted articles cannot be recovered.

Draft of this article would be also deleted.

Are you sure you want to delete this article?