Growatt/Grott proxy (async)

Build on top of asyncio.

Features:
- automatic inverter/data registers detection
- DTC (device type code) filter (optional)
- logging - log levels: debug, info, error etc.
- logging options: stdout/file
- command socket (see below)
- separate log file per datalogger/inverter (when logging to file)
- datalogger session
- server stats (on signal.SIGUSR1/kill -10)
- plugins: sync & async plugins
- optional orjson support (will be used if available)
Note that only a limited set of registers are supported at the moment. All definitions can be found in grott_async/utils/protocol.py
Usage:

grott-proxy [-c <config.ini>] [-w <work_dir>]

Plugins - async & sync. Each plugin must be an instance of GrottProxyASyncPlugin or GrottProxySyncPlugin. The plugin file must be placed in directory plugins relative to the working path (-w command switch or the directory from which grott-proxy is called). The variable in the file doesn't matter as long as it is unique for the respective plugin type. The data method of the class will be called with each data packet from every datalogger.

sync example:

import logging
from grott_async.extras.plugin import GrottProxySyncPlugin


class MyPlugin(GrottProxySyncPlugin):

    def __init__(self, x, y, z):
        self.x = x
        self.y = y
        self.z = z

    def show_data(self, data: dict):
        print(data)

    def data(self, packet: bytes, parsed_data: dict, log: logging.Logger):
        self.show_data(parsed_data)

cool_plugin_name = MyPlugin(1, 2, 3)

Command Socket

The proxy will create a listener (AF_INET, SOCK_STREAM) on 127.0.0.1:15279. The following commands are accepted:

list - list all data loggers currently connected to the proxy

read <logger serial> <register address> - read a specific register of a given data logger / inverter

set <logger serial> <register address> <register value> - set a value in specific register of a given inverter

Responses are returned by all commands. The responses from the inverter are filtered i.e. they are processed only by the proxy without being forwarded to the Growatt servers.

Examples:

~ # telnet 127.0.0.1 15279
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
list
XGD1821A81 | RJE3A22419 | 6
read XGD1821A81 0
Reg: 0 Value: 1

githubDante/grott-async

Growatt/Grott proxy (async)

Command Socket