【Me守る君】スマートバンドによる自動バイタル計測

先日開催された「obniz IoTコンテスト 2021」に参加させていただき、せっかく無償でobnizをいただけましたので更に何か試してみようと思案しました。
コンテスト参加向けのシステムを作成するにあたり初めてobnizを触ったので色々わからないことが多かったのですが、逆に面白そうな機能も知ることができました。その中でも特にobnizの特徴として挙げられる機能の一つにBLE通信があると思います。他の機器でこの機能を実装しようとすると何かしら追加機材が必要になりますがobnizは最初からボード内にBLE通信機能が実装されています。
以前、androidスマホアプリなどでBluetooth接続機器の操作を試したことがあったので、これはひょっとしてobnizでも何か役に立ちそうな仕組みに使えないか？と考えました。

かなり前のことですが、近所のドラッグストアのスマホグッズコーナーに何やら怪しい？スマートバンドが売っていてこれが超お買い得価格設定でしたのでGetしてみました。確か、実売価格で￥1,200くらいだったと思います。（ちょっと正確に覚えてないけど、あまりの安さにて慌てて購入した記憶あり）

ネット通販サイトを見ると、この手の（かつ、この金額の）ものは色々出回ってますね。。。。ちょっと怪しげですが。
実際使ってみると普通に使えましたし、なんといってもSpO2も計れちゃうのがすごい。当然ながら医療機器ではありませんので数値は絶対値として信頼できるものではありません。が、継続して使えばなんとなくの変化は見えるかも？と思ってしばらく使ってました。
ところがこれは計測データを蓄積しても、これまた怪しい専用アプリでデータを見るしか無いというのが何しろネックです。

まえがきがやたら長くて大変申し訳無いです。
結論としてこのデバイスにobnizから自前でBLE通信して計測データを取得する仕組みを作ってみよう、というのが今回のシステムになります。
※当然ながら、本システムで見守り及びバイタル計測の責を追うシステムにそのまま使うことは推奨しません。計測データは参考値範囲として利用するか、あくまでシステム試作事例としてご覧になっていただきますようお願いします。

obnizを使ってスマートバンドの自動計測ができれば、例えば遠く離れて暮らす両親のちょっとした見守りシステム、もしくは健康管理システムになります。お年を召した方々にスマホアプリでスマートバンドの計測データ管理をしてもらうのはハードル高いですでが、このシステムであればこのバンドを付けてもらうだけであとは何もしなくてOK。たまに充電だけはしないといけないので充電のレクチャだけですね。（厳密に言えば両親宅にWifiが必要なのはハードルありか。。。。）
どちらにせよ最初に設定して置いてくればあとは何もしなくても毎日バンドをつけていてもらえばOKです。
クラウド経由で定期的に計測したバイタルデータが見守り側のLINEに通知され、蓄積されたデータをグラフで見ることもできます。

実際同様な仕組みで介護施設等に向けたobnizを利用したシステムが商用化されているようですね。
今回のシステムは仕組みは同様ですが「わずか千円ちょっとのスマートバンドでもこれが実現できちゃう」というところがミソでしょうか。

機器名	メーカー	備考
obniz Board 1Y	obniz	言わずと知れたobniz
LM716 (SmartBand)	不明	近所のドラッグストアで購入。メーカ等は不明です。

※スマートバンドは同じ箱のものを２つ購入しどちらも外観は一緒なのですが、実際にBluetoothでスキャンすると違う機器名でした。。。機械は一緒でも中身のファームウェアとかはいろいろあるのかも。

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

前回投稿させていただいた「Wekiの気持ち」では、できるだけobniz-Cloud上で仕組みを作ろうとしたのですが、幾つか問題があってGoogleAppsScript側に一部ロジックを寄せています。（その問題というのが Authorizationヘッダ付きのHTTPリクエストがいまいちうまくいかないという問題で、ちょっとまだ私の中でも解決していません）
今回はできるだけシステム構成を単純にしたかったので上記の問題が発生しないnode.js上でのプログラムとしています。
また、これには他にも理由があります。というのは、obniz-Cloudの実行時間制限によるものです。
obniz-Cloudは最大で30秒までの実行時間制限があります。
今回、最初はobniz-Cloud上でのアプリ実行として試作を始めたのですが、スマートバンドへBLE接続しバイタル計測して結果を取得するだけでも30秒以上かかってしまいクラウドアプリケーションが毎回タイムアウトエラーになってしまいました。（あと10秒くらいあるとギリギリ入りそうなんですが・・・残念）
node.jsの場合はとりあえずはPCで動かすので時間制限は関係ないです。また、node.jsを利用できるクラウドサービスではデフォルトでも60秒くらいは実行時間がありますし、大抵の場合延長する事もできますのでこの辺の問題は回避できました。

ここに動画が表示されます

順番にポイントとなる箇所の説明を記載しておきます。

特殊なことはありません。最初に必要な手続きとして記述。

BLE初期化
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);

スキャンした戻り値（peripheral）を確認して、これを使ってデバイスに接続します。

デバイスへ接続
if(peripheral) {
  obniz.display.print("found band\n");
  try {
    await peripheral.connectWait();
    obniz.display.print("connected band\n");
                   ・
                   ・
                   ・

機器からの変更通知として、今回はバイタル測定結果の通知が発生した際にNotifyを受け取るための申込みを行います。
この申込に必要なのはターゲットとなる「Service」と「Characteristics」です。これもデバイスの仕様書がないので、事前に実行したログ等から読みとって探しておく必要があります。

Subscribe
await peripheral.getService(TARGET_SERVICE)
                .getCharacteristic(TARGET_CHARACTERISTIC_SUBSCRIBE)
                .registerNotifyWait((data) => {
                   ・
                   ・
                   ・

Notifyを受け取る準備ができたら計測の実行コマンドを送信（書き込み）します。このコマンドも同様に事前に把握必要。
なお、前段のNotify申込時の「Characteristics」と、コマンド書き込みの「Characteristics」はそれぞれ別に定義されているはずです。
また、今回利用した機材については仕様の公開情報がありません。このため、下記サンプルコード中のコマンドバイト配列についてはこちらで調査した機器のものを勝手に公開はできませんので仮にすべて 0xff で表記しています。

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へのメッセージ送信については Line DevelopersサイトのMessaging API をご参考にREST-API仕様をご確認ください。
Machinistへのデータ送信のREST仕様も Machinistサイトに詳細説明あります。
これらのほかクラウドサービスとobnizの連携については今後スポットをあてて説明するような紹介投稿できればと思っています。
（ボリューム的に厳しいのでこの章は今度）

今回はobniz-Cloud上ではなく node.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 () {}

今回はなんちゃってスマートバンドを用いた計測でしたので、計測した測定値そのものの信頼性についてはコメントしません。が、BLE経由で計測機器に自動計測実行を行い、計測データを収集してLINE通知・クラウドサービス上にデータ保存してグラフ表示、ということまでシステムを組むという例を作成できました。
当然ながらこれ自身で見守りシステムとしてそのまま使えるものではありませんが、信頼性のある機材が揃えば実際の運用にも繋げられる可能性を見いだせたかと思います。
※本システムで見守り及びバイタル計測の責を追うシステムにそのまま使うことは推奨しません。計測データは参考値範囲として利用するか、あくまでシステム試作事例としてご覧になっていただきますようお願いします。