gridrelay.py

import time
from pvinflux import PvInflux
from pvoutputorg import PvOutputOrg
from pvconf import PvConf
from gridkenter import GridKenter
from pvmqtt import PvMqtt


class GridRelay:
    def __init__(self, conf: PvConf, logger):
        self.conf = conf
        self.logger = logger
        self.logger.debug("GridRelay class instantiated")

        self.gridkenter = GridKenter(conf, logger)
        self.pvoutput = PvOutputOrg(conf, logger)
        self.pvmqtt = PvMqtt(conf, logger)
        self.pvinflux = PvInflux(self.conf, self.logger)
        self.pvinflux_initialized = False

        self.logger.info("Starting GridRelay on separate thread")
        self.start()

    def start(self):
        self.logger.debug("GridRelay waiting 5sec to initialize docker-compose containers")
        time.sleep(5)

        while 1:
            try:
                grid_measurement_data = self.gridkenter.fetch_gridkenter_data(self.conf.gridrelaydaysback)
                self.write_gridkenter_to_influxdb(grid_measurement_data)
                self.write_gridkenter_to_pvoutput(grid_measurement_data)
            except:
                self.logger.exception(
                    "Uncaught exception in GridRelay data processing loop."
                )

            self.logger.debug("Waiting for next interval...")
            time.sleep(self.conf.gridrelayinterval)

    def write_gridkenter_to_pvoutput(self, grid_measurement_data):
        if self.conf.pvoutput:
            try:
                self.pvoutput.write_griddata_to_pvoutput(grid_measurement_data)
            except:
                self.logger.exception("Error writing GridData to PVOutput.org")

    def write_gridkenter_to_influxdb(self, grid_measurement_data):
        if self.conf.influx:
            if self.pvinflux_initialized == False:
                self.pvinflux_initialized = self.pvinflux.initialize()

            if self.pvinflux_initialized:
                self.pvinflux.pvinflux_write_griddata(grid_measurement_data)
        else:
            self.logger.debug("Writing data to Influx skipped, not initialized yet.")