MariaDB - 栄商会

2022年7月30日2022年7月30日

MySQLクライアント接続設定（備忘録）

サーバーにMySQLを入れた際にターミナル接続は可能なのに、クライアントソフトからの接続ができなかったため、cnfファイルの変更備忘録。

cnfファイル　/etc/mysql/mysql.conf.d/mysqld.conf

bind-address = 192.168.1.51 #デフォルトは127.0.0.1
mysqlx-bind-address = 192.168.1.51　＃デフォルトは127.0.0.1

sudo service mysql restart　でMySQLをリスタートし、アプリで確認。無事アクセスできました。

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年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