RaspberryPi と GoogleCloudPlatform で家電をコントロール Vol.2

ハードウェアが出来たので、ソフトウェア部分を作成していきます。

リモコンの学習とhubotのインストール

操作したい家電のリモコンデータの学習と、hubotをインストールしてslackと接続していきます。
こちらを参考に作成しました。

ここまでで、スマートスピーカーから操作できるスマートリモコンが出来ましたので、これにGoogleCloudPlatformに連携してきます。

GoogleCloudPlatform との連携

RaspberryPiで温度・湿度を測定し、測定結果をAPIで送信します。CloudFunctionsでこれを受信して、CloudSQLにデータを格納します。
この際に温度変化等からON/OFFを判断してRaspberryPiに結果を戻し、リモコン信号を発信させます。（今回は固定値を返しています。）
まずは、RaspberryPiからAPIで送信し、結果を受け取ってリモコン信号を発信する流れを作成していきます。

1. CloudSQLの準備

• インスタンスを作成していきます。

• MySQLを指定して、インスタンスID、パスワード等を指定していきます。

• とりあえずミニマムの構成で作成しました。

• インスタンスの作成が出来たら、データベースを作成していきます。ここではroomDbという名前で作成しました。

• 作成したデータベースに、測定したデータを格納するテーブルを作成します。

CREATE TABLE `roomData` (
  `recId` bigint(20) NOT NULL AUTO_INCREMENT,
  `temperature` decimal(5,2) DEFAULT NULL,
  `humidity` decimal(5,2) DEFAULT NULL,
  `pressure` decimal(7,2) DEFAULT NULL,
  `measurement_time` datetime DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`recId`)
)

これでCloudSQLの準備は出来ました。

２. CloudFunctionsの準備

• APIを受けるCloudFunctionsで作成していきます。

• 未認証の呼び出しを受けれるように作成していきます。

3. 受け取ったデータの格納と、レスポンスを返します。

• 先程作成したテーブルへのデータ格納と、レスポンスの返却部分を作成します。
  レスポンスは固定内容を返すようにしています。

const mysql = require('mysql');

const connectionName = '＊＊＊＊＊＊＊＊:＊＊＊＊＊＊＊:room';
const dbUser = '＊＊＊＊＊';
const dbPassword = '＊＊＊＊＊';
const dbName = 'roomDb';

const mysqlConfig = {
  connectionLimit: 1,
  user: dbUser,
  password: dbPassword,
  database: dbName,
};

if (process.env.NODE_ENV === 'production') {
  mysqlConfig.socketPath = `/cloudsql/${connectionName}`;
}

let mysqlPool;

exports.main = (req, res) => {
  if (!mysqlPool) {
    mysqlPool = mysql.createPool(mysqlConfig);
  }

  const insertSQL = `INSERT INTO roomData (temperature, humidity, pressure) VALUES ('${req.body.temp}', '${req.body.hum}', '${req.body.pressure}')`;
  console.log(insertSQL);

  mysqlPool.query(insertSQL, (err, results) => {
    if (err) {
      console.error(err);
    }
  });

  res.status(200).send({'command':'airconon'});
}

• PACKAGE.JSON にMySQLを追加します。

  "dependencies": {
    "mysql": "2.18.1"
  }

これでGoogleCloudPlatform側の準備が出来たので、RaspberryPi側と繋いでいきます。

RaspberryPi から測定結果を送信

スイッチサイエンスのBME280のリポジトリからPythonのサンプルコードをダウンロードします。
このコードを流用して、APIの送信部分を追加します。
作成したCloudFunctionsのURLを指定して、測定結果を送信します。
APIから学習したコード名を返すようにしていますので、APIのレスポンスから取得してリモコン信号の送信用スクリプトに渡してあげます。

url = "https://********.cloudfunctions.net/********"
payload = {'temp': temperature, 'hum': var_h, 'pressure': pressure/100 }

res = requests.post(url, json=payload)
if res.status_code == requests.codes.ok:
    resJson = res.json()
    subprocess.call(["./bin/pi-send.sh", resJson["command"]])
else:
    print "api error!!"

これで、測定結果をGCPに送信し、そこから受け取ったレスポンスに応じてリモコン信号を発信することが出来ました。
次からは、レスポンスの作成部分を作っていきたいと思います。