コメント無し

# まえがき（が長くてすみません） 先日開催された[「obniz IoTコンテスト 2021」](https://elchika.com/promotion/obniz2021/)に参加させていただき、せっかく無償でobnizをいただけましたので更に何か試してみようと思案しました。

以前、androidスマホアプリなどでBluetooth接続機器の操作を試したことがあったので、これはひょっとしてobnizでも何か役に立ちそうな仕組みに使えないか？と考えました。 かなり前のことですが、近所のドラッグストアのスマホグッズコーナーに何やら怪しい？スマートバンドが売っていてこれが超お買い得価格設定でしたのでGetしてみました。確か、実売価格で￥1,200くらいだったと思います。（ちょっと正確に覚えてないけど、あまりの安さにて慌てて購入した記憶あり）  ! ネット通販サイトを見ると、この手の（かつ、この金額の）ものは色々出回ってますね。。。。ちょっと怪しげですが。

ところがこれは計測データを蓄積しても、これまた怪しい専用アプリでデータを見るしか無いというのが何しろネックです。

※当然ながら、本システムで見守り及びバイタル計測の責を追うシステムにそのまま使うことは推奨しません。計測データは参考値範囲として利用するか、あくまでシステム試作事例としてご覧になっていただきますようお願いします。 # システム概要

クラウド経由で定期的に計測したバイタルデータが見守り側のLINEに通知され、蓄積されたデータをグラフで見ることもできます。 

今回のシステムは仕組みは同様ですが「わずか千円ちょっとのスマートバンドでもこれが実現できちゃう」というところがミソでしょうか。 ## LINE通知画面  ## グラフ表示（Machinist）  # 機材説明 |機器名|メーカー|備考| |:---:|:---:|:---:| |obniz Board 1Y|obniz|言わずと知れたobniz| |LM716 (SmartBand)|不明|近所のドラッグストアで購入。メーカ等は不明です。|

# システム構成 今回のシステム構成は単純です。 有線はありません。（電源は取るとして）　obnizから直接BLE通信を行ってスマートバンドへのコマンド送信、及び測定データ取得を行います。 

また、これには他にも理由があります。というのは、obniz-Cloudの実行時間制限によるものです。 obniz-Cloudは最大で30秒までの実行時間制限があります。

node.jsの場合はとりあえずはPCで動かすので時間制限は関係ないです。また、node.jsを利用できるクラウドサービスではデフォルトでも60秒くらいは実行時間がありますし、大抵の場合延長する事もできますのでこの辺の問題は回避できました。 # 実行動画 @[youtube](https://youtu.be/bHEDU2X7Wq8) # プログラム解説 順番にポイントとなる箇所の説明を記載しておきます。 ## BLE初期化 特殊なことはありません。最初に必要な手続きとして記述。 ```JS:BLE初期化 await obniz.ble.initWait(); obniz.display.clear(); obniz.display.print("BLE initialized\n"); ``` ## デバイススキャン 今回はデバイス名称を指定してスキャンします。 ```JS:デバイススキャン var target = { localName: TARGET_DEVICE_NAME }; var peripheral = await obniz.ble.scan.startOneWait(target); ``` ## デバイスへ接続 スキャンした戻り値（peripheral）を確認して、これを使ってデバイスに接続します。 ```JS:デバイスへ接続 if(peripheral) { obniz.display.print("found band\n"); try { await peripheral.connectWait(); obniz.display.print("connected band\n"); ・ ・ ・ ``` ## 変更通知の受け取り申し込み 機器からの変更通知として、今回はバイタル測定結果の通知が発生した際にNotifyを受け取るための申込みを行います。

```JS:Subscribe await peripheral.getService(TARGET_SERVICE) .getCharacteristic(TARGET_CHARACTERISTIC_SUBSCRIBE) .registerNotifyWait((data) => { ・ ・ ・ ``` ## 計測実行コマンドの書き込み

```JS:Write var bytes = new Uint8Array(9); // 以下は実際には調査したコマンドバイト配列を設定しますが、説明用に今回はすべて 0xff で埋めてます bytes[0] = 0xff; bytes[1] = 0xff; bytes[2] = 0xff; bytes[3] = 0xff; bytes[4] = 0xff; bytes[5] = 0xff; bytes[6] = 0xff; bytes[7] = 0xff; bytes[8] = 0xff; obniz.display.print("starting measurement\n"); await peripheral.getService(TARGET_SERVICE).getCharacteristic(TARGET_CHARACTERISTIC_WRITE).writeWait(bytes); ``` ## 通知データについて これについても当然ながら公式のデータシートがあるわけでもなく、ご自身で実際にその機器とやりとりしているBluetooth通信を調べるしかないです。Bluetooth通信のログなどはAndroidスマホ等で出力できますのでこれをみて頑張って解析するしか無いです。 この手段についてはここでは割愛します。 ## LINEとMachinistへのデータ送信

これらのほかクラウドサービスとobnizの連携については今後スポットをあてて説明するような紹介投稿できればと思っています。 （ボリューム的に厳しいのでこの章は今度） # プログラムソース

```JS:for_node.js // this is obniz program on node.js const Obniz = require("obniz"); const request = require("request"); const TARGET_DEVICE_NAME = "LM716"; const TARGET_SERVICE = "ターゲットサービスのID"; const TARGET_CHARACTERISTIC_WRITE = "コマンド書き込みのCharacteristicID"; const TARGET_CHARACTERISTIC_SUBSCRIBE = "Subscribe用のCharacteristicID"; const url_push = "https://api.line.me/v2/bot/message/push"; const channel_id = "LINEのチャネルID"; const access_token = "LINE接続のアクセストークン"; const url_machinist = "https://gw.machinist.iij.jp/endpoint"; const access_token_machinist = "Machinist接続のアクセストークン"; var obniz = new Obniz("ご自身のobniz-ID"); // called on online obniz.onconnect = async function() { // Smartband接続 await obniz.ble.initWait(); obniz.display.clear(); obniz.display.print("BLE initialized\n"); var target = { localName: TARGET_DEVICE_NAME }; var peripheral = await obniz.ble.scan.startOneWait(target); if(peripheral) { obniz.display.print("found band\n"); try { await peripheral.connectWait(); obniz.display.print("connected band\n"); // subscribe await peripheral.getService(TARGET_SERVICE).getCharacteristic(TARGET_CHARACTERISTIC_SUBSCRIBE).registerNotifyWait((data) => { if(data.length >= 19) { var data = { "SpO2": data[16], "bp_low": data[17], "bp_high": data[18], "pulse": data[19] }; var message = []; message.push("SpO2: " + data.SpO2 + " %"); message.push("bp: " + data.bp_high + "/" + data.bp_low + " mmHg"); message.push("pulse: " + data.pulse + " bpm"); // print data obniz.display.clear(); obniz.display.print(message[0]+"\n"); obniz.display.print(message[1]+"\n"); obniz.display.print(message[2]+"\n"); // Push to LINE var postdata = { "data": data, "message": message.join("\n") } postMessage(postdata); } }); // write var bytes = new Uint8Array(9); // 以下は実際には調査したコマンドバイト配列を設定しますが、説明用に今回はすべて 0xff で埋めてます bytes[0] = 0xff; bytes[1] = 0xff; bytes[2] = 0xff; bytes[3] = 0xff; bytes[4] = 0xff; bytes[5] = 0xff; bytes[6] = 0xff; bytes[7] = 0xff; bytes[8] = 0xff; obniz.display.print("starting measurement\n"); await peripheral.getService(TARGET_SERVICE).getCharacteristic(TARGET_CHARACTERISTIC_WRITE).writeWait(bytes); } catch(e) { console.error(e); } } }; // LINEにメッセージ and Machinistにデータを送る async function postMessage(postdata) { // LINEに送信 var line_options = { url: url_push, method: "post", headers: { "Authorization": "Bearer " + access_token }, json: { "to": channel_id, "messages": [{ "type": "text", "text": postdata.message }] } } await request(line_options, async(error, response, body) => { console.log(body); if(error) { console.log(error); } }); // Machinistに登録 var mdata = { "agent": "Smart-band Agent", "metrics": [ { "name": "SpO2", "namespace": "Smart-band Sensor", "data_point": { "value": parseInt(postdata.data.SpO2) } }, { "name": "blood pressure high", "namespace": "Smart-band Sensor", "data_point": { "value": parseInt(postdata.data.bp_high) } }, { "name": "blood pressure low", "namespace": "Smart-band Sensor", "data_point": { "value": parseInt(postdata.data.bp_low) } }, { "name": "pulse", "namespace": "Smart-band Sensor", "data_point": { "value": parseInt(postdata.data.pulse) } } ] } var machinist_options = { url: url_machinist, method: "post", headers: { "Authorization": "Bearer " + access_token_machinist }, json: mdata } await request(machinist_options, async(error, response, body) => { console.log(body); if(error) { console.log(error); } }); } // called on offline obniz.onclose = async function () {} ``` # 今後の課題