BLEデバイスとラズパイで温湿度を計測する話

#define DEBUG_MODE

#include <Wire.h>
// https://github.com/nkolban/ESP32_BLE_Arduino
#include <BLEDevice.h>
#include <BLEServer.h>

#include <esp_sleep.h>
// https://github.com/ks-tec/BME280_I2C 
#include <BME280_I2C.h>

#define SERIAL_BAUD_RATE  115200
#define BME280_I2C_SCL    22
#define BME280_I2C_SDA    21
// BME280_ADDRESS is already defined as 0x76 in BME280_I2C.h 
// 22 and 21 is GPIO number on target board.
// Create BME280 object
BME280_I2C BME280; 

#define DEVICE_NAME "ESP32_BLE"         // device name
#define DEVICE_NUMBER 1                 // server device idetify number（1～8）
// See the following for generating UUIDs:
// https://www.uuidgenerator.net/
#define SERVICE_UUID        "4800d65f-5ff8-4714-a945-ed9d30f02ab7"
#define CHARACTERISTIC_UUID "7e7c1652-4546-4226-ab01-3c706bd4e25d"

RTC_DATA_ATTR static uint8_t SEQ_NUM; // sequence number on RTC memory
const int SLEEP_TIME = 600;            // sleep time (second)
const int ADVERTISING_TIME = 300;       // advertising time (mili second)

void readBME280_setAdvertisementData(BLEAdvertising* pAdvertising)
{
  // set sea-level pressure
  BME280.setSeaLevelPressure(1010);
  // read values from BME280 and store calibrated values in the library
  // and the calibrated values is storeed to BME280.data in the library.
  // the stored data is temperature, atmospheric pressure, humidity and altitude.
  BME280.read();
  
  #ifdef DEBUG_MODE
  // format the stored values
    char weather_value[64];
    const char *comma = ",";
    char temp_c[12], humi_c[12], pres_c[12], altd_c[12];
    sprintf(temp_c, "%2.2lf", BME280.data.temperature);
    sprintf(humi_c, "%2.2lf", BME280.data.humidity);
    sprintf(pres_c, "%4.2lf", BME280.data.pressure);
    //sprintf(altd_c, "%4.2lf", BME280.data.altitude);
    sprintf(weather_value,"%s%s%s%s%s", temp_c, comma, humi_c, comma, pres_c); 
    Serial.println(weather_value);
  #endif
  double t = BME280.data.temperature;
  double h = BME280.data.humidity;
  double p = BME280.data.pressure;
  uint16_t temp = (uint16_t)(t * 100);  // need to divide with 100 at the client receiving this data
  uint16_t humi = (uint16_t)(h * 100);  // need to divide with 100 at the client receiving this data
  uint16_t pres = (uint16_t)(p * 50);  // need to divide with 50 at the client receiving this data
  
  // Make the send data for putting in the Advertising object.
    std::string strData = "";
    strData += (char)0xff;                      // Manufacturer specific data
    strData += (char)0xff;                      // manufacturer ID low byte
    strData += (char)0xff;                      // manufacturer ID high byte
    strData += (char)DEVICE_NUMBER;             // server divice identfy number 
    strData += (char)0x55;                      // dummy status data 
    strData += (char)SEQ_NUM;                   // sequence number  
    strData += (char)(temp & 0xff);           // Low byte of temperature data
    strData += (char)((temp >> 8) & 0xff);    // High byte of temperature data
    strData += (char)(humi & 0xff);           // High byte of humidity data
    strData += (char)((humi >> 8) & 0xff);    // High byte of humidity data
    strData += (char)(pres & 0xff);           // Low byte of pressure data
    strData += (char)((pres >> 8) & 0xff);    // High byte of pressure data
    strData += (char)0x34;                      // Low byte of dummy data
    strData += (char)0x12;                      // High byte of dummy data 
    strData = (char)strData.length() + strData; // Length of strData  

    // Set the device name, flags, and send data in the Advertising objedt
    BLEAdvertisementData AdvertisementData = BLEAdvertisementData();
    AdvertisementData.setName(DEVICE_NAME);
    AdvertisementData.setFlags(0x06);         
    AdvertisementData.addData(strData);
    pAdvertising->setAdvertisementData(AdvertisementData);
}


void setup() {
  // put your setup code here, to run once:
  Wire.begin();
  #ifdef DEBUG_MODE
    Serial.begin(SERIAL_BAUD_RATE);
    Serial.println("Bosch BME280 Temp,Humidity,Pressure Sensor");
  #endif
  
  // set address and connected pins
  BME280.setAddress(BME280_ADDRESS, BME280_I2C_SDA, BME280_I2C_SCL);

  // initialize BME280
  // each parameter uses the enum values ​​defined in the header file.
  // typically, SPI mode uses BME280_SPI3_DISABLE because it is for I2C.
  bool isStatus = BME280.begin(
      BME280.BME280_STANDBY_0_5,
      BME280.BME280_FILTER_16,
      BME280.BME280_SPI3_DISABLE,
      BME280.BME280_OVERSAMPLING_2,
      BME280.BME280_OVERSAMPLING_16,
      BME280.BME280_OVERSAMPLING_1,
      BME280.BME280_MODE_NORMAL);

  if (!isStatus)
  {
    #ifdef DEBUG_MODE
    Serial.println("can NOT initialize for using BME280.\n");
    #endif
  }
  else
  {
    #ifdef DEBUG_MODE
    Serial.println("ready to using BME280.\n");
    #endif
  }

  
  // initialize BLD device
  BLEDevice::init(DEVICE_NAME); 

  // BLEサーバーを作成してアドバタイズオブジェクトを取得する
  BLEServer *pServer = BLEDevice::createServer();
  BLEAdvertising *pAdvertising = pServer->getAdvertising();
  // 送信情報を設定してシーケンス番号をインクリメントする
  readBME280_setAdvertisementData(pAdvertising);
  SEQ_NUM++;

  // Advertising
  pAdvertising->start();
  #ifdef DEBUG_MODE
    Serial.println("Advertising!!!");
  #endif
  delay(ADVERTISING_TIME);
  pAdvertising->stop();

  #ifdef DEBUG_MODE
    Serial.println("Deep sleep mode!");
  #endif
  esp_deep_sleep(SLEEP_TIME * 1000000LL);
}

void loop() {
  // put your main code here, to run repeatedly:

}

from asyncio import exceptions
import json
from bluepy.btle import Scanner, DefaultDelegate, BTLEException
import ambient
import time
from httplib2 import Credentials
import requests

import json
import datetime
import gspread
from oauth2client.service_account import ServiceAccountCredentials

# key for using google service
SCOPE = ['https://spreadsheets.google.com/feeds','https://www.googleapis.com/auth/drive']
KEY_NAME = 'Google Cloud Platformの自身のプロジェクト上で作った秘密鍵ファイル（JSON等）へのパスを記述する'
SPREADSHEET_KEY = '温湿度データを追加書き込みする対象のGoogle spread sheetへのアクセスキーを記述する'

# key for seraching target name of  my devices
# アドバタイジングパケットの中で自身で定義したデータを記述（スキャンしてリスト化されたBLEデバイスの中から自分のBLEデバイスを見つけるための情報
target_device = {
    'ESP32_BLE':{'companyID':'ffff'}
    }
target = 'ESP32_BLE'
# key for using Ambient service
youserKey = "Ambientへのアクセスキーを記述する"
channelId = "チャンネルIDを記述する"
writeKey = "ライトアクセス用のキーを記述する"
using_ambient = True
Debugging = False
timeout = 12.0

class ScanDelegate(DefaultDelegate):
    def __init__(self):
        DefaultDelegate.__init__(self)

    def handleDiscovery(self, dev, isNewDev, isNewData):
        if Debugging :
            if isNewDev:
                print("Discovered device", dev.addr)
            elif isNewData:
                print("Received new data from", dev.addr)


def main():
    # Create contral google spread sheet
    _credentials = ServiceAccountCredentials.from_json_keyfile_name(KEY_NAME, SCOPE)
    _gcontrol = gspread.authorize(_credentials)
    worksheet = _gcontrol.open_by_key(SPREADSHEET_KEY).sheet1
    
    # Create instance for scan class of BLE device
    scanner = Scanner().withDelegate(ScanDelegate())
    # Create instance for Ambient service class 
    if using_ambient:
        amb = ambient.Ambient(channelId, writeKey)

    # Repeat BLE device scan and data transmission until key interrupt is entered.
    while True:
        global d1, d2, d3, d4, d5, d6, d7, d8,targetFlg
        targetFlg  = False
        try:
            devices = scanner.scan(timeout, passive=True)
            for device in devices:
                if Debugging:
                    print("Device %s (%s), RSSI=%d dB" % (device.addr, device.addrType, device.rssi))
                for (adtype, desc, value) in device.getScanData():
                    if Debugging:
                        print("  %s = %s" % (desc, value))
                    if target  in ('ESP32_BLE'):
                        if desc == 'Manufacturer' and value[0:4] == target_device[target]['companyID']:
                            deviceID =value[4:6]
                            status = value[6:8]
                            number = value[8:10]
                            temp =  value[12:14] + value[10:12]
                            humid = value[16:18] + value[14:16]
                            press = value[20:22] + value[18:20]
                            dummy = value[24:26] + value[22:24]
                            # Convert an unprefixed hexadecimal string to Int
                            int_number = int(number, 16)
                            float_temp = int(temp, 16) / 100.00
                            float_humid = int(humid, 16) / 100.00
                            float_press = int(press, 16) / 50.0
                            float_dummy = int(dummy, 16) / 100.00

                            targetFlg = True

                            print(deviceID, ',', status, ',', int_number, ',', float_temp, ',',
                                    float_humid, ',', float_press, ',', float_dummy, sep='')
                            today = datetime.datetime.now()
                            record = [today.strftime('%Y/%m/%d %H:%M'),deviceID, float_temp, float_humid, float_press]
                            worksheet.append_row(record)

                            if deviceID == "01":
                                d1 = float_temp
                                d2 = float_humid
                                d3 = float_press
                                d4 = float_dummy
                            elif deviceID == "02":
                                d5 = float_temp
                                d6 = float_humid
                                d7 = float_press
                                d8 = float_dummy
                            else:
                                print("devicID failed")        
            try:
                # Data from two devices are sent together.
                # d1-d2:for deviceID="01", d5-d8:for deviceID="02" 
                if targetFlg and using_ambient:
                    rtn = amb.send({'d1':d1, 'd2':d2, 'd3':d3, 'd4':d4,
                                    'd5':d5, 'd6':d6, 'd7':d7, 'd8':d8})
                    if Debugging :
                        print('sent data to Ambient (rtn = %d )' % rtn.status_code)
                    rtn.close
            except requests.exceptions.requests.RequestException as e:
                print('request failed', e)

        except BTLEException:
            print("BTLE Exception")

      
        time.sleep(0.1)

if __name__ == "__main__":
    main()