Архивы умный дом

Набор скриптов для «умного дома» на Raspberry PI 3

08.11.2023 Павел Грибов PHP, Python

Так уж получилось, что мой «умный» дом, это фактически небольшая кучка скриптов. Приведу пример основных из них, вдруг кому интересно будет…

Отправка/получение данных по радиоканалу с частотой 433Mhz:

Получение:

#!/usr/bin/env python3

import argparse
import signal
import sys
import time
import logging
from rpi_rf import RFDevice
import fcntl, sys,os

fp = open(os.path.realpath(__file__), 'r')
try:
    fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print('неужели другой мой экземпляр всё ещё работает?')
    sys.exit(0)

rfdevice = None
# pylint: disable=unused-argument
def exithandler(signal, frame):
    rfdevice.cleanup()
    sys.exit(0)

logging.basicConfig(level=logging.DEBUG, datefmt='%Y-%m-%d %H:%M:%S',
                    format='%(asctime)-15s - [%(levelname)s] %(module)s: %(message)s', )

parser = argparse.ArgumentParser(description='Receives a decimal code via a 433/315MHz GPIO device')
parser.add_argument('-g', dest='gpio', type=int, default=22,
                    help="GPIO pin (Default: 27)")
args = parser.parse_args()

signal.signal(signal.SIGINT, exithandler)
rfdevice = RFDevice(args.gpio)
rfdevice.enable_rx()
timestamp = None
logging.info("Listening for codes on GPIO " + str(args.gpio))
while True:
    if rfdevice.rx_code_timestamp != timestamp:
        timestamp = rfdevice.rx_code_timestamp
        logging.info(str(rfdevice.rx_code) +
                     " [pulselength " + str(rfdevice.rx_pulselength) +
                     ", protocol " + str(rfdevice.rx_proto) + "]")
    time.sleep(0.01)

#!/usr/bin/env python3

import argparse

import signal

import sys

import time

import logging

from rpi_rf import RFDevice

import fcntl, sys,os

fp = open(os.path.realpath(__file__), 'r')

try:

fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)

except IOError:

print('неужели другой мой экземпляр всё ещё работает?')

sys.exit(0)

rfdevice = None

# pylint: disable=unused-argument

def exithandler(signal, frame):

rfdevice.cleanup()

sys.exit(0)

logging.basicConfig(level=logging.DEBUG, datefmt='%Y-%m-%d %H:%M:%S',

format='%(asctime)-15s - [%(levelname)s] %(module)s: %(message)s', )

parser = argparse.ArgumentParser(description='Receives a decimal code via a 433/315MHz GPIO device')

parser.add_argument('-g', dest='gpio', type=int, default=22,

help="GPIO pin (Default: 27)")

args = parser.parse_args()

signal.signal(signal.SIGINT, exithandler)

rfdevice = RFDevice(args.gpio)

rfdevice.enable_rx()

timestamp = None

logging.info("Listening for codes on GPIO " + str(args.gpio))

while True:

if rfdevice.rx_code_timestamp != timestamp:

timestamp = rfdevice.rx_code_timestamp

logging.info(str(rfdevice.rx_code) +

" [pulselength " + str(rfdevice.rx_pulselength) +

", protocol " + str(rfdevice.rx_proto) + "]")

time.sleep(0.01)

Отправка:

#!/usr/bin/env python3

import argparse
import signal
import sys
import time
import logging
from rpi_rf import RFDevice
import fcntl, sys,os

fp = open(os.path.realpath(__file__), 'r')
try:
    fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print('неужели другой мой экземпляр всё ещё работает?')
    sys.exit(0)

logging.basicConfig(level=logging.INFO, datefmt='%Y-%m-%d %H:%M:%S',
                    format='%(asctime)-15s - [%(levelname)s] %(module)s: %(message)s',)

parser = argparse.ArgumentParser(description='Sends a decimal code via a 433/315MHz GPIO device')
parser.add_argument('code', metavar='CODE', type=int, help="Decimal code to send")
parser.add_argument('-g', dest='gpio', type=int, default=17, help="GPIO pin (Default: 17)")
parser.add_argument('-p', dest='pulselength', type=int, default=None,help="Pulselength (Default: 350)")
parser.add_argument('-t', dest='protocol', type=int, default=None,help="Protocol (Default: 1)")
parser.add_argument('-l', dest='length', type=int, default=None,help="Codelength (Default: 24)")
parser.add_argument('-r', dest='repeat', type=int, default=10,help="Repeat cycles (Default: 10)")
args = parser.parse_args()

rfdevice = RFDevice(args.gpio)
rfdevice.enable_tx()
rfdevice.tx_repeat = args.repeat

if args.protocol:
    protocol = args.protocol
else:
    protocol = "default"
if args.pulselength:
    pulselength = args.pulselength
else:
    pulselength = "default"
if args.length:
    length = args.length
else:
    length = "default"

logging.info(str(args.code) +
             " [protocol: " + str(protocol) +
             ", pulselength: " + str(pulselength) +
             ", length: " + str(length) +
             ", repeat: " + str(rfdevice.tx_repeat) + "]")

rfdevice.tx_code(args.code, args.protocol, args.pulselength, args.length)
rfdevice.cleanup()

#!/usr/bin/env python3

import argparse

import signal

import sys

import time

import logging

from rpi_rf import RFDevice

import fcntl, sys,os

fp = open(os.path.realpath(__file__), 'r')

try:

fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)

except IOError:

print('неужели другой мой экземпляр всё ещё работает?')

sys.exit(0)

logging.basicConfig(level=logging.INFO, datefmt='%Y-%m-%d %H:%M:%S',

format='%(asctime)-15s - [%(levelname)s] %(module)s: %(message)s',)

parser = argparse.ArgumentParser(description='Sends a decimal code via a 433/315MHz GPIO device')

parser.add_argument('code', metavar='CODE', type=int, help="Decimal code to send")

parser.add_argument('-g', dest='gpio', type=int, default=17, help="GPIO pin (Default: 17)")

parser.add_argument('-p', dest='pulselength', type=int, default=None,help="Pulselength (Default: 350)")

parser.add_argument('-t', dest='protocol', type=int, default=None,help="Protocol (Default: 1)")

parser.add_argument('-l', dest='length', type=int, default=None,help="Codelength (Default: 24)")

parser.add_argument('-r', dest='repeat', type=int, default=10,help="Repeat cycles (Default: 10)")

args = parser.parse_args()

rfdevice = RFDevice(args.gpio)

rfdevice.enable_tx()

rfdevice.tx_repeat = args.repeat

if args.protocol:

protocol = args.protocol

else:

protocol = "default"

if args.pulselength:

pulselength = args.pulselength

else:

pulselength = "default"

if args.length:

length = args.length

else:

length = "default"

logging.info(str(args.code) +

" [protocol: " + str(protocol) +

", pulselength: " + str(pulselength) +

", length: " + str(length) +

", repeat: " + str(rfdevice.tx_repeat) + "]")

rfdevice.tx_code(args.code, args.protocol, args.pulselength, args.length)

rfdevice.cleanup()

Получение температуры/влажности с датчиков dh11:

#!/usr/bin/python
import Adafruit_DHT
import time
import mysql.connector
from mysql.connector import Error
import json
import os
import fcntl, sys

fp = open(os.path.realpath(__file__), 'r')
try:
    fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print('неужели другой мой экземпляр всё ещё работает?')
    sys.exit(0)

dir=os.path.dirname(os.path.abspath(__file__))
with open(dir+'/../config.json', 'r', encoding='utf-8') as f: #открыли файл с данными
    config = json.load(f) #загнали все, что получилось в переменную

print(config["db"]);


try:
    conn = mysql.connector.connect(host=config["db"]["host"],database=config["db"]["database"],user=config["db"]["username"],password=config["db"]["password"])
    if conn.is_connected(): print('Вроде соеденился!')
except Error as e:
    print(e);
    exit(0);

DHT_SENSOR = Adafruit_DHT.DHT11

sql="SELECT * FROM sources WHERE device=1";
if len(sys.argv)==2:
 id=sys.argv[1]
 sql=f"SELECT * FROM sources WHERE id='{id}'";

cursor2=conn.cursor(dictionary=True,buffered=True)
cursor2.execute(sql,[]);
myrow3 = cursor2.fetchone()
while myrow3 is not None:
  id=myrow3["id"]
  source=myrow3["id"]
  place=myrow3["place"]
  param=json.loads(myrow3["param"].decode("utf-8"))
  pin=param["pin"]
  print(f"-опрашиваю статус датчик {id},pin={pin}")
  cnt=3
  while cnt>0:
    humidity, temperature = Adafruit_DHT.read(DHT_SENSOR, pin)
    if humidity is not None and temperature is not None:
        if humidity<140:
         print("Temp={0:0.1f}C Humidity={1:0.1f}%".format(temperature, humidity))
         sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},1,{temperature},now());";
         cursor = conn.cursor(dictionary=True,buffered=True)
         cursor.execute(sql);
         conn.commit()
         cnt=0
    else:
        print("Sensor failure. Check wiring...");
    time.sleep(3);
    cnt=cnt-1
  myrow3 = cursor2.fetchone()
conn.commit()

exit(-1)

#!/usr/bin/python

import Adafruit_DHT

import time

import mysql.connector

from mysql.connector import Error

import json

import os

import fcntl, sys

fp = open(os.path.realpath(__file__), 'r')

try:

fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)

except IOError:

print('неужели другой мой экземпляр всё ещё работает?')

sys.exit(0)

dir=os.path.dirname(os.path.abspath(__file__))

with open(dir+'/../config.json', 'r', encoding='utf-8') as f: #открыли файл с данными

config = json.load(f) #загнали все, что получилось в переменную

print(config["db"]);

try:

conn = mysql.connector.connect(host=config["db"]["host"],database=config["db"]["database"],user=config["db"]["username"],password=config["db"]["password"])

if conn.is_connected(): print('Вроде соеденился!')

except Error as e:

print(e);

exit(0);

DHT_SENSOR = Adafruit_DHT.DHT11

sql="SELECT * FROM sources WHERE device=1";

if len(sys.argv)==2:

id=sys.argv[1]

sql=f"SELECT * FROM sources WHERE id='{id}'";

cursor2=conn.cursor(dictionary=True,buffered=True)

cursor2.execute(sql,[]);

myrow3 = cursor2.fetchone()

while myrow3 is not None:

id=myrow3["id"]

source=myrow3["id"]

place=myrow3["place"]

param=json.loads(myrow3["param"].decode("utf-8"))

pin=param["pin"]

print(f"-опрашиваю статус датчик {id},pin={pin}")

cnt=3

while cnt>0:

humidity, temperature = Adafruit_DHT.read(DHT_SENSOR, pin)

if humidity is not None and temperature is not None:

if humidity<140:

print("Temp={0:0.1f}C Humidity={1:0.1f}%".format(temperature, humidity))

sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},1,{temperature},now());";

cursor = conn.cursor(dictionary=True,buffered=True)

cursor.execute(sql);

conn.commit()

cnt=0

else:

print("Sensor failure. Check wiring...");

time.sleep(3);

cnt=cnt-1

myrow3 = cursor2.fetchone()

conn.commit()

exit(-1)

Мигаем светодиом:

#!/usr/bin/python
import RPi.GPIO as GPIO
import time
import fcntl, sys, os
from time import sleep
while  True:
    try:
        GPIO.setmode(GPIO.BCM)
        GPIO.setup(23, GPIO.OUT)
        GPIO.output(23, True)
        time.sleep(0.5)
        GPIO.output(23, False)
        time.sleep(0.5)
    finally:
       print("clean up")
       GPIO.cleanup()

#!/usr/bin/python

import RPi.GPIO as GPIO

import time

import fcntl, sys, os

from time import sleep

while True:

try:

GPIO.setmode(GPIO.BCM)

GPIO.setup(23, GPIO.OUT)

GPIO.output(23, True)

time.sleep(0.5)

GPIO.output(23, False)

time.sleep(0.5)

finally:

print("clean up")

GPIO.cleanup()

Получение данных с микротика

Температура:

$fl = fopen("/tmp/".basename(__FILE__).".lock", "w");
    if( ! ( $fl && flock( $fl, LOCK_EX | LOCK_NB ) ) ) {
    die("--копия скрипта уже запущена!");
};


define('WUO_ROOT', dirname(__FILE__));
require_once WUO_ROOT.'/vendor/autoload.php';
require_once WUO_ROOT.'/../class/Tsql.php';

$config=json_decode(file_get_contents(WUO_ROOT."/../config.json"));
var_dump($config);


$sqln=new Tsql("mysql","m_data",$config->db->host,$config->db->username,$config->db->password);


$config = new \RouterOS\Config([
    'host' => '192.wefrwerfwe1',
    'user' => 'ewrfwerfe',
    'pass' => 'erwfwerfew',
    'port' => 8728,
]);
$client = new \RouterOS\Client($config);

$res=$client->query('/system/health/print')->read();

$temp=$res[0]["temperature"];

 $sql="insert into m_data (place,source,value_type,value,dt) values (10,12,1,'$temp',now())";
 $stmt=$sqln->dbh->prepare($sql);
 $stmt->execute();

$fl = fopen("/tmp/".basename(__FILE__).".lock", "w");

if( ! ( $fl && flock( $fl, LOCK_EX | LOCK_NB ) ) ) {

die("--копия скрипта уже запущена!");

};

define('WUO_ROOT', dirname(__FILE__));

require_once WUO_ROOT.'/vendor/autoload.php';

require_once WUO_ROOT.'/../class/Tsql.php';

$config=json_decode(file_get_contents(WUO_ROOT."/../config.json"));

var_dump($config);

$sqln=new Tsql("mysql","m_data",$config->db->host,$config->db->username,$config->db->password);

$config = new \RouterOS\Config([

'host' => '192.wefrwerfwe1',

'user' => 'ewrfwerfe',

'pass' => 'erwfwerfew',

'port' => 8728,

]);

$client = new \RouterOS\Client($config);

$res=$client->query('/system/health/print')->read();

$temp=$res[0]["temperature"];

$sql="insert into m_data (place,source,value_type,value,dt) values (10,12,1,'$temp',now())";

$stmt=$sqln->dbh->prepare($sql);

$stmt->execute();

Уровни WIFI сигналов:

$client = new \RouterOS\Client($config);

$res=$client->query('/interface/wireless/registration-table/print')->read();

var_dump($res);

$client = new \RouterOS\Client($config);

$res=$client->query('/interface/wireless/registration-table/print')->read();

var_dump($res);

WiFi реле Sonoff DIY 3:

Текущий статус:

#!/usr/bin/python3
import pymysql
import requests
from urllib3.exceptions import InsecureRequestWarning
from mysql.connector import Error
import mysql.connector
import random
import os,fcntl, sys
import json

sys.path.insert(0, '/root/scripts/includes')
import functions

fp = open(os.path.realpath(__file__), 'r')
try:
    fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)
except IOError:
    print('неужели другой мой экземпляр всё ещё работает?')
    sys.exit(0)


dir=os.path.dirname(os.path.abspath(__file__))
with open(dir+'/../config.json', 'r', encoding='utf-8') as f: #открыли файл с данными
    config = json.load(f) #загнали все, что получилось в переменную

def GetSonoffStatus(ip):
 ret={"error":True,"signal":0,"switch":True}

 requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
 post_params = '{"deviceid": "","data": {}}'

 try:
    response = requests.post(f"http://{ip}:8081/zeroconf/info", data=post_params, verify=False)
    res = response.json()
    print(f"пришло:{res}")

    if type(res['data'])==str:
      res["data"]=json.loads(res["data"])

    if res["data"]["switch"]=="off":
       ret["switch"]=False

    if "signalStrength" in res["data"]:
       ret["signal"]=res["data"]["signalStrength"]
    ret["error"]=False

 except Exception as e:
    print(f"Ошибка:{e}")


# соединяемся с БД
try:
    conn = mysql.connector.connect(host=config["db"]["host"],database=config["db"]["database"],user=config["db"]["username"],password=config["db"]["password"])
    if conn.is_connected(): print('Вроде соеденился!')
except Error as e:
    print(e);
    exit(0);

sql="SELECT * FROM sources WHERE device=3";
if len(sys.argv)==2:
 ip=sys.argv[1]
 sql=f"SELECT * FROM sources WHERE ip='{ip}'";

cursor2=conn.cursor(dictionary=True,buffered=True)
cursor2.execute(sql,[]);
myrow3 = cursor2.fetchone()
while myrow3 is not None:
  ip=myrow3["ip"].decode("utf-8")
  source=myrow3["id"]
  place=myrow3["place"]
  deviceid=myrow3["deviceid"].decode("utf-8")
  print(f"-опрашиваю статус реле {ip}")
  res=functions.GetSonoffStatus(ip)
  if res["error"]==False:
    sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},3,{res['switch']},now())";
    cursor = conn.cursor(dictionary=True,buffered=True)
    cursor.execute(sql);
    conn.commit()
    sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},4,{res['signal']},now())";
    cursor = conn.cursor(dictionary=True,buffered=True)
    cursor.execute(sql);
    conn.commit()
  myrow3 = cursor2.fetchone()
conn.commit()

#!/usr/bin/python3

import pymysql

import requests

from urllib3.exceptions import InsecureRequestWarning

from mysql.connector import Error

import mysql.connector

import random

import os,fcntl, sys

import json

sys.path.insert(0, '/root/scripts/includes')

import functions

fp = open(os.path.realpath(__file__), 'r')

try:

fcntl.flock(fp, fcntl.LOCK_EX | fcntl.LOCK_NB)

except IOError:

print('неужели другой мой экземпляр всё ещё работает?')

sys.exit(0)

dir=os.path.dirname(os.path.abspath(__file__))

with open(dir+'/../config.json', 'r', encoding='utf-8') as f: #открыли файл с данными

config = json.load(f) #загнали все, что получилось в переменную

def GetSonoffStatus(ip):

ret={"error":True,"signal":0,"switch":True}

requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)

post_params = '{"deviceid": "","data": {}}'

try:

response = requests.post(f"http://{ip}:8081/zeroconf/info", data=post_params, verify=False)

res = response.json()

print(f"пришло:{res}")

if type(res['data'])==str:

res["data"]=json.loads(res["data"])

if res["data"]["switch"]=="off":

ret["switch"]=False

if "signalStrength" in res["data"]:

ret["signal"]=res["data"]["signalStrength"]

ret["error"]=False

except Exception as e:

print(f"Ошибка:{e}")

# соединяемся с БД

try:

conn = mysql.connector.connect(host=config["db"]["host"],database=config["db"]["database"],user=config["db"]["username"],password=config["db"]["password"])

if conn.is_connected(): print('Вроде соеденился!')

except Error as e:

print(e);

exit(0);

sql="SELECT * FROM sources WHERE device=3";

if len(sys.argv)==2:

ip=sys.argv[1]

sql=f"SELECT * FROM sources WHERE ip='{ip}'";

cursor2=conn.cursor(dictionary=True,buffered=True)

cursor2.execute(sql,[]);

myrow3 = cursor2.fetchone()

while myrow3 is not None:

ip=myrow3["ip"].decode("utf-8")

source=myrow3["id"]

place=myrow3["place"]

deviceid=myrow3["deviceid"].decode("utf-8")

print(f"-опрашиваю статус реле {ip}")

res=functions.GetSonoffStatus(ip)

if res["error"]==False:

sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},3,{res['switch']},now())";

cursor = conn.cursor(dictionary=True,buffered=True)

cursor.execute(sql);

conn.commit()

sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},4,{res['signal']},now())";

cursor = conn.cursor(dictionary=True,buffered=True)

cursor.execute(sql);

conn.commit()

myrow3 = cursor2.fetchone()

conn.commit()

Переключение реле:

def SonoffReleSwitch(conn,ip,deviceid,rele):
 requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
 if rele==True:
   post_params = '{"deviceid": "","data": {"switch":"on"}}'
 else:
     post_params = '{"deviceid": "","data": {"switch":"off"}}'
 # переключаю реле
 try:
    response = requests.post(f"http://{ip}:8081/zeroconf/switch", data=post_params, verify=False)
    res = response.json()
    print(f"---пришло:{res}")
    if res["error"]==0:
       print("- ошибок нет!");
       return True
    return False
 except requests.exceptions.HTTPError as errh:
  print("HTTP Error")
 except requests.exceptions.ReadTimeout as errrt:
  print("Time out")
 except requests.exceptions.ConnectionError as conerr:
  print("Connection error")
 return False

def SonoffReleSwitch(conn,ip,deviceid,rele):

requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)

if rele==True:

post_params = '{"deviceid": "","data": {"switch":"on"}}'

else:

post_params = '{"deviceid": "","data": {"switch":"off"}}'

# переключаю реле

try:

response = requests.post(f"http://{ip}:8081/zeroconf/switch", data=post_params, verify=False)

res = response.json()

print(f"---пришло:{res}")

if res["error"]==0:

print("- ошибок нет!");

return True

return False

except requests.exceptions.HTTPError as errh:

print("HTTP Error")

except requests.exceptions.ReadTimeout as errrt:

print("Time out")

except requests.exceptions.ConnectionError as conerr:

print("Connection error")

return False

Оставить комментарий 433, microtick, rele, sonoff, умный дом

Python: Получение состояния реле Sonoff Basic R3

09.01.2023 Павел Грибов Python

Задача: получить состояние реле и записать его состояние в БД

Решение:

Реле отдает своё состояние по ссылке:

http://{ip}:8081/zeroconf/info

1	http://{ip}:8081/zeroconf/info

Однако в зависимости от ревизии прошивки, данные могут немного отличаться. В нижеприведённом скрипте это учтено:

#!/usr/bin/python3
import config
import pymysql
import requests
from urllib3.exceptions import InsecureRequestWarning
import random

ip="192.168.88.245"             # IP реле
source=2        # источник - реле SonOff_1 (Гостинная)
place=1         # расположение реле - гостиннная

# здесь кусок кода который опрашивает текущее состояние реле
requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
post_params = '{"deviceid": "","data": {}}'
response = requests.post(f"http://{ip}:8081/zeroconf/info", data=post_params, verify=False)
try:
    res = response.json()
    print(f"пришло:{res}")
    switch=True
    signal=0
    if type(res['data'])==str:
      res["data"]=json.loads(res["data"])
    if res["data"]["switch"]=="off":switch=False
    if "signalStrength" in res["data"]:signal=res["data"]["signalStrength"]

except Exception as e:
    print(f"Ошибка:{e}")
    exit(-1)

print(signal)
print(switch)

# соединяемся с БД
con=pymysql.connect(host=config.gconfig['mysql_host'],
                port=3306,
                user=config.gconfig['mysql_user'],
                password=config.gconfig['mysql_password'],
                database=config.gconfig['mysql_base'],
                cursorclass=pymysql.cursors.DictCursor
        )
# ложим данные в БД
with con.cursor() as cursor:
    sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},3,{switch},now())";
    cursor.execute(sql)
    con.commit()
    sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},4,{signal},now())";
    cursor.execute(sql)
    con.commit()

#!/usr/bin/python3

import config

import pymysql

import requests

from urllib3.exceptions import InsecureRequestWarning

import random

ip="192.168.88.245" # IP реле

source=2 # источник - реле SonOff_1 (Гостинная)

place=1 # расположение реле - гостиннная

# здесь кусок кода который опрашивает текущее состояние реле

requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)

post_params = '{"deviceid": "","data": {}}'

response = requests.post(f"http://{ip}:8081/zeroconf/info", data=post_params, verify=False)

try:

res = response.json()

print(f"пришло:{res}")

switch=True

signal=0

if type(res['data'])==str:

res["data"]=json.loads(res["data"])

if res["data"]["switch"]=="off":switch=False

if "signalStrength" in res["data"]:signal=res["data"]["signalStrength"]

except Exception as e:

print(f"Ошибка:{e}")

exit(-1)

print(signal)

print(switch)

# соединяемся с БД

con=pymysql.connect(host=config.gconfig['mysql_host'],

port=3306,

user=config.gconfig['mysql_user'],

password=config.gconfig['mysql_password'],

database=config.gconfig['mysql_base'],

cursorclass=pymysql.cursors.DictCursor

)

# ложим данные в БД

with con.cursor() as cursor:

sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},3,{switch},now())";

cursor.execute(sql)

con.commit()

sql=f"insert into m_data (place,source,value_type,value,dt) values ({place},{source},4,{signal},now())";

cursor.execute(sql)

con.commit()

Оставить комментарий sonoff, получение состояния, реле, умный дом

Прогноз погоды на arduino.

11.09.2015 Павел Грибов arduino

Продолжаю героически пилить «Умный дом». На текущий момент сделано: вывод времени, даты, дня недели, погоды на сегодня и завтра, текущей температуры, включение/выключение дисплея по датчику движения.

Не удалось: подружить плату точного времени ds3231 работающую по шине i2C и Ethernet плату ENC28J60 работающую по шине SPI, Пошел какой-то конфликт между платами, разобраться как разрулить не смог. Пришлось время тоже брать с интернета.

Ниже приведен скетч на текущий момент. » Читать далее

Оставить комментарий arduino, умный дом

Оказывается у Arduino Mega/Uno нет нормальной многопоточности…

13.07.2015 Павел Грибов Отзывы о девайсах

Думал в выходные про будущую реализацию «Умного дома».. Делал некоторые наброски и т.п.. Стало шоком, что оказывается в Arduino не реализована «железячная» многопоточность т.е. выполнение нескольких подпрограмм одновременно. Реализовать некое подобие можно при помощи костылей «выполнение по таймеру» и прерываний.. Но всё не то.. Так-же есть несколько скетчей, написаных на ассемблере, которые расширяют стандартный вход main в программе, и делают «некий программный аналог» многопоточности. Ну ближе к делу посмотрим… Знать бы конечно сразу, так возможно бы остановился на Raspberry Pi..но цена там конечно более кусачая.

Оставить комментарий arduino, многопоточность, умный дом

Декабрь 2024
Пн	Вт	Ср	Чт	Пт	Сб	Вс
						1
2	3	4	5	6	7	8
9	10	11	12	13	14	15
16	17	18	19	20	21	22
23	24	25	26	27	28	29
30	31