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) |
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
+-----+-----+---------+------+---+---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--+---+------+---------+-----+-----+
pip install serial modbus_tk configparser pymodbus paho-mqtt
pouzivam upraveny kod odtud
#!/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
[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
apt install wiringpi
otestovat
gpio readall
napajeny 3v3
#!/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
[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