Uživatelské nástroje

Nástroje pro tento web


smarthome:newpi

Nové SpiHOME

Souhrn služeb

nazev sluzby popis
elmer.service vycitani elmeru
dht22.service hodnoty z DHT22
dallas.service hodnoty z 1wire
mqtt-gpio.service ovladani gpio rele
relay.service inicializace rele
zabbix-agent.service zabak
mpd.service music player (neni vsude)
bellj.service zvonek nahore (neni vsude)
bells.service zvonek dole (neni vsude)

Sračky na úvod

apt update && apt upgrade && apt install python-pip mc

uz jedem pres systemd:

nano /lib/systemd/system/myscript.service
[Unit]
Description=My Script Service
# Wants=network-online.target
# After=network.target network-online.target
After=multi-user.target

[Service]
Type=idle
ExecStart=/usr/bin/python /home/pi/myscript.py
# ExecStart=/usr/bin/python /home/pi/myscript.py > /home/pi/myscript.log 2>&1

[Install]
WantedBy=multi-user.target
sudo chmod 644 /lib/systemd/system/myscript.service
sudo systemctl daemon-reload
 sudo systemctl enable myscript.service

Log2RAM

Zapojeni headeru

 +-----+-----+---------+------+---+---Pi 3B--+---+------+---------+-----+-----+
 | BCM | wPi |   Name  | use  | V | Physical | V | use  | Name    | wPi | BCM |
 +-----+-----+---------+------+---+----++----+---+------+---------+-----+-----+
 |     |     |    3.3v |      |   |  1 || 2  |   |      | 5v      |     |     |
 |   2 |   8 |   SDA.1 |      | 1 |  3 || 4  |   |      | 5v      |     |     |
 |   3 |   9 |   SCL.1 |      | 1 |  5 || 6  |   |      | 0v      |     |     |
 |   4 |   7 | GPIO. 7 | 1wire| 0 |  7 || 8  | 0 |      | TxD     | 15  | 14  |
 |     |     |      0v |      |   |  9 || 10 | 1 |      | RxD     | 16  | 15  |
 |  17 |   0 | GPIO. 0 | 1RB1 | 0 | 11 || 12 | 0 |DHT-22| GPIO. 1 | 1   | 18  |
 |  27 |   2 | GPIO. 2 | 1RB2 | 0 | 13 || 14 |   |      | 0v      |     |     |
 |  22 |   3 | GPIO. 3 | 1RB3 | 0 | 15 || 16 | 0 |RF433R| GPIO. 4 | 4   | 23  |
 |     |     |    3.3v |      |   | 17 || 18 | 0 |      | GPIO. 5 | 5   | 24  |
 |  10 |  12 |    MOSI |      | 0 | 19 || 20 |   |      | 0v      |     |     |
 |   9 |  13 |    MISO |      | 0 | 21 || 22 | 0 |      | GPIO. 6 | 6   | 25  |
 |  11 |  14 |    SCLK |      | 0 | 23 || 24 | 1 |      | CE0     | 10  | 8   |
 |     |     |      0v |      |   | 25 || 26 | 1 |      | CE1     | 11  | 7   |
 |   0 |  30 |   SDA.0 |      | 1 | 27 || 28 | 1 |      | SCL.0   | 31  | 1   |
 |   5 |  21 | GPIO.21 | 1RB4 | 1 | 29 || 30 |   |      | 0v      |     |     |
 |   6 |  22 | GPIO.22 | 1RB5 | 0 | 31 || 32 | 0 | 2RB1 | GPIO.26 | 26  | 12  |
 |  13 |  23 | GPIO.23 | 1RB6 | 1 | 33 || 34 |   |      | 0v      |     |     |
 |  19 |  24 | GPIO.24 | 1RB7 | 1 | 35 || 36 | 0 | 2RB2 | GPIO.27 | 27  | 16  |
 |  26 |  25 | GPIO.25 | 1RB8 | 1 | 37 || 38 | 0 | 2RB3 | GPIO.28 | 28  | 20  |
 |     |     |      0v |      |   | 39 || 40 | 0 | 2RB4 | GPIO.29 | 29  | 21  |
 +-----+-----+---------+------+---+----++----+---+------+---------+-----+-----+
 | BCM | wPi |   Name  | Mode | V | Physical | V | Mode | Name    | wPi | BCM |
 +-----+-----+---------+------+---+---Pi 3B--+---+------+---------+-----+-----+

Elmer SDM360

pip install serial modbus_tk configparser pymodbus paho-mqtt

pouzivam upraveny kod odtud

sdm630-mqtt.py
#!/usr/bin/env python3
# -*- coding: utf_8 -*-

from sdm630 import *

import sys
import serial
import time
import paho.mqtt.client as mqtt
import logging
import os
import traceback
import configparser as ConfigParser
import time

CONFIG_FILE = '/usr/local/bin/sdm630_mqtt/sdm630-mqtt.conf'

logging.getLogger().setLevel(logging.WARNING)

# time.sleep(20)

def publish(topic,value):
        info = mqclient.publish("/".join((config.get("mqtt","topic_prefix"),topic)),value,qos=1)
        info.wait_for_publish()


if ((len(sys.argv) == 3) and sys.argv[1] == '-c'):
        CONFIG_FILE = sys.argv[2]
logging.info("Reading config...")
config = ConfigParser.ConfigParser()
confread = config.read(CONFIG_FILE)
logging.info("Read config {}".format(confread))


logging.info("Connecting to MQTT server...")
mqclient = mqtt.Client()
try:
        mqclient.connect(config.get("mqtt","server"),
                config.getint("mqtt","port"),
                config.getint("mqtt","keepalive"))
        mqclient.loop_start()
except:
        traceback.print_exc()
        logging.error("Cannot connect to MQTT server")
        sys.exit(1)

logging.info("Setup...")
num_meters = config.getint("sdm630","num_meters")
meters = []
#connection_type = config.get("sdm630", "connection_type")

#for i in range(num_meters):
#       if connection_type == 'tcp':
#               logging.info("Opening port {}".format(config.get("tcp","port")))
#               meter = SDM630TCP(host=config.get("tcp","host"),
#                       port=config.get("tcp","port"),
#                       aid=config.getint("sdm630","id"+str(i+1)),
#                       regfile=config.get("sdm630", "regfile"))
#       elif connection_type == 'rs485':
logging.info("Opening port {}".format(config.get("rs485","port")))
meter = SDM630RS485(config.get("rs485","PORT"),
config.getint("rs485","BAUDRATE"),
config.getint("sdm630","id"+str(+1)),
regfile=config.get("sdm630", "regfile"))
meters.append(meter)

logging.info("Entering endless loop")
while (True):
        for (num,sdm630) in enumerate(meters):
                num += 1
                publish(str(num)+"/voltage/all",str(sdm630.voltx3))
                publish(str(num)+"/current/all",str(sdm630.ampx3))
                publish(str(num)+"/power/all",str(sdm630.powx3))
                publish(str(num)+"/voltage/l1",sdm630.v1)
                publish(str(num)+"/voltage/l2",sdm630.v2)
                publish(str(num)+"/voltage/l3",sdm630.v3)
                publish(str(num)+"/current/l1",sdm630.a1)
                publish(str(num)+"/current/l2",sdm630.a2)
                publish(str(num)+"/current/l3",sdm630.a3)
                publish(str(num)+"/power/l1",sdm630.p1)
                publish(str(num)+"/power/l2",sdm630.p2)
                publish(str(num)+"/power/l3",sdm630.p3)
                publish(str(num)+"/power/total",sdm630.total_power)
                publish(str(num)+"/voltamps/l1",sdm630.va1)
                publish(str(num)+"/voltamps/l2",sdm630.va2)
                publish(str(num)+"/voltamps/l3",sdm630.va3)
                publish(str(num)+"/voltage/avg",sdm630.avg_voltage)
                publish(str(num)+"/current/avg",sdm630.avg_current)
                publish(str(num)+"/current/sum",sdm630.sum_current)
                publish(str(num)+"/frequency",sdm630.frequency)
                publish(str(num)+"/voltage/l1l2",sdm630.v1v2)
                publish(str(num)+"/voltage/l2l3",sdm630.v2v3)
                publish(str(num)+"/voltage/l3l1",sdm630.v3v1)
                publish(str(num)+"/curent/neutral",sdm630.neutral_current)
                publish(str(num)+"/wh/import",sdm630.import_wh)
                publish(str(num)+"/wh/export",sdm630.export_wh)
                publish(str(num)+"/time",time.time())
        time.sleep(1)

service je /lib/systemd/system/elmer.service

elmer.service
[Unit]
Description=My Script Service
#Wants=network-online.target
Requires=network.target
After=network.target
# After=multi-user.target

[Service]
Type=simple
ExecStart=/usr/bin/python /usr/local/bin/sdm630_mqtt/sdm630-mqtt.py
Restart=on-failure

[Install]
WantedBy=multi-user.target

relebord

apt install wiringpi

otestovat

gpio readall

DHT-22

napajeny 3v3

  • pouzivam gpio1
  • potrebujeme pipnout Adafruit-Python-DHT, paho-mqtt, configparser
dht22-mqtt.py
#!/usr/bin/env python2

import paho.mqtt.client as mqtt
import time
import Adafruit_DHT
from configparser import ConfigParser
import json

config = ConfigParser(delimiters=('=', ))
config.read('config.ini')

sensor_type = config['sensor'].get('type', 'dht22').lower()

if sensor_type == 'dht22':
    sensor = Adafruit_DHT.DHT22
elif sensor_type == 'dht11':
    sensor = Adafruit_DHT.dht11
elif sensor_type == 'am2302':
    sensor = Adafruit_DHT.AM2302
else:
    raise Exception('Supported sensor types: DHT22, DHT11, AM2302')

pin = config['sensor'].get('pin', 10)
topict = config['mqtt'].get('topic', 'temp/chodba')
topich = config['mqtt'].get('topic', 'humid/chodba')
decim_digits = config['sensor'].getint('decimal_digits', 4)

# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
    print("Connected with result code {}".format(rc))

client = mqtt.Client()
client.on_connect = on_connect
client.connect(config['mqtt'].get('hostname', 'homeassistant'),
               config['mqtt'].getint('port', 1883),
               config['mqtt'].getint('timeout', 60))
client.loop_start()

while True:
    time.sleep(3)
    humidity, temperature = Adafruit_DHT.read_retry(sensor, pin)
    if humidity is not None and temperature is not None:

        data = round(temperature, decim_digits)
        client.publish(topict, json.dumps(data))

        data = round(humidity, decim_digits)
        client.publish(topich, json.dumps(data))


        print('Published. Sleeping ...')
    else:
        print('Failed to get reading. Skipping ...')

kde je conf v config.ini

config.ini
[mqtt]

hostname = 10.133.1.41
port = 1883
timeout = 60
topict = temp/chodba
topich = humid/chodba
[sensor]

pin = 18
type = dht22
# interval = 3000000
decimal_digits = 4

sluzba je dht22.service

smarthome/newpi.txt · Poslední úprava: 2021/10/13 13:42 autor: mwk