複数ソース(SwitchBot, OpenWeater,etc)からの温度・湿度情報をInfluxDBに保存してGrafanaで表示する

今年も暑い

“今日も暑ーい1日になりそうです” ほら言ってる わっ超あおられる ♪

ほんとテレビのニュースをみると暑いって話ばかり。なので家で安全に過ごしたい。外に出る場合も温度や温度を把握しておきたい。

参考にした記事

次のデバイス or APIから温度あるいは湿度の情報を得て

• OpenWeather (Cloud API)
• SwitchBot温湿時計シリーズ (IoTデバイス)
• TEMPer温度計 (USBデバイス)

次の記事で InfluxDBv2 に格納し Grafana で可視化することができる。

やりたいこと

私は SwitchBot Hub2 も TEMPer も所有してるので、OpenWeather 含め、これらの温湿度情報まとめて表示したい。

Grafana から InfluxDB の Flux Query

Fluxを良くわかってないので間違っているかもしれません。とりあえずユニオンすれば良いかなぁとやって出来たので…他に良い方法があるのかもしれませんが…。

SwitchBotの記事の様に単一の情報元なら次の様なクエリーでGrafanaに表示できる。

from(bucket: "switchbot")
  |> range(start: v.timeRangeStart, stop:v.timeRangeStop)
  |> filter(fn: (r) =>
    r._measurement == "MeterPlus" and
    r._field == "humidity"
  )

じゃあ複数をまとめるには？

fromで取得したデータはstreamという様なので、各情報を一旦streamに入れる。

OpenWeatherMap

上記のOpenWeatherの参考記事の様にTelegrafのOpenWeatherMap PlugIn で取得しているのでCPU, MEMなどの情報も入っている。ここから私はraspiという名前のバケットに格納した。_measurementのweatherに天気情報が入っているがcpu, memなども入っているのでweatherでフィルタし、温度の場合はtemperatureでフィルタする。後でまとめるセンサーのデータと混ぜるとcity,condition_nameなどが邪魔になるので最低限必要なカラムだけキープする。

openweathermap = 
from(bucket: "raspi")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "weather")
  |> filter(fn: (r) => r["_field"] == "temperature")
  |> keep(columns: ["_measurement", "_field", "_time", "_value"])

SwitchBot

上記のSwitchBotの参考記事のやり方で行い、switchbotバケットに入れているのと、私は複数デバイスを持っているのでtemperatureだけでフィルタした。

switchbot =
from(bucket: "switchbot")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_field"] == "temperature")

TEMPer

こちらも同様。

temper = 
from(bucket: "temper")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_field"] == "temperature")

まとめる

unionでまとめて必要なカラムだけ残す。

union(tables: [openweathermap, switchbot, temper])

結果

openweathermap = 
from(bucket: "raspi")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "weather")
  |> filter(fn: (r) => r["_field"] == "temperature")
  |> keep(columns: ["_measurement", "_field", "_time", "_value"])

switchbot =
from(bucket: "switchbot")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_field"] == "temperature")

temper = 
from(bucket: "temper")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_field"] == "temperature")

union(tables: [openweathermap, switchbot, temper])

同様に湿度はhumidityでフィルタ。

凡例の名前を変える

下記のGrafanaフォーラムに書かれた方法の通りの手順で凡例名(Legend names)をわかりやすい名前に変えていく(家族も見るので)。

できたグラフ

QNAPでGradana+InfluxDBを動かしReverse Proxyで公開してるので外からスマフォ画面で。

もろもろ

• Flux Queryがこれで良いのかどうか不明なので勉強する
• 夏に負けない