「switchbotの部屋の気温をGrafana,InfruxDBで可視化してみる」 可視化愛好家、前加賀美の今日も可視化日和！！ #1

$ sudo apt update
$ sudo apt install influxdb

$ sudo pip3 install influxdb
$ sudo apt install influxdb-client

$ sudo systemctl unmask influxdb.service
$ sudo systemctl start influxdb

$ influx
Connected to http://localhost:8086 version 1.6.4
InfluxDB shell version: 1.6.4
> CREATE DATABASE tempDB
> exit

$ sudo pip3 install bluepy

from influxdb import InfluxDBClient
import struct
import sys
from bluepy.btle import Scanner, DefaultDelegate
import time
from datetime import datetime

# データベースに接続
dbclient = InfluxDBClient(host='localhost', port=8086, database='tempDB')

#Broadcastデータ取得用デリゲート
#class SwitchbotScanDelegate(btle.DefaultDelegate):
class SwitchbotScanDelegate(DefaultDelegate):
    #コンストラクタ
    def __init__(self, macaddr):
        #btle.DefaultDelegate.__init__(self)
        DefaultDelegate.__init__(self)
        #センサデータ保持用変数
        self.sensorValue = None
        self.macaddr = macaddr
 
    # スキャンハンドラー
    def handleDiscovery(self, dev, isNewDev, isNewData):
        # 対象Macアドレスのデバイスが見つかったら
        if dev.addr == self.macaddr:
            # アドバタイズデータを取り出し
            for (adtype, desc, value) in dev.getScanData():  
                #環境センサのとき、データ取り出しを実行
                if desc == '16b Service Data':
                    #センサデータ取り出し
                    self._decodeSensorData(value)
 
    # センサデータを取り出してdict形式に変換
    def _decodeSensorData(self, valueStr):
        #文字列からセンサデータ(4文字目以降)のみ取り出し、バイナリに変換
        valueBinary = bytes.fromhex(valueStr[4:])
        #バイナリ形式のセンサデータを数値に変換
        batt = valueBinary[2] & 0b01111111
        isTemperatureAboveFreezing = valueBinary[4] & 0b10000000
        temp = ( valueBinary[3] & 0b00001111 ) / 10 + ( valueBinary[4] & 0b01111111 )
        if not isTemperatureAboveFreezing:
            temp = -temp
        humid = valueBinary[5] & 0b01111111
        #dict型に格納
        self.sensorValue = {
            'SensorType': 'SwitchBot',
            'MacAddr': self.macaddr,
            'Temperature': temp,
            'Humidity': humid,
            'Battery': batt
        }


def send_temp_data(macaddr):
    # macaddr指定した温湿度センサの値を取得
    macaddr = str.lower(macaddr)
    scanner = Scanner().withDelegate( SwitchbotScanDelegate(macaddr) )
    #スキャン(timeout9s)
    scanner.scan( 9.0 )
    temp=0
    #出力
    try:
        temp = str(scanner.delegate.sensorValue['Temperature'])
    except TypeError as e:
        print("Temporarily lost communication with Bluetooth temperature device.",e) 
    except:
        import traceback
        traceback.print_exc()
    
    return  temp
 
if __name__ == '__main__':
    while True:
        print("temp is  : ", send_temp_data('FE:EA:12:3D:E8:00'))
        
        json_body = [
            {
                "measurement": "temp_measurement",
                "time": datetime.utcnow(),
                "fields": {
                    ## ★XX:XX:XX:XX:XX:XXにはswitchbotのmacアドレスを入れてください
                    "temp": float(send_temp_data('XX:XX:XX:XX:XX:XX')),
                }
            }
        ]
        dbclient.write_points(json_body)
        time.sleep(10)

$ sudo python3 switchbot.py

## 実行結果
temp is  :  22.9

# データベースに接続
dbclient = InfluxDBClient(host='localhost', port=8086, database='tempDB')

$ sudo apt install -y apt-transport-https
$ sudo apt install -y software-properties-common wget
$ wget -q -O - https://packages.grafana.com/gpg.key | sudo apt-key add -
$ echo "deb https://packages.grafana.com/oss/deb stable main" | sudo tee -a /etc/apt/sources.list.d/grafana.list
$ sudo apt update
$ sudo apt install grafana
$ sudo systemctl daemon-reload
$ sudo systemctl start grafana-server

$ sudo ufw status | grep 3000

3000/tcp                   ALLOW       Anywhere                  
3000/tcp (v6)              ALLOW       Anywhere (v6)

$ sudo ufw allow 3000/tcp