power_scraper.py

#!/usr/bin/python3

# Scrapes Inverter information from solax inverters and presents it to OpenEnergyMonitor
#
# Setup:
#   pip3 install toml twisted pymodbus influxdb_client
#   cp config-example.toml config.toml
#   vi config.toml
#
# Copyright (c)2018 Inferno Embedded   http://infernoembedded.com
#
# This program is free software: you can redistribute it and/or modify
#    it under the terms of the GNU General Public License as published by
#    the Free Software Foundation, either version 3 of the License, or
#    (at your option) any later version.
#
#    This program is distributed in the hope that it will be useful,
#    but WITHOUT ANY WARRANTY; without even the implied warranty of
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
#    GNU General Public License for more details.
#
#    You should have received a copy of the GNU General Public License
#    along with this program.  If not, see <https://www.gnu.org/licenses/>.

import toml
from twisted.internet import task, reactor
#from twisted.internet.protocol import Protocol
from twisted.logger import globalLogPublisher

import logging
logging.basicConfig()
# log = logging.getLogger()
# log.setLevel(logging.DEBUG)

import traceback

from Inputs.SolaxWifi import SolaxWifi
from Inputs.SolaxModbus import SolaxModbus
from Inputs.SolaxXHybridModbus import SolaxXHybridModbus
from Inputs.SDM630ModbusV2 import SDM630ModbusV2
from Inputs.DTSU666Modbus import DTSU666Modbus
from Inputs.SolaxX3RS485 import SolaxX3RS485
from Outputs.SolaxBatteryControl import SolaxBatteryControl
from Outputs.EmonCMS import EmonCMS
from Outputs.Influx2 import Influx2

from twisted.internet.defer import setDebugging
setDebugging(True)

from twisted.logger._levels import LogLevel

def analyze(event):
    if event.get("log_level") == LogLevel.critical:
        print("Critical: ", event)

def outputActions(vals, batteryAPI):
    global outputs
    if outputs is None:
        return

    for output in outputs:
        output.send(vals, batteryAPI)

def inputActions(inputs):
    for input in inputs:
        input.fetch(outputActions)

def shutdown():
    print("Shutdown")
    global SolaxModbusInverters
    for inverter in SolaxModbusInverters:
        inverter.shutdown()


globalLogPublisher.addObserver(analyze)

with open("config.toml") as conffile:
    global config
    config = toml.loads(conffile.read())

#     pp.pprint(config)

global outputs
outputs = []

global SolaxModbusInverters
SolaxModbusInverters = []



if 'emoncms' in config:
    print("Setting up EmonCMS")
    outputs.append(EmonCMS(config['emoncms']))

if 'influx' in config:
    print("Setting up Influx")
    outputs.append(Influx2(config['influx']))

if 'Solax-BatteryControl' in config:
    print("Setting up Solax-BatteryControl")
    outputs.append(SolaxBatteryControl(config['Solax-BatteryControl']))

if 'Solax-Wifi' in config:
    print("Setting up Solax-Wifi")
    SolaxWifiInverters = []
    for inverter in config['Solax-Wifi']['inverters']:
        wifiInverter = SolaxWifi(inverter, config['solax-Wifi']['timeout'])
        SolaxWifiInverters.append(wifiInverter)

    looperSolaxWifi = task.LoopingCall(inputActions, SolaxWifiInverters)
    looperSolaxWifi.start(config['Solax-Wifi']['poll_period'])

if 'Solax-Modbus' in config:
    print("Setting up Solax-Modbus")
    SolaxModbusInverters = []
    for inverter in config['Solax-Modbus']['inverters']:
        modbusInverter = SolaxModbus(config, inverter)
        SolaxModbusInverters.append(modbusInverter)

    looperSolaxModbus = task.LoopingCall(inputActions, SolaxModbusInverters)
    looperSolaxModbus.start(config['Solax-Modbus']['poll_period'])

if 'Solax-XHybrid-Modbus' in config:
    print("Setting up Solax-XHybrid-Modbus")
    SolaxXHybridModbusInverters = []
    for inverter in config['Solax-XHybrid-Modbus']['inverters']:
        modbusInverter = SolaxXHybridModbus(config, inverter)
        SolaxXHybridModbusInverters.append(modbusInverter)

    looperSolaxXHybridModbus = task.LoopingCall(inputActions, SolaxXHybridModbusInverters)
    looperSolaxXHybridModbus.start(config['Solax-XHybrid-Modbus']['poll_period'])

if 'SDM630ModbusV2' in config:
    print("Setting up SDM630ModbusV2")
    SDM630Meters = []
    for meter in config['SDM630ModbusV2']['ports']:
        modbusMeter = SDM630ModbusV2(meter, config['SDM630ModbusV2']['baud'], config['SDM630ModbusV2']['parity'],
                                 config['SDM630ModbusV2']['stopbits'], config['SDM630ModbusV2']['timeout'])
        SDM630Meters.append(modbusMeter)

    looperSDM630 = task.LoopingCall(inputActions, SDM630Meters)
    looperSDM630.start(config['SDM630ModbusV2']['poll_period'])

if 'DTSU666' in config:
    print("Setting up DTSU666")
    DTSU666Meters = []
    for meter in config['DTSU666']['ports']:
        modbusMeter = DTSU666Modbus(meter, config['DTSU666']['baud'], config['DTSU666']['parity'],
                                 config['DTSU666']['stopbits'], config['DTSU666']['timeout'])
        DTSU666Meters.append(modbusMeter)

    looperDTSU666 = task.LoopingCall(inputActions, DTSU666Meters)
    looperDTSU666.start(config['DTSU666']['poll_period'])

if 'SolaxX3RS485' in config:
    print("Setting up SolaxX3RS485")
    SolaxRS485Meters = []
    for meter in config['SolaxX3RS485']['ports']:
        modbusMeter = SolaxX3RS485(meter, config['SolaxX3RS485']['baud'], config['SolaxX3RS485']['parity'],
                                 config['SolaxX3RS485']['stopbits'], config['SolaxX3RS485']['timeout'])
        SolaxRS485Meters.append(modbusMeter)

    looperSolaxRS485 = task.LoopingCall(inputActions, SolaxRS485Meters)
    looperSolaxRS485.start(config['SolaxX3RS485']['poll_period'])

reactor.addSystemEventTrigger('before', 'shutdown', shutdown)

reactor.run()