ブログ - 栄商会

2021年4月6日2021年4月4日

エーゼットにはまるその2

先日アクアシャインコートを購入しましたが、エーゼットの本業はオイル。ホームページ上には極圧添加剤が華々しく出ています。これまで知り合いのスズキ機工のベルハンマーシリーズを使用していたので、比較購入です。

左から、超極圧添加剤原液、超極圧スプレーオイル、超極圧浸透スプレー、超極圧グリスの4点です。

超極圧添加剤原液は主にクルマないしは乾式クラッチを持つバイクのオイルにドーピング予定です。スプレーオイルは主にチェーンやベアリング。浸透スプレーは錆などで動きが渋くナット部分に、グリスは、バイクのフロント、リアのホイールベアリングの給脂などに使用していく予定です。当面は売り物セローの整備に使用していく予定です。

ちょこっと自転車にスプレーしてみましたが、グーです。

2021年4月5日2021年4月4日

エーゼットにはまる

燃料添加剤FCR－062以来、エーゼットのホームページを見て、琴線に触れる商品を見つけたので購入し、既存他社製品との比較をしてみたいと思います。

まずはガラスコーティング剤です。アクアシャインコートです。定価1,320円ですが、Amazonでアクアシャインカーシャンプーとセットで1,320円https://www.amazon.co.jp/gp/product/B01GT83H8I/ref=ppx_yo_dt_b_asin_title_o00_s00?ie=UTF8&psc=1と、速攻でポチりました。コート剤はこれまでワコーズのバリアスコートを使っていたのですが、特に利きに不満がなかったのですが、値段が圧倒的に安いため比較購入しました。

取りあえず普段汚れっぱなしの軽トラで施工してみました。まずはアクアシャインカーシャンプーの蓋を開け、蓋が計量カップ代わりになっていますので、すりきり一杯約20mlをバケツに入れ水は標準4Lですが濃いめの1Lで泡立てて使用しました。スポンジで泡立てていつものように洗車しましたが、ピッチなどはあっという間にきれいに取れます。その後セローも洗いましたが、油汚れも結構きれいになりました。水分を拭き取り後、渇いた状態で、アクアシャインコートを噴霧、と頑張ってもスプレーヘッドのレバーが動きません。良ーく見てみるとセンターのシャフトにロックパーツが。これを回してロックを解除して、噴霧再開です。ガラスでもモール類でも何でもコートできるので、噴霧し付属のマイクロファイバーで拭き取るだけとの簡単施工です。水分残っててもオッケーですのであっという間でした。ガラスコートが確実に馴染むまで約一日かかるそうなので、効果の確認は後日です。ザラザラした軽トラお表面がサラサラになってしまいました。ネットではガラスコートの他にもエーゼットのシリコンオイルを塗りたくるのも流行っていますが、シリコンはまた後日です。

また、他にもブツを購入しましたが、紹介はまた別途。

2021年4月4日2021年4月4日

エーゼット　燃料添加剤を入れる　その３

売り物セロー250にエーゼット燃料添加剤FCR-062を添加後の現時点での経過です。2月20日に満タン時にFCR-062を所定量入れ、やっと燃料タンク１回分（約200キロ、途中でバッテリーの充電のため外してしまったので、距離はだいたいです）走行したのちのエンジン内部の様子です。

まずは添加後50kmでのエンジン内部の状態です。

次いで燃料タンク１本分使用後のエンジン内部の状態です。

200km程度ではカーボンはすべて除去できませんが、ピストンのヘリの部分のカーボンが徐々に減っていることが確認されます。

200kmでこのくらいですから、1000kmくらいは添加し続ける必要があるかもしれません。とりあえず綺麗になるまで続けてみます。（ただし、資金繰りのため、早々に売りきってしまうかもしれませんが・・・）

2021年3月28日2021年3月30日

伊豆松崎大沢温泉の桜

最近、忙しくブログの更新もまったくしてませんでした。関東一都三県の緊急事態宣言も解除されましたが、なるべく近くで気分転換しようということで、南伊豆にある松崎町、大沢温泉の染井吉野を見に行ってきました。「道の駅」花の三聖苑伊豆松崎にクルマを止め、那珂川添いの桜並木を散策しました。パワースポットの山神社のわきを通り那珂川を渡る赤い欄干の橋の上から素晴らし桜並木が見渡せます。

川添いを上流に向かって散策し、もう1本の橋を過ぎると旧依田邸と大沢温泉ホテルが見えてきます。大沢温泉は鄙びた湯治場ですが、2年ぶりに訪問しましたら大沢温泉ホテルが新しく「大沢温泉　依田之庄」という日帰り温泉的に施設に変わっていました。調べてみたところ昨年の末の令和２年12月27日に新たにオープンしたそうです。詳しくはhttp://www.izu-matsuzaki.com/publics/index/111/をご覧下さい。

旧依田邸の前から河川敷に降りてみました。川の水のきれいで透き通っています。お弁当持ってきて、ここで食べれば最高だったですが、後悔です。ここからの桜も最高です。

駐車場に戻って。昼食をということで、走り出しましたが、結構クルマも多く出ていたので、南伊豆町のティハールhttp://www.tihal.com/まで行ってみました。松崎から岩地までは細くて急カーブの道が続きますが、だいぶ改良工事が進み以前のように対向車がくると待ってないといけないということも少なくなりました。だいぶ南伊豆方面からツーリング中のバイクも続々とやってきます。波勝崎改め波勝崎モンキーベイを過ぎ、少々走るとティハールに到着です。

なんかテラス席も人がいないので、休み中と思いきや、コロナ対策で食事はテイクアウトのみということになっていました。しかしながらテラス席で食べても良いよと言うことでいつものネパールカレーのククラ（鶏肉）ワイフはブル（玉子）とコーヒーチーズケーキ、チョコチーズケーキを注文しました。

食後は渋滞を避けるため、宇久須より仁科峠に抜け、西伊豆スカイラインから戸田峠、大仁を回って無事帰ってきました。大分ツーリングのバイクも多かったですが、皆さん事故らなければ良いがと一寸思うような方もいました。

2021年3月4日2021年3月3日

ESP32　BME680で測定したデータをMariaDBにとばす　その２

先日BME680のデータをMariaDBに飛ばしましたが、スタンドアロンで自動測定できるようにプログラムを更新しました。また、Wi-Fiに接続している際にＬＥＤを点灯させることとしました。ピン４番にプルアップ抵抗を介してＬＥＤを接続します。

以下がプログラムです。ブートした際に自動的に走らせるために、プログラム名はmain.pyにしてあります。

from machine import Pin,SoftI2C
from bme680 import *
import ntptime
import utime
import ujson
import urequests

UTC_OFFSET=9
p21 = Pin(21, Pin.IN, Pin.PULL_UP)
p23 = Pin(23, Pin.IN, Pin.PULL_UP)
led = Pin(4, Pin.OUT)
i2c = SoftI2C(scl=Pin(21), sda=Pin(23))

def do_connect():
    import network
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    if not wlan.isconnected():
        print('connecting to network...')
        wlan.connect('essid', 'password')
        while not wlan.isconnected():
            pass
    print('network config:', wlan.ifconfig())
    led.value(1)

     
def get_jst():
    sleep_ms(1000)
    ntptime.settime()
    tm=utime.localtime(utime.mktime(utime.localtime())+UTC_OFFSET*3600)
    jst = str(tm[0])+'/'+str(tm[1])+'/'+str(tm[2])+' '+str(tm[3])+':'+str(tm[4])+':'+str(tm[5])
    return(jst)
     
do_connect()
print(get_jst())

while True:
  try:
    bme = BME680_I2C(i2c=i2c) 
    temp = str(round(bme.temperature, 2))
    hum = str(round(bme.humidity, 2))
    pres = str(round(bme.pressure, 2))
    gas = str(round(bme.gas/1000, 2))

    dict = {
            "temp_value":temp,
            "hum_value":hum,
            "pres_value":pres,
            "gas_value":gas
            }
    response = urequests.post(
            'https://***url***/datarcv.php',
            data=ujson.dumps(dict).encode("utf-8"),
                headers={'Content-Type': 'application/json'}
            )
    print  (response.text)
  except OSError as e:
    print('Failed to read sensor.')
 
  sleep(10)

from machine import Pin,SoftI2C

from bme680 import *

import ntptime

import utime

import ujson

import urequests

UTC_OFFSET=9

p21 = Pin(21, Pin.IN, Pin.PULL_UP)

p23 = Pin(23, Pin.IN, Pin.PULL_UP)

led = Pin(4, Pin.OUT)

i2c = SoftI2C(scl=Pin(21), sda=Pin(23))

def do_connect():

import network

wlan = network.WLAN(network.STA_IF)

wlan.active(True)

if not wlan.isconnected():

print('connecting to network...')

wlan.connect('essid', 'password')

while not wlan.isconnected():

pass

print('network config:', wlan.ifconfig())

led.value(1)

def get_jst():

sleep_ms(1000)

ntptime.settime()

tm=utime.localtime(utime.mktime(utime.localtime())+UTC_OFFSET*3600)

jst = str(tm[0])+'/'+str(tm[1])+'/'+str(tm[2])+' '+str(tm[3])+':'+str(tm[4])+':'+str(tm[5])

return(jst)

do_connect()

print(get_jst())

while True:

try:

bme = BME680_I2C(i2c=i2c)

temp = str(round(bme.temperature, 2))

hum = str(round(bme.humidity, 2))

pres = str(round(bme.pressure, 2))

gas = str(round(bme.gas/1000, 2))

dict = {

"temp_value":temp,

"hum_value":hum,

"pres_value":pres,

"gas_value":gas

}

response = urequests.post(

'https://***url***/datarcv.php',

data=ujson.dumps(dict).encode("utf-8"),

headers={'Content-Type': 'application/json'}

)

print (response.text)

except OSError as e:

print('Failed to read sensor.')

sleep(10)

この通りWi-Fiに接続するとＬＥＤがともります。phpMyAdminで確認すると10秒おきにデータが蓄積していきます。

2021年3月3日

ESP32 複合センサBME680で測定したデータをMariaDBにとばす

先日仕入れたBME680を用いて温度、湿度、気圧、ガス濃度を測定してMariaDBに飛ばして記録したいと思います。今回のプログラムです。先にWi-Fiにつないでからrunさせます。

import ujson
import urequests

from machine import Pin,I2C
from time import sleep
from bme680 import *
p21 = Pin(21, Pin.IN, Pin.PULL_UP)
p23 = Pin(23, Pin.IN, Pin.PULL_UP)

i2c = I2C(scl=Pin(21), sda=Pin(23))

while True:
  try:
    bme = BME680_I2C(i2c=i2c) 
    temp = str(round(bme.temperature, 2))
    hum = str(round(bme.humidity, 2))
    pres = str(round(bme.pressure, 2))
    gas = str(round(bme.gas/1000, 2))

    print('Temperature:', temp)
    print('Humidity:', hum)
    print('Pressure:', pres)
    print('Gas:', gas)

    dict = {
            "temp_value":temp,
            "hum_value":hum,
            "pres_value":pres,
            "gas_value":gas
            }
    response = urequests.post(
            'https://***url***/postrcv.php',
            data=ujson.dumps(dict).encode("utf-8"),
                headers={'Content-Type': 'application/json'}
            )
    print  (response.text)
  except OSError as e:
    print('Failed to read sensor.')
 
  sleep(10)

import ujson

import urequests

from machine import Pin,I2C

from time import sleep

from bme680 import *

p21 = Pin(21, Pin.IN, Pin.PULL_UP)

p23 = Pin(23, Pin.IN, Pin.PULL_UP)

i2c = I2C(scl=Pin(21), sda=Pin(23))

while True:

try:

bme = BME680_I2C(i2c=i2c)

temp = str(round(bme.temperature, 2))

hum = str(round(bme.humidity, 2))

pres = str(round(bme.pressure, 2))

gas = str(round(bme.gas/1000, 2))

print('Temperature:', temp)

print('Humidity:', hum)

print('Pressure:', pres)

print('Gas:', gas)

dict = {

"temp_value":temp,

"hum_value":hum,

"pres_value":pres,

"gas_value":gas

}

response = urequests.post(

'https://***url***/postrcv.php',

data=ujson.dumps(dict).encode("utf-8"),

headers={'Content-Type': 'application/json'}

)

print (response.text)

except OSError as e:

print('Failed to read sensor.')

sleep(10)

実行結果です。

C:\Users\>ampy -p com3 run c:\micropython\posttest8.py
Warning: I2C(-1, ...) is deprecated, use SoftI2C(...) instead
Temperature: 17.36
Humidity: 54.01
Pressure: 1019.21
Gas: 56.24
"temp=17.36 , hum=54.01 , pres=1019.21, gas=56.24"New record created successfully
Temperature: 17.35
Humidity: 54.14
Pressure: 1019.22
Gas: 54.43
"temp=17.35 , hum=54.14 , pres=1019.22, gas=54.43"New record created successfully
Temperature: 17.41
Humidity: 54.15
Pressure: 1019.24
Gas: 53.23
"temp=17.41 , hum=54.15 , pres=1019.24, gas=53.23"New record created successfully
Temperature: 17.48
Humidity: 54.03
Pressure: 1019.2
Gas: 52.34
"temp=17.48 , hum=54.03 , pres=1019.2, gas=52.34"New record created successfully

Aborted!

しっかりと10秒おきにDBに記録されています。

次回はプログラムを見直し、単独で自動運転できるようにします。

2021年3月1日2021年3月1日

ESP32 複合センサBME680

先日お知らせしたBME680による温湿度気圧、ガス濃度の分析です。

今回は秋月電子のセンサを用いていますが、同じようにAdafruitでも同様のセンサキットを用意しており、GithubにてMicroPython用に用意されているAdafruithttps://github.com/robert-hh/BME680-Micropythonのモジュールを用います。

まずはモジュールです。

# The MIT License (MIT)
#
# Copyright (c) 2017 ladyada for Adafruit Industries
#
# Permission is hereby granted, free of charge, to any person obtaining a copy
# of this software and associated documentation files (the "Software"), to deal
# in the Software without restriction, including without limitation the rights
# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
# copies of the Software, and to permit persons to whom the Software is
# furnished to do so, subject to the following conditions:
#
# The above copyright notice and this permission notice shall be included in
# all copies or substantial portions of the Software.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
# THE SOFTWARE.

# We have a lot of attributes for this complex sensor.
# pylint: disable=too-many-instance-attributes

"""
`bme680` - BME680 - Temperature, Humidity, Pressure & Gas Sensor
================================================================

MicroPython driver from BME680 air quality sensor, based on Adafruit_bme680

* Author(s): Limor 'Ladyada' Fried of Adafruit
             Jeff Raber (SPI support)
             and many more contributors
"""

import time
import math
from micropython import const
from ubinascii import hexlify as hex
try:
    import struct
except ImportError:
    import ustruct as struct

#    I2C ADDRESS/BITS/SETTINGS
#    -----------------------------------------------------------------------
_BME680_CHIPID = const(0x61)

_BME680_REG_CHIPID = const(0xD0)
_BME680_BME680_COEFF_ADDR1 = const(0x89)
_BME680_BME680_COEFF_ADDR2 = const(0xE1)
_BME680_BME680_RES_HEAT_0 = const(0x5A)
_BME680_BME680_GAS_WAIT_0 = const(0x64)

_BME680_REG_SOFTRESET = const(0xE0)
_BME680_REG_CTRL_GAS = const(0x71)
_BME680_REG_CTRL_HUM = const(0x72)
_BME280_REG_STATUS = const(0xF3)
_BME680_REG_CTRL_MEAS = const(0x74)
_BME680_REG_CONFIG = const(0x75)

_BME680_REG_PAGE_SELECT = const(0x73)
_BME680_REG_MEAS_STATUS = const(0x1D)
_BME680_REG_PDATA = const(0x1F)
_BME680_REG_TDATA = const(0x22)
_BME680_REG_HDATA = const(0x25)

_BME680_SAMPLERATES = (0, 1, 2, 4, 8, 16)
_BME680_FILTERSIZES = (0, 1, 3, 7, 15, 31, 63, 127)

_BME680_RUNGAS = const(0x10)

_LOOKUP_TABLE_1 = (2147483647.0, 2147483647.0, 2147483647.0, 2147483647.0, 2147483647.0,
                   2126008810.0, 2147483647.0, 2130303777.0, 2147483647.0, 2147483647.0,
                   2143188679.0, 2136746228.0, 2147483647.0, 2126008810.0, 2147483647.0,
                   2147483647.0)

_LOOKUP_TABLE_2 = (4096000000.0, 2048000000.0, 1024000000.0, 512000000.0, 255744255.0, 127110228.0,
                   64000000.0, 32258064.0, 16016016.0, 8000000.0, 4000000.0, 2000000.0, 1000000.0,
                   500000.0, 250000.0, 125000.0)


def _read24(arr):
    """Parse an unsigned 24-bit value as a floating point and return it."""
    ret = 0.0
    #print([hex(i) for i in arr])
    for b in arr:
        ret *= 256.0
        ret += float(b & 0xFF)
    return ret


class Adafruit_BME680:
    """Driver from BME680 air quality sensor

       :param int refresh_rate: Maximum number of readings per second. Faster property reads
         will be from the previous reading."""
    def __init__(self, *, refresh_rate=10):
        """Check the BME680 was found, read the coefficients and enable the sensor for continuous
           reads."""
        self._write(_BME680_REG_SOFTRESET, [0xB6])
        time.sleep(0.005)

        # Check device ID.
        chip_id = self._read_byte(_BME680_REG_CHIPID)
        if chip_id != _BME680_CHIPID:
            raise RuntimeError('Failed to find BME680! Chip ID 0x%x' % chip_id)

        self._read_calibration()

        # set up heater
        self._write(_BME680_BME680_RES_HEAT_0, [0x73])
        self._write(_BME680_BME680_GAS_WAIT_0, [0x65])

        self.sea_level_pressure = 1013.25
        """Pressure in hectoPascals at sea level. Used to calibrate ``altitude``."""

        # Default oversampling and filter register values.
        self._pressure_oversample = 0b011
        self._temp_oversample = 0b100
        self._humidity_oversample = 0b010
        self._filter = 0b010

        self._adc_pres = None
        self._adc_temp = None
        self._adc_hum = None
        self._adc_gas = None
        self._gas_range = None
        self._t_fine = None

        self._last_reading = 0
        self._min_refresh_time = 1000 / refresh_rate

    @property
    def pressure_oversample(self):
        """The oversampling for pressure sensor"""
        return _BME680_SAMPLERATES[self._pressure_oversample]

    @pressure_oversample.setter
    def pressure_oversample(self, sample_rate):
        if sample_rate in _BME680_SAMPLERATES:
            self._pressure_oversample = _BME680_SAMPLERATES.index(sample_rate)
        else:
            raise RuntimeError("Invalid oversample")

    @property
    def humidity_oversample(self):
        """The oversampling for humidity sensor"""
        return _BME680_SAMPLERATES[self._humidity_oversample]

    @humidity_oversample.setter
    def humidity_oversample(self, sample_rate):
        if sample_rate in _BME680_SAMPLERATES:
            self._humidity_oversample = _BME680_SAMPLERATES.index(sample_rate)
        else:
            raise RuntimeError("Invalid oversample")

    @property
    def temperature_oversample(self):
        """The oversampling for temperature sensor"""
        return _BME680_SAMPLERATES[self._temp_oversample]

    @temperature_oversample.setter
    def temperature_oversample(self, sample_rate):
        if sample_rate in _BME680_SAMPLERATES:
            self._temp_oversample = _BME680_SAMPLERATES.index(sample_rate)
        else:
            raise RuntimeError("Invalid oversample")

    @property
    def filter_size(self):
        """The filter size for the built in IIR filter"""
        return _BME680_FILTERSIZES[self._filter]

    @filter_size.setter
    def filter_size(self, size):
        if size in _BME680_FILTERSIZES:
            self._filter = _BME680_FILTERSIZES[size]
        else:
            raise RuntimeError("Invalid size")

    @property
    def temperature(self):
        """The compensated temperature in degrees celsius."""
        self._perform_reading()
        calc_temp = (((self._t_fine * 5) + 128) / 256)
        return calc_temp / 100

    @property
    def pressure(self):
        """The barometric pressure in hectoPascals"""
        self._perform_reading()
        var1 = (self._t_fine / 2) - 64000
        var2 = ((var1 / 4) * (var1 / 4)) / 2048
        var2 = (var2 * self._pressure_calibration[5]) / 4
        var2 = var2 + (var1 * self._pressure_calibration[4] * 2)
        var2 = (var2 / 4) + (self._pressure_calibration[3] * 65536)
        var1 = (((((var1 / 4) * (var1 / 4)) / 8192) *
                (self._pressure_calibration[2] * 32) / 8) +
                ((self._pressure_calibration[1] * var1) / 2))
        var1 = var1 / 262144
        var1 = ((32768 + var1) * self._pressure_calibration[0]) / 32768
        calc_pres = 1048576 - self._adc_pres
        calc_pres = (calc_pres - (var2 / 4096)) * 3125
        calc_pres = (calc_pres / var1) * 2
        var1 = (self._pressure_calibration[8] * (((calc_pres / 8) * (calc_pres / 8)) / 8192)) / 4096
        var2 = ((calc_pres / 4) * self._pressure_calibration[7]) / 8192
        var3 = (((calc_pres / 256) ** 3) * self._pressure_calibration[9]) / 131072
        calc_pres += ((var1 + var2 + var3 + (self._pressure_calibration[6] * 128)) / 16)
        return calc_pres/100

    @property
    def humidity(self):
        """The relative humidity in RH %"""
        self._perform_reading()
        temp_scaled = ((self._t_fine * 5) + 128) / 256
        var1 = ((self._adc_hum - (self._humidity_calibration[0] * 16)) -
                ((temp_scaled * self._humidity_calibration[2]) / 200))
        var2 = (self._humidity_calibration[1] *
                (((temp_scaled * self._humidity_calibration[3]) / 100) +
                 (((temp_scaled * ((temp_scaled * self._humidity_calibration[4]) / 100)) /
                   64) / 100) + 16384)) / 1024
        var3 = var1 * var2
        var4 = self._humidity_calibration[5] * 128
        var4 = (var4 + ((temp_scaled * self._humidity_calibration[6]) / 100)) / 16
        var5 = ((var3 / 16384) * (var3 / 16384)) / 1024
        var6 = (var4 * var5) / 2
        calc_hum = (((var3 + var6) / 1024) * 1000) / 4096
        calc_hum /= 1000  # get back to RH

        if calc_hum > 100:
            calc_hum = 100
        if calc_hum < 0:
            calc_hum = 0
        return calc_hum

    @property
    def altitude(self):
        """The altitude based on current ``pressure`` vs the sea level pressure
           (``sea_level_pressure``) - which you must enter ahead of time)"""
        pressure = self.pressure # in Si units for hPascal
        return 44330 * (1.0 - math.pow(pressure / self.sea_level_pressure, 0.1903))

    @property
    def gas(self):
        """The gas resistance in ohms"""
        self._perform_reading()
        var1 = ((1340 + (5 * self._sw_err)) * (_LOOKUP_TABLE_1[self._gas_range])) / 65536
        var2 = ((self._adc_gas * 32768) - 16777216) + var1
        var3 = (_LOOKUP_TABLE_2[self._gas_range] * var1) / 512
        calc_gas_res = (var3 + (var2 / 2)) / var2
        return int(calc_gas_res)

    def _perform_reading(self):
        """Perform a single-shot reading from the sensor and fill internal data structure for
           calculations"""
        if (time.ticks_diff(self._last_reading, time.ticks_ms()) * time.ticks_diff(0, 1)
                < self._min_refresh_time):
            return

        # set filter
        self._write(_BME680_REG_CONFIG, [self._filter << 2])
        # turn on temp oversample & pressure oversample
        self._write(_BME680_REG_CTRL_MEAS,
                    [(self._temp_oversample << 5)|(self._pressure_oversample << 2)])
        # turn on humidity oversample
        self._write(_BME680_REG_CTRL_HUM, [self._humidity_oversample])
        # gas measurements enabled
        self._write(_BME680_REG_CTRL_GAS, [_BME680_RUNGAS])

        ctrl = self._read_byte(_BME680_REG_CTRL_MEAS)
        ctrl = (ctrl & 0xFC) | 0x01  # enable single shot!
        self._write(_BME680_REG_CTRL_MEAS, [ctrl])
        new_data = False
        while not new_data:
            data = self._read(_BME680_REG_MEAS_STATUS, 15)
            new_data = data[0] & 0x80 != 0
            time.sleep(0.005)
        self._last_reading = time.ticks_ms()

        self._adc_pres = _read24(data[2:5]) / 16
        self._adc_temp = _read24(data[5:8]) / 16
        self._adc_hum = struct.unpack('>H', bytes(data[8:10]))[0]
        self._adc_gas = int(struct.unpack('>H', bytes(data[13:15]))[0] / 64)
        self._gas_range = data[14] & 0x0F

        var1 = (self._adc_temp / 8) - (self._temp_calibration[0] * 2)
        var2 = (var1 * self._temp_calibration[1]) / 2048
        var3 = ((var1 / 2) * (var1 / 2)) / 4096
        var3 = (var3 * self._temp_calibration[2] * 16) / 16384

        self._t_fine = int(var2 + var3)

    def _read_calibration(self):
        """Read & save the calibration coefficients"""
        coeff = self._read(_BME680_BME680_COEFF_ADDR1, 25)
        coeff += self._read(_BME680_BME680_COEFF_ADDR2, 16)

        coeff = list(struct.unpack('<hbBHhbBhhbbHhhBBBHbbbBbHhbb', bytes(coeff[1:39])))
        # print("\n\n",coeff)
        coeff = [float(i) for i in coeff]
        self._temp_calibration = [coeff[x] for x in [23, 0, 1]]
        self._pressure_calibration = [coeff[x] for x in [3, 4, 5, 7, 8, 10, 9, 12, 13, 14]]
        self._humidity_calibration = [coeff[x] for x in [17, 16, 18, 19, 20, 21, 22]]
        self._gas_calibration = [coeff[x] for x in [25, 24, 26]]

        # flip around H1 & H2
        self._humidity_calibration[1] *= 16
        self._humidity_calibration[1] += self._humidity_calibration[0] % 16
        self._humidity_calibration[0] /= 16

        self._heat_range = (self._read_byte(0x02) & 0x30) / 16
        self._heat_val = self._read_byte(0x00)
        self._sw_err = (self._read_byte(0x04) & 0xF0) / 16

    def _read_byte(self, register):
        """Read a byte register value and return it"""
        return self._read(register, 1)[0]

    def _read(self, register, length):
        raise NotImplementedError()

    def _write(self, register, values):
        raise NotImplementedError()

class BME680_I2C(Adafruit_BME680):
    """Driver for I2C connected BME680.

        :param i2c: I2C device object
        :param int address: I2C device address
        :param bool debug: Print debug statements when True.
        :param int refresh_rate: Maximum number of readings per second. Faster property reads
          will be from the previous reading."""
    def __init__(self, i2c, address=0x77, debug=False, *, refresh_rate=10):
        """Initialize the I2C device at the 'address' given"""
        self._i2c = i2c
        self._address = address
        self._debug = debug
        super().__init__(refresh_rate=refresh_rate)

    def _read(self, register, length):
        """Returns an array of 'length' bytes from the 'register'"""
        result = bytearray(length)
        self._i2c.readfrom_mem_into(self._address, register & 0xff, result)
        if self._debug:
            print("\t${:x} read ".format(register), " ".join(["{:02x}".format(i) for i in result]))
        return result

    def _write(self, register, values):
        """Writes an array of 'length' bytes to the 'register'"""
        if self._debug:
            print("\t${:x} write".format(register), " ".join(["{:02x}".format(i) for i in values]))
        for value in values:
            self._i2c.writeto_mem(self._address, register, bytearray([value & 0xFF]))
            register += 1


class BME680_SPI(Adafruit_BME680):
    """Driver for SPI connected BME680.

        :param spi: SPI device object, configured
        :param cs: Chip Select Pin object, configured to OUT mode
        :param bool debug: Print debug statements when True.
        :param int refresh_rate: Maximum number of readings per second. Faster property reads
          will be from the previous reading.
      """

    def __init__(self, spi, cs, debug=False, *, refresh_rate=10):
        self._spi = spi
        self._cs = cs
        self._debug = debug
        self._cs(1)
        super().__init__(refresh_rate=refresh_rate)

    def _read(self, register, length):
        if register != _BME680_REG_PAGE_SELECT:
            # _BME680_REG_PAGE_SELECT exists in both SPI memory pages
            # For all other registers, we must set the correct memory page
            self._set_spi_mem_page(register)
        register = (register | 0x80) & 0xFF  # Read single, bit 7 high.

        try:
            self._cs(0)
            self._spi.write(bytearray([register]))  # pylint: disable=no-member
            result = bytearray(length)
            self._spi.readinto(result)  # pylint: disable=no-member
            if self._debug:
                print("\t${:x} read ".format(register), " ".join(["{:02x}".format(i) for i in result]))
        except Exception as e:
            print (e)
            result = None
        finally:
            self._cs(1)
        return result

    def _write(self, register, values):
        if register != _BME680_REG_PAGE_SELECT:
            # _BME680_REG_PAGE_SELECT exists in both SPI memory pages
            # For all other registers, we must set the correct memory page
            self._set_spi_mem_page(register)
        register &= 0x7F  # Write, bit 7 low.
        try:
            self._cs(0)
            buffer = bytearray(2 * len(values))
            for i, value in enumerate(values):
                buffer[2 * i] = register + i
                buffer[2 * i + 1] = value & 0xFF
            self._spi.write(buffer)  # pylint: disable=no-member
            if self._debug:
                print("\t${:x} write".format(register), " ".join(["{:02x}".format(i) for i in values]))
        except Exception as e:
            print (e)
        finally:
            self._cs(1)

    def _set_spi_mem_page(self, register):
        spi_mem_page = 0x00
        if register < 0x80:
            spi_mem_page = 0x10
        self._write(_BME680_REG_PAGE_SELECT, [spi_mem_page])

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

374

375

376

377

378

379

380

381

382

383

384

385

386

387

388

389

390

391

392

393

394

395

396

397

398

399

400

401

402

403

404

405

406

407

408

409

410

411

412

413

414

415

416

417

418

419

420

421

# The MIT License (MIT)

# Permission is hereby granted, free of charge, to any person obtaining a copy

# of this software and associated documentation files (the "Software"), to deal

# in the Software without restriction, including without limitation the rights

# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell

# copies of the Software, and to permit persons to whom the Software is

# furnished to do so, subject to the following conditions:

# The above copyright notice and this permission notice shall be included in

# all copies or substantial portions of the Software.

# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN

# THE SOFTWARE.

# We have a lot of attributes for this complex sensor.

# pylint: disable=too-many-instance-attributes

"""

`bme680` - BME680 - Temperature, Humidity, Pressure & Gas Sensor

================================================================

MicroPython driver from BME680 air quality sensor, based on Adafruit_bme680

* Author(s): Limor 'Ladyada' Fried of Adafruit

Jeff Raber (SPI support)

and many more contributors

"""

import time

import math

from micropython import const

from ubinascii import hexlify as hex

try:

import struct

except ImportError:

import ustruct as struct

# I2C ADDRESS/BITS/SETTINGS

# -----------------------------------------------------------------------

_BME680_CHIPID = const(0x61)

_BME680_REG_CHIPID = const(0xD0)

_BME680_BME680_COEFF_ADDR1 = const(0x89)

_BME680_BME680_COEFF_ADDR2 = const(0xE1)

_BME680_BME680_RES_HEAT_0 = const(0x5A)

_BME680_BME680_GAS_WAIT_0 = const(0x64)

_BME680_REG_SOFTRESET = const(0xE0)

_BME680_REG_CTRL_GAS = const(0x71)

_BME680_REG_CTRL_HUM = const(0x72)

_BME280_REG_STATUS = const(0xF3)

_BME680_REG_CTRL_MEAS = const(0x74)

_BME680_REG_CONFIG = const(0x75)

_BME680_REG_PAGE_SELECT = const(0x73)

_BME680_REG_MEAS_STATUS = const(0x1D)

_BME680_REG_PDATA = const(0x1F)

_BME680_REG_TDATA = const(0x22)

_BME680_REG_HDATA = const(0x25)

_BME680_SAMPLERATES = (0, 1, 2, 4, 8, 16)

_BME680_FILTERSIZES = (0, 1, 3, 7, 15, 31, 63, 127)

_BME680_RUNGAS = const(0x10)

_LOOKUP_TABLE_1 = (2147483647.0, 2147483647.0, 2147483647.0, 2147483647.0, 2147483647.0,

2126008810.0, 2147483647.0, 2130303777.0, 2147483647.0, 2147483647.0,

2143188679.0, 2136746228.0, 2147483647.0, 2126008810.0, 2147483647.0,

2147483647.0)

_LOOKUP_TABLE_2 = (4096000000.0, 2048000000.0, 1024000000.0, 512000000.0, 255744255.0, 127110228.0,

64000000.0, 32258064.0, 16016016.0, 8000000.0, 4000000.0, 2000000.0, 1000000.0,

500000.0, 250000.0, 125000.0)

def _read24(arr):

"""Parse an unsigned 24-bit value as a floating point and return it."""

ret = 0.0

#print([hex(i) for i in arr])

for b in arr:

ret *= 256.0

ret += float(b & 0xFF)

return ret

class Adafruit_BME680:

"""Driver from BME680 air quality sensor

:param int refresh_rate: Maximum number of readings per second. Faster property reads

will be from the previous reading."""

def __init__(self, *, refresh_rate=10):

"""Check the BME680 was found, read the coefficients and enable the sensor for continuous

reads."""

self._write(_BME680_REG_SOFTRESET, [0xB6])

time.sleep(0.005)

# Check device ID.

chip_id = self._read_byte(_BME680_REG_CHIPID)

if chip_id != _BME680_CHIPID:

raise RuntimeError('Failed to find BME680! Chip ID 0x%x' % chip_id)

self._read_calibration()

# set up heater

self._write(_BME680_BME680_RES_HEAT_0, [0x73])

self._write(_BME680_BME680_GAS_WAIT_0, [0x65])

self.sea_level_pressure = 1013.25

"""Pressure in hectoPascals at sea level. Used to calibrate ``altitude``."""

# Default oversampling and filter register values.

self._pressure_oversample = 0b011

self._temp_oversample = 0b100

self._humidity_oversample = 0b010

self._filter = 0b010

self._adc_pres = None

self._adc_temp = None

self._adc_hum = None

self._adc_gas = None

self._gas_range = None

self._t_fine = None

self._last_reading = 0

self._min_refresh_time = 1000 / refresh_rate

@property

def pressure_oversample(self):

"""The oversampling for pressure sensor"""

return _BME680_SAMPLERATES[self._pressure_oversample]

@pressure_oversample.setter

def pressure_oversample(self, sample_rate):

if sample_rate in _BME680_SAMPLERATES:

self._pressure_oversample = _BME680_SAMPLERATES.index(sample_rate)

else:

raise RuntimeError("Invalid oversample")

@property

def humidity_oversample(self):

"""The oversampling for humidity sensor"""

return _BME680_SAMPLERATES[self._humidity_oversample]

@humidity_oversample.setter

def humidity_oversample(self, sample_rate):

if sample_rate in _BME680_SAMPLERATES:

self._humidity_oversample = _BME680_SAMPLERATES.index(sample_rate)

else:

raise RuntimeError("Invalid oversample")

@property

def temperature_oversample(self):

"""The oversampling for temperature sensor"""

return _BME680_SAMPLERATES[self._temp_oversample]

@temperature_oversample.setter

def temperature_oversample(self, sample_rate):

if sample_rate in _BME680_SAMPLERATES:

self._temp_oversample = _BME680_SAMPLERATES.index(sample_rate)

else:

raise RuntimeError("Invalid oversample")

@property

def filter_size(self):

"""The filter size for the built in IIR filter"""

return _BME680_FILTERSIZES[self._filter]

@filter_size.setter

def filter_size(self, size):

if size in _BME680_FILTERSIZES:

self._filter = _BME680_FILTERSIZES[size]

else:

raise RuntimeError("Invalid size")

@property

def temperature(self):

"""The compensated temperature in degrees celsius."""

self._perform_reading()

calc_temp = (((self._t_fine * 5) + 128) / 256)

return calc_temp / 100

@property

def pressure(self):

"""The barometric pressure in hectoPascals"""

self._perform_reading()

var1 = (self._t_fine / 2) - 64000

var2 = ((var1 / 4) * (var1 / 4)) / 2048

var2 = (var2 * self._pressure_calibration[5]) / 4

var2 = var2 + (var1 * self._pressure_calibration[4] * 2)

var2 = (var2 / 4) + (self._pressure_calibration[3] * 65536)

var1 = (((((var1 / 4) * (var1 / 4)) / 8192) *

(self._pressure_calibration[2] * 32) / 8) +

((self._pressure_calibration[1] * var1) / 2))

var1 = var1 / 262144

var1 = ((32768 + var1) * self._pressure_calibration[0]) / 32768

calc_pres = 1048576 - self._adc_pres

calc_pres = (calc_pres - (var2 / 4096)) * 3125

calc_pres = (calc_pres / var1) * 2

var1 = (self._pressure_calibration[8] * (((calc_pres / 8) * (calc_pres / 8)) / 8192)) / 4096

var2 = ((calc_pres / 4) * self._pressure_calibration[7]) / 8192

var3 = (((calc_pres / 256) ** 3) * self._pressure_calibration[9]) / 131072

calc_pres += ((var1 + var2 + var3 + (self._pressure_calibration[6] * 128)) / 16)

return calc_pres/100

@property

def humidity(self):

"""The relative humidity in RH %"""

self._perform_reading()

temp_scaled = ((self._t_fine * 5) + 128) / 256

var1 = ((self._adc_hum - (self._humidity_calibration[0] * 16)) -

((temp_scaled * self._humidity_calibration[2]) / 200))

var2 = (self._humidity_calibration[1] *

(((temp_scaled * self._humidity_calibration[3]) / 100) +

(((temp_scaled * ((temp_scaled * self._humidity_calibration[4]) / 100)) /

64) / 100) + 16384)) / 1024

var3 = var1 * var2

var4 = self._humidity_calibration[5] * 128

var4 = (var4 + ((temp_scaled * self._humidity_calibration[6]) / 100)) / 16

var5 = ((var3 / 16384) * (var3 / 16384)) / 1024

var6 = (var4 * var5) / 2

calc_hum = (((var3 + var6) / 1024) * 1000) / 4096

calc_hum /= 1000 # get back to RH

if calc_hum > 100:

calc_hum = 100

if calc_hum < 0:

calc_hum = 0

return calc_hum

@property

def altitude(self):

"""The altitude based on current ``pressure`` vs the sea level pressure

(``sea_level_pressure``) - which you must enter ahead of time)"""

pressure = self.pressure # in Si units for hPascal

return 44330 * (1.0 - math.pow(pressure / self.sea_level_pressure, 0.1903))

@property

def gas(self):

"""The gas resistance in ohms"""

self._perform_reading()

var1 = ((1340 + (5 * self._sw_err)) * (_LOOKUP_TABLE_1[self._gas_range])) / 65536

var2 = ((self._adc_gas * 32768) - 16777216) + var1

var3 = (_LOOKUP_TABLE_2[self._gas_range] * var1) / 512

calc_gas_res = (var3 + (var2 / 2)) / var2

return int(calc_gas_res)

def _perform_reading(self):

"""Perform a single-shot reading from the sensor and fill internal data structure for

calculations"""

if (time.ticks_diff(self._last_reading, time.ticks_ms()) * time.ticks_diff(0, 1)

< self._min_refresh_time):

return

# set filter

self._write(_BME680_REG_CONFIG, [self._filter << 2])

# turn on temp oversample & pressure oversample

self._write(_BME680_REG_CTRL_MEAS,

[(self._temp_oversample << 5)|(self._pressure_oversample << 2)])

# turn on humidity oversample

self._write(_BME680_REG_CTRL_HUM, [self._humidity_oversample])

# gas measurements enabled

self._write(_BME680_REG_CTRL_GAS, [_BME680_RUNGAS])

ctrl = self._read_byte(_BME680_REG_CTRL_MEAS)

ctrl = (ctrl & 0xFC) | 0x01 # enable single shot!

self._write(_BME680_REG_CTRL_MEAS, [ctrl])

new_data = False

while not new_data:

data = self._read(_BME680_REG_MEAS_STATUS, 15)

new_data = data[0] & 0x80 != 0

time.sleep(0.005)

self._last_reading = time.ticks_ms()

self._adc_pres = _read24(data[2:5]) / 16

self._adc_temp = _read24(data[5:8]) / 16

self._adc_hum = struct.unpack('>H', bytes(data[8:10]))[0]

self._adc_gas = int(struct.unpack('>H', bytes(data[13:15]))[0] / 64)

self._gas_range = data[14] & 0x0F

var1 = (self._adc_temp / 8) - (self._temp_calibration[0] * 2)

var2 = (var1 * self._temp_calibration[1]) / 2048

var3 = ((var1 / 2) * (var1 / 2)) / 4096

var3 = (var3 * self._temp_calibration[2] * 16) / 16384

self._t_fine = int(var2 + var3)

def _read_calibration(self):

"""Read & save the calibration coefficients"""

coeff = self._read(_BME680_BME680_COEFF_ADDR1, 25)

coeff += self._read(_BME680_BME680_COEFF_ADDR2, 16)

coeff = list(struct.unpack('<hbBHhbBhhbbHhhBBBHbbbBbHhbb', bytes(coeff[1:39])))

# print("\n\n",coeff)

coeff = [float(i) for i in coeff]

self._temp_calibration = [coeff[x] for x in [23, 0, 1]]

self._pressure_calibration = [coeff[x] for x in [3, 4, 5, 7, 8, 10, 9, 12, 13, 14]]

self._humidity_calibration = [coeff[x] for x in [17, 16, 18, 19, 20, 21, 22]]

self._gas_calibration = [coeff[x] for x in [25, 24, 26]]

# flip around H1 & H2

self._humidity_calibration[1] *= 16

self._humidity_calibration[1] += self._humidity_calibration[0] % 16

self._humidity_calibration[0] /= 16

self._heat_range = (self._read_byte(0x02) & 0x30) / 16

self._heat_val = self._read_byte(0x00)

self._sw_err = (self._read_byte(0x04) & 0xF0) / 16

def _read_byte(self, register):

"""Read a byte register value and return it"""

return self._read(register, 1)[0]

def _read(self, register, length):

raise NotImplementedError()

def _write(self, register, values):

raise NotImplementedError()

class BME680_I2C(Adafruit_BME680):

"""Driver for I2C connected BME680.

:param i2c: I2C device object

:param int address: I2C device address

:param bool debug: Print debug statements when True.

:param int refresh_rate: Maximum number of readings per second. Faster property reads

will be from the previous reading."""

def __init__(self, i2c, address=0x77, debug=False, *, refresh_rate=10):

"""Initialize the I2C device at the 'address' given"""

self._i2c = i2c

self._address = address

self._debug = debug

super().__init__(refresh_rate=refresh_rate)

def _read(self, register, length):

"""Returns an array of 'length' bytes from the 'register'"""

result = bytearray(length)

self._i2c.readfrom_mem_into(self._address, register & 0xff, result)

if self._debug:

print("\t${:x} read ".format(register), " ".join(["{:02x}".format(i) for i in result]))

return result

def _write(self, register, values):

"""Writes an array of 'length' bytes to the 'register'"""

if self._debug:

print("\t${:x} write".format(register), " ".join(["{:02x}".format(i) for i in values]))

for value in values:

self._i2c.writeto_mem(self._address, register, bytearray([value & 0xFF]))

class BME680_SPI(Adafruit_BME680):

"""Driver for SPI connected BME680.

:param spi: SPI device object, configured

:param cs: Chip Select Pin object, configured to OUT mode

:param bool debug: Print debug statements when True.

:param int refresh_rate: Maximum number of readings per second. Faster property reads

will be from the previous reading.

"""

def __init__(self, spi, cs, debug=False, *, refresh_rate=10):

self._spi = spi

self._cs = cs

self._debug = debug

self._cs(1)

super().__init__(refresh_rate=refresh_rate)

def _read(self, register, length):

if register != _BME680_REG_PAGE_SELECT:

# _BME680_REG_PAGE_SELECT exists in both SPI memory pages

# For all other registers, we must set the correct memory page

self._set_spi_mem_page(register)

try:

self._cs(0)

self._spi.write(bytearray([register])) # pylint: disable=no-member

result = bytearray(length)

self._spi.readinto(result) # pylint: disable=no-member

if self._debug:

print("\t${:x} read ".format(register), " ".join(["{:02x}".format(i) for i in result]))

except Exception as e:

print (e)

result = None

finally:

self._cs(1)

return result

def _write(self, register, values):

if register != _BME680_REG_PAGE_SELECT:

# _BME680_REG_PAGE_SELECT exists in both SPI memory pages

# For all other registers, we must set the correct memory page

self._set_spi_mem_page(register)

try:

self._cs(0)

buffer = bytearray(2 * len(values))

for i, value in enumerate(values):

buffer[2 * i] = register + i

buffer[2 * i + 1] = value & 0xFF

self._spi.write(buffer) # pylint: disable=no-member

if self._debug:

print("\t${:x} write".format(register), " ".join(["{:02x}".format(i) for i in values]))

except Exception as e:

print (e)

finally:

self._cs(1)

def _set_spi_mem_page(self, register):

spi_mem_page = 0x00

if register < 0x80:

spi_mem_page = 0x10

self._write(_BME680_REG_PAGE_SELECT, [spi_mem_page])

このモジュールを用いますと簡単に測定できます。Adafruitで用意しているテスト用プログラムを使用し、毎度のプルアップをソフト的に行います。

from bme680 import *
from machine import I2C, Pin
import time
p21 = Pin(21, Pin.IN, Pin.PULL_UP)
p23 = Pin(23, Pin.IN, Pin.PULL_UP)
bme = BME680_I2C(I2C(-1, Pin(21), Pin(23)))

for _ in range(3):
    print(bme.temperature, bme.humidity, bme.pressure, bme.gas)
    time.sleep(1)

from bme680 import *

from machine import I2C, Pin

import time

p21 = Pin(21, Pin.IN, Pin.PULL_UP)

p23 = Pin(23, Pin.IN, Pin.PULL_UP)

bme = BME680_I2C(I2C(-1, Pin(21), Pin(23)))

for _ in range(3):

print(bme.temperature, bme.humidity, bme.pressure, bme.gas)

time.sleep(1)

あっという間に出来上がりです。

C:\Users\>ampy -p com3 run c:\micropython\bmetest.py
Warning: I2C(-1, ...) is deprecated, use SoftI2C(...) instead
15.30285 45.3333 1031.108 269211
15.31457 45.40735 1031.111 116460
15.33859 45.47064 1031.105 124723

次回はこれを用いて、DBにつなぎます。

2021年2月28日2021年3月1日

秋月電子で新しいブツを仕入れる

緊急事態宣言下ではありますが、途中のルートでしたので秋葉原の秋月電子https://akizukidenshi.com/catalog/によって新しいブツを仕入れてきました。

温湿度、気圧、ガスの複合センサのBME680とブレッドボードです。

まずはブレッドボードです。以前にもちょくちょく買ってたんですが、直近で買ったやつがいけない。

左側が前に買ったやつで、右が今回買ってるのと同じブレッドボードです。見て分かるようにESP32は幅が広いため５：５のブレッドボードだと、片側のみしか使えないんですよね。今回購入したブレッドボードは、６：６なので、両サイドでも最低1本はピンを刺すことができます。これに気がつかないとテスト配線するのに大きな不都合が出てきます。

次に新しいセンサBME680ですが、これはBOSCH製の複合センサですが、秋月電子の方で必要な部品を取り付けてあります。

１番上のセンサがBOSCH製のセンサです。左下の黒い部品がI2CレベルコンバータICです。このBOSCH製のセンサはSPII2C対応ですが、このキットではI2Cクロックアップ用に付いているみたいです。右下は定番の電源用の三端子レギュレータです。老眼が進み、細かい半田付けも厳しくなってきましたが、引き続き頑張ります。

2021年2月27日2021年2月27日

キャリートラック（DA63T）サーモスタット交換

事業用のキャリートラックですが、先日車検時にサーモスタット不良を指摘されていましたので、交換しました。

この型式のサーモは手の入りにくいところにあるということで、ネットで予習をしておきました。

まずは助手席の背もたれと、シートを外します。

このシートの2個のボルトを外せばオープンです。

ですが、それでもサーモスタットまでは手が入りません。

全然手が入りません。ミッションのノブをネジって外し、４駆のトランスファーレバーのネジを外してレバーを外し、ピンを外してやっとセンターコンソールが外れます。

プラスを切ってある10ミリのボルトを4個外したら、動くかと思ったら動きません。ミッションレバーの前方の12ミリネジ2個を外します。

これでやっとプレートが動きますが、渋いので輪止めをかけて、サイドブレーキを外します。そうして運転席側にずらしますが、まだ足りないので、最終的には運転席側のシートベルトソケットの14ミリのボルトまで外しました。サーモスタットカバーの手前側の12ミリはユニバーサル付きのソケットで緩め、奥側のボルトはメガネでなんとか緩めました。サーモスタットカバーについているエア抜き用の10ミリボルトはエクステンション二個延長でなんとか緩めました。手前側のボルトはソケットですから、さっさと抜けましたが、奥側はスペースもないので、スパナでシコシコ回してやっと抜けました。サーモスタットカバーをなんとか外し、やっとサーモとご対面です。

ピンボケでした。すいません。

新品との比較をしてみると、完全に開きっぱなしでした。左側が古いサーモです。

後はひたすら組立るだけです。組み付けが終了したら、エア抜きをする必要があります。ボンネットを開けると、冷却水交換後のエア抜きの仕方のシールが貼ってあります。

このホースを外して、サーモスタットカバーのエア抜きのボルトを緩めるんですがなかなかエア抜きできません。よく読んだら、ラジエターのキャップも開けるんですね。よく読まないと。エア抜き終了し、クーラントを継ぎ足したら終了です。試運転して、漏れてないことを確認して終了です。

2021年2月25日2021年2月25日

ESP32からMariaDBにデータをとばす

センサからのデータもとれるようになり、Wi-Fiにつながり、ＮＴＰで時計の補正もできるようになりました。

IoTを進める中で必要なのはデータベースにひたすらデータを放り込み、その中で、異常のあるデータをいかに早く見つけ出すかが重要になります。このため、今回はデータベースにMariaDBを用い、ESP32からデータをPHPにPOSTしデータベースに取り込む一連の流れを紹介します。

まずはデータベースを作成します。MariaDBのインストールその他は省略しまして、既にesp_dataというデータベースを作成してあるところから始めます。phpMyAdminを使用してデータベース中にSensorDataというテーブルを作ります。次のSQL文をphpMyAdminのSQLクエリを実行し、テーブルを作ります。今回テストの都合でMACadd列は省略してあります。

CREATE TABLE SensorData (
    id INT(6) UNSIGNED AUTO_INCREMENT PRIMARY KEY,
//    MACadd VARCHAR(30) NOT NULL,
    value1 VARCHAR(10),
    value2 VARCHAR(10),
    value3 VARCHAR(10),
    reading_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
)

テーブルが出来上がったら、適当にデータを入れてみます。

INSERT INTO SensorData(value1, value2, value3) VALUES (12.3,23.4,35.3)

実行を押すとSQL文が実行され、行が挿入されます。ここまで確認したら、次はMicroPython上でjsonを用いたPOST文を作成します。

import ujson
import urequests
 

dict = {
        "data_value":"12.4",
        "temp_value":"23.4",
        "humi_value":"35.2"
        }
response = urequests.post(
        'http://**url**/postrcv.php',
        data=ujson.dumps(dict).encode("utf-8"),
        headers={'Content-Type': 'application/json'}
        )
print  (response.text)

import ujson

import urequests

dict = {

"data_value":"12.4",

"temp_value":"23.4",

"humi_value":"35.2"

}

response = urequests.post(

'http://**url**/postrcv.php',

data=ujson.dumps(dict).encode("utf-8"),

headers={'Content-Type': 'application/json'}

)

print (response.text)

MicroPythonではpythonで使用するjsonとrequestsの頭にuをつける形になります。この形でpostできます。

次にデータを受けるphp側を作成します。

<?php

$in = json_decode(stripslashes(file_get_contents('php://input')),true);
$data_value = $in["data_value"];
$temp_value = $in["temp_value"]; 
$humi_value = $in["humi_value"];

$servername = "localhost";
$dbname = "esp_data";
$username = "username";
$password = "password";

$conn = new mysqli($servername, $username, $password, $dbname);
if ($conn->connect_error) {
     die("Connection failed: " . $conn->connect_error);
} 

$sql="INSERT INTO `SensorData`(`value1`, `value2`, `value3`) VALUES ($data_value,$temp_value,$humi_value)";
if ($conn->query($sql) === TRUE) {
    echo "New record created successfully";
} 
else {
    echo "Error: " . $sql . "<br>" . $conn->error;
}
    
$conn->close();

?>

<?php

$in = json_decode(stripslashes(file_get_contents('php://input')),true);

$data_value = $in["data_value"];

$temp_value = $in["temp_value"];

$humi_value = $in["humi_value"];

$servername = "localhost";

$dbname = "esp_data";

$username = "username";

$password = "password";

$conn = new mysqli($servername, $username, $password, $dbname);

if ($conn->connect_error) {

die("Connection failed: " . $conn->connect_error);

}

$sql="INSERT INTO `SensorData`(`value1`, `value2`, `value3`) VALUES ($data_value,$temp_value,$humi_value)";

if ($conn->query($sql) === TRUE) {

echo "New record created successfully";

}

else {

echo "Error: " . $sql . "<br>" . $conn->error;

}

$conn->close();

コマンドラインからampyを用いて上記MicroPythonのプログラムを走らせた結果が次です。

C:\Users\>ampy -p com4 run c:\micropython\posttest.py
New record created successfully

phpMyAdminで確認しても新しいレコードが挿入されています。

編集コピー削除1712.323.435.32021-02-25 19:35:51