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