mqtt in venv delivers only sometimes some values

[RookieRon]

I like this program because I just need a simple translator from PIP5048GK-speech to MQTT.

Problem:
When I use
"mpp-solar -p /dev/ttyUSB0 -c QPIGS -o mqtt -q 192.168.178.84 --mqttuser user --mqttpass pass"

it gives no values to broker and this message:
WARNING:mqtt_manager:_publish_loop@310: Cannot publish to PIP5048GK/status/ac_input_voltage/value - not connected

in debug mode it suddenly delivers some values (it depends and varies from 4 to 8 proper values) and gives the output below.
Is someone able to help here? It seems like some timing problem, right?

2025-07-22 18:30:19,912:INFO:init:main@248: Solar Device Command Utility, version: 0.16.56-dev, python version: 3.12.3
2025-07-22 18:30:19,912:DEBUG:init:log_debug_context@322: [SYSTEM] sys.argv = ['/home/raspi/venv/mppsolar/bin/mppsolar', '-o', 'mqtt', '-c', 'QPIGS', '-T', 'PIP5048GK', '-q', '192.168.178.84', '--mqttuser', 'user', '--mqttpass', 'pass', '-D']
2025-07-22 18:30:19,912:DEBUG:init:log_debug_context@323: [SYSTEM] args.daemon = False
2025-07-22 18:30:19,912:DEBUG:init:log_debug_context@324: [SYSTEM] args.debug = True
2025-07-22 18:30:19,912:DEBUG:mqttbroker_legacy:init@19: mqttbroker config: {'name': '192.168.178.84', 'port': 1883, 'user': 'user', 'pass': 'pass'}
2025-07-22 18:30:19,912:DEBUG:init:main@437: MqttBroker name: 192.168.178.84, port: 1883, user: user
2025-07-22 18:30:19,912:DEBUG:init:main@439: udp port 5555
2025-07-22 18:30:19,913:DEBUG:init:main@441: Using Postgres None
2025-07-22 18:30:19,913:DEBUG:init:main@444: Using Mongo None with mppsolar
2025-07-22 18:30:19,913:INFO:init:main@555: Creating device "unnamed" (type: "mppsolar") on port "/dev/ttyUSB0 (porttype=None)" using protocol "PI30"
2025-07-22 18:30:19,917:DEBUG:init:main@559: device_class <class 'mppsolar.devices.mppsolar.mppsolar'>
2025-07-22 18:30:19,917:DEBUG:device:init@29: init args ()
2025-07-22 18:30:19,917:DEBUG:device:init@30: init kwargs {'name': 'unnamed', 'port': '/dev/ttyUSB0', 'protocol': 'PI30', 'baud': 2400, 'porttype': None, 'mqtt_broker': <mppsolar.libs.mqttbroker_legacy.MqttBroker object at 0x761cc841a1e0>, 'udp_port': 5555, 'mongo_url': None, 'mongo_db': 'mppsolar', 'push_url': 'http://localhost:9091/metrics/job/pushgateway', 'prom_output_dir': '/var/lib/node_exporter'}
2025-07-22 18:30:19,917:DEBUG:init:get_port_type@73: port matches ttyusb
2025-07-22 18:30:19,917:INFO:init:get_port@115: Using serialio for communications
2025-07-22 18:30:19,926:DEBUG:init:get_protocol@13: Protocol PI30
2025-07-22 18:30:20,292:DEBUG:device:init@34: init name unnamed, port <mppsolar.inout.serialio.SerialIO object at 0x761cc79bac60>, protocol PI30 protocol handler
2025-07-22 18:30:20,292:DEBUG:init:main@605: Commands [(<mppsolar.devices.mppsolar.mppsolar object at 0x761cc858f830>, 'QPIGS', 'PIP5048GK', 'mqtt', None, None, None)]
2025-07-22 18:30:20,292:INFO:init:setup_daemon_if_requested@383: Daemon mode NOT requested. Using DISABLED daemon.
2025-07-22 18:30:20,293:INFO:init:main@612: Daemon DISABLED
2025-07-22 18:30:20,294:DEBUG:daemon:initialize@146: Base Daemon initialized
2025-07-22 18:30:20,294:DEBUG:daemon_disabled:_dummyNotify@31: DaemonDummy notified: args=(<DummyNotification.READY: 'READY'>,), kwargs={}
2025-07-22 18:30:20,294:INFO:init:log_process_info@311: [AFTER_DAEMON_INITIALIZE] PID: 12469, PPID: 3400, PGID: 12469, SID: 3400, Leader: True
2025-07-22 18:30:20,295:INFO:init:log_process_info@317: [AFTER_DAEMON_INITIALIZE] Command: /home/raspi/venv/mppsolar/bin/python3 /home/raspi/venv/mppsolar/bin/mppsolar -o mqtt -c QPIGS -T PIP5048GK -q 192.168.178.84 --mqttuser user --mqttpass pass -D
2025-07-22 18:30:20,295:INFO:mqtt_manager:start_all@378: Started 0 MQTT connections
2025-07-22 18:30:20,295:DEBUG:daemon_disabled:_dummyNotify@31: DaemonDummy notified: args=(<DummyNotification.STATUS: 'STATUS'>, 'Service Initializing ...'), kwargs={}
2025-07-22 18:30:20,295:INFO:init:log_process_info@311: [AFTER_DAEMON_NOTIFY] PID: 12469, PPID: 3400, PGID: 12469, SID: 3400, Leader: True
2025-07-22 18:30:20,295:INFO:init:log_process_info@317: [AFTER_DAEMON_NOTIFY] Command: /home/raspi/venv/mppsolar/bin/python3 /home/raspi/venv/mppsolar/bin/mppsolar -o mqtt -c QPIGS -T PIP5048GK -q 192.168.178.84 --mqttuser user --mqttpass pass -D
2025-07-22 18:30:20,296:INFO:init:main@627: Looping 1 commands
2025-07-22 18:30:20,296:DEBUG:daemon:watchdog@155: Base Daemon watchdog ping
2025-07-22 18:30:20,296:DEBUG:daemon_disabled:_dummyNotify@31: DaemonDummy notified: args=(<DummyNotification.STATUS: 'STATUS'>, 'Getting results from device: mppsolar device - name: unnamed, port: <mppsolar.inout.serialio.SerialIO object at 0x761cc79bac60>, protocol: PI30 protocol handler for command: QPIGS, tag: PIP5048GK, outputs: mqtt'), kwargs={}
2025-07-22 18:30:20,296:INFO:init:main@633: Getting results from device: mppsolar device - name: unnamed, port: <mppsolar.inout.serialio.SerialIO object at 0x761cc79bac60>, protocol: PI30 protocol handler for command: QPIGS, tag: PIP5048GK, outputs: mqtt
2025-07-22 18:30:20,296:INFO:device:run_command@46: Running command QPIGS
2025-07-22 18:30:20,296:INFO:abstractprotocol:get_full_command@61: Using protocol b'PI30' with 45 commands
2025-07-22 18:30:20,297:DEBUG:protocol_helpers:crcPI@308: Calculating CRC for b'QPIGS'
2025-07-22 18:30:20,297:DEBUG:protocol_helpers:crcPI@358: Generated CRC 0xb7 0xa9 0xb7a9
2025-07-22 18:30:20,297:DEBUG:abstractprotocol:get_full_command@67: full command: b'QPIGS\xb7\xa9\r'
2025-07-22 18:30:20,297:INFO:device:run_command@78: Full command b'QPIGS\xb7\xa9\r' for command QPIGS
2025-07-22 18:30:20,297:DEBUG:device:_send_command_with_retry@124: Command attempt 1/3 for QPIGS
2025-07-22 18:30:20,297:DEBUG:abstractprotocol:get_command_defn@71: Processing command 'QPIGS'
2025-07-22 18:30:20,297:DEBUG:abstractprotocol:get_command_defn@73: Found command QPIGS in protocol b'PI30'
2025-07-22 18:30:20,297:DEBUG:serialio:send_and_receive@19: port /dev/ttyUSB0, baudrate 2400
2025-07-22 18:30:20,300:DEBUG:serialio:send_and_receive@22: Executing command via serialio...
2025-07-22 18:30:20,797:DEBUG:serialio:send_and_receive@30: serial response was: b'(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r'
2025-07-22 18:30:20,798:DEBUG:device:run_command@92: Send and Receive Response b'(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r'
2025-07-22 18:30:20,799:DEBUG:abstractprotocol:decode@244: response passed to decode: b'(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r'
2025-07-22 18:30:20,799:DEBUG:abstractprotocol:get_command_defn@71: Processing command 'QPIGS'
2025-07-22 18:30:20,799:DEBUG:abstractprotocol:get_command_defn@73: Found command QPIGS in protocol b'PI30'
2025-07-22 18:30:20,799:DEBUG:protocol_helpers:crcPI@308: Calculating CRC for b'(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010'
2025-07-22 18:30:20,799:DEBUG:protocol_helpers:crcPI@358: Generated CRC 0x6e 0x30 0x6e30
2025-07-22 18:30:20,800:DEBUG:pi30:check_response_valid@1030: CRCs match
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:decode@289: Processing response of type INDEXED
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:decode@293: trimmed and split responses: [b'000.0', b'00.0', b'228.1', b'50.0', b'0364', b'0150', b'007', b'420', b'50.60', b'000', b'044', b'0024', b'00.3', b'390.8', b'00.00', b'00000', b'00010000', b'00', b'00', b'00156', b'010']
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:decode@492: Got defn [0, 'AC Input Voltage', 'float', 'V', {'icon': 'mdi:lightning'}]
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: AC Input Voltage, raw_value b'000.0'
2025-07-22 18:30:20,800:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,803:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,803:DEBUG:abstractprotocol:decode@492: Got defn [1, 'AC Input Frequency', 'float', 'Hz']
2025-07-22 18:30:20,803:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: AC Input Frequency, raw_value b'00.0'
2025-07-22 18:30:20,804:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,804:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,804:DEBUG:abstractprotocol:decode@492: Got defn [2, 'AC Output Voltage', 'float', 'V']
2025-07-22 18:30:20,804:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: AC Output Voltage, raw_value b'228.1'
2025-07-22 18:30:20,804:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,805:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,805:DEBUG:abstractprotocol:decode@492: Got defn [3, 'AC Output Frequency', 'float', 'Hz']
2025-07-22 18:30:20,805:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: AC Output Frequency, raw_value b'50.0'
2025-07-22 18:30:20,805:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,805:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,809:DEBUG:abstractprotocol:decode@492: Got defn [4, 'AC Output Apparent Power', 'int', 'VA']
2025-07-22 18:30:20,809:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: AC Output Apparent Power, raw_value b'0364'
2025-07-22 18:30:20,809:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,810:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,810:DEBUG:abstractprotocol:decode@492: Got defn [5, 'AC Output Active Power', 'int', 'W']
2025-07-22 18:30:20,810:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: AC Output Active Power, raw_value b'0150'
2025-07-22 18:30:20,810:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,810:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,811:DEBUG:abstractprotocol:decode@492: Got defn [6, 'AC Output Load', 'int', '%']
2025-07-22 18:30:20,811:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: AC Output Load, raw_value b'007'
2025-07-22 18:30:20,811:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,811:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,812:DEBUG:abstractprotocol:decode@492: Got defn [7, 'BUS Voltage', 'int', 'V']
2025-07-22 18:30:20,812:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: BUS Voltage, raw_value b'420'
2025-07-22 18:30:20,812:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,812:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,814:DEBUG:abstractprotocol:decode@492: Got defn [8, 'Battery Voltage', 'float', 'V']
2025-07-22 18:30:20,815:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: Battery Voltage, raw_value b'50.60'
2025-07-22 18:30:20,815:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,818:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,818:DEBUG:abstractprotocol:decode@492: Got defn [9, 'Battery Charging Current', 'int', 'A']
2025-07-22 18:30:20,818:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: Battery Charging Current, raw_value b'000'
2025-07-22 18:30:20,818:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,819:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,819:DEBUG:abstractprotocol:decode@492: Got defn [10, 'Battery Capacity', 'int', '%']
2025-07-22 18:30:20,819:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: Battery Capacity, raw_value b'044'
2025-07-22 18:30:20,819:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,820:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,820:DEBUG:abstractprotocol:decode@492: Got defn [11, 'Inverter Heat Sink Temperature', 'int', '°C']
2025-07-22 18:30:20,820:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: Inverter Heat Sink Temperature, raw_value b'0024'
2025-07-22 18:30:20,820:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,820:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,821:DEBUG:abstractprotocol:decode@492: Got defn [12, 'PV Input Current for Battery', 'float', 'A']
2025-07-22 18:30:20,821:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: PV Input Current for Battery, raw_value b'00.3'
2025-07-22 18:30:20,821:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,821:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,823:DEBUG:abstractprotocol:decode@492: Got defn [13, 'PV Input Voltage', 'float', 'V']
2025-07-22 18:30:20,823:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: PV Input Voltage, raw_value b'390.8'
2025-07-22 18:30:20,823:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,823:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,824:DEBUG:abstractprotocol:decode@492: Got defn [14, 'Battery Voltage from SCC', 'float', 'V']
2025-07-22 18:30:20,824:DEBUG:abstractprotocol:process_response@118: Processing data_type: float for data_name: Battery Voltage from SCC, raw_value b'00.00'
2025-07-22 18:30:20,824:DEBUG:abstractprotocol:process_response@209: Processing format string: 'float(raw_value)'
2025-07-22 18:30:20,824:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,824:DEBUG:abstractprotocol:decode@492: Got defn [15, 'Battery Discharge Current', 'int', 'A']
2025-07-22 18:30:20,825:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: Battery Discharge Current, raw_value b'00000'
2025-07-22 18:30:20,825:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,825:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,827:DEBUG:abstractprotocol:decode@492: Got defn [16, 'Device Status', 'flags', ['Is SBU Priority Version Added', 'Is Configuration Changed', 'Is SCC Firmware Updated', 'Is Load On', 'Is Battery Voltage to Steady While Charging', 'Is Charging On', 'Is SCC Charging On', 'Is AC Charging On']]
2025-07-22 18:30:20,827:DEBUG:abstractprotocol:process_response@118: Processing data_type: flags for data_name: Device Status, raw_value b'00010000'
2025-07-22 18:30:20,827:DEBUG:abstractprotocol:process_response@150: flags defn
2025-07-22 18:30:20,827:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,828:DEBUG:abstractprotocol:decode@492: Got defn [17, 'RSV1', 'int', 'A']
2025-07-22 18:30:20,828:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: RSV1, raw_value b'00'
2025-07-22 18:30:20,828:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,829:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,829:DEBUG:abstractprotocol:decode@492: Got defn [18, 'RSV2', 'int', 'A']
2025-07-22 18:30:20,829:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: RSV2, raw_value b'00'
2025-07-22 18:30:20,829:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,830:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,830:DEBUG:abstractprotocol:decode@492: Got defn [19, 'PV Input Power', 'int', 'W']
2025-07-22 18:30:20,830:DEBUG:abstractprotocol:process_response@118: Processing data_type: int for data_name: PV Input Power, raw_value b'00156'
2025-07-22 18:30:20,830:DEBUG:abstractprotocol:process_response@209: Processing format string: 'int(raw_value)'
2025-07-22 18:30:20,831:DEBUG:abstractprotocol:decode@472: Processing INDEXED type responses
2025-07-22 18:30:20,832:DEBUG:abstractprotocol:decode@492: Got defn [20, 'Device Status2', 'flags', ['Is Charging to Float', 'Is Switched On', 'Is Reserved']]
2025-07-22 18:30:20,833:DEBUG:abstractprotocol:process_response@118: Processing data_type: flags for data_name: Device Status2, raw_value b'010'
2025-07-22 18:30:20,833:DEBUG:abstractprotocol:process_response@150: flags defn
2025-07-22 18:30:20,833:INFO:device:run_command@103: Decoded response {'_command': 'QPIGS', '_command_description': 'General Status Parameters inquiry', 'raw_response': ['(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r', ''], 'AC Input Voltage': [0.0, 'V', {'icon': 'mdi:lightning'}], 'AC Input Frequency': [0.0, 'Hz'], 'AC Output Voltage': [228.1, 'V'], 'AC Output Frequency': [50.0, 'Hz'], 'AC Output Apparent Power': [364, 'VA'], 'AC Output Active Power': [150, 'W'], 'AC Output Load': [7, '%'], 'BUS Voltage': [420, 'V'], 'Battery Voltage': [50.6, 'V'], 'Battery Charging Current': [0, 'A'], 'Battery Capacity': [44, '%'], 'Inverter Heat Sink Temperature': [24, '°C'], 'PV Input Current for Battery': [0.3, 'A'], 'PV Input Voltage': [390.8, 'V'], 'Battery Voltage from SCC': [0.0, 'V'], 'Battery Discharge Current': [0, 'A'], 'Is SBU Priority Version Added': [0, 'bool'], 'Is Configuration Changed': [0, 'bool'], 'Is SCC Firmware Updated': [0, 'bool'], 'Is Load On': [1, 'bool'], 'Is Battery Voltage to Steady While Charging': [0, 'bool'], 'Is Charging On': [0, 'bool'], 'Is SCC Charging On': [0, 'bool'], 'Is AC Charging On': [0, 'bool'], 'RSV1': [0, 'A'], 'RSV2': [0, 'A'], 'PV Input Power': [156, 'W'], 'Is Charging to Float': [0, 'bool'], 'Is Switched On': [1, 'bool'], 'Is Reserved': [0, 'bool']}
2025-07-22 18:30:20,834:DEBUG:init:main@635: results: {'_command': 'QPIGS', '_command_description': 'General Status Parameters inquiry', 'raw_response': ['(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r', ''], 'AC Input Voltage': [0.0, 'V', {'icon': 'mdi:lightning'}], 'AC Input Frequency': [0.0, 'Hz'], 'AC Output Voltage': [228.1, 'V'], 'AC Output Frequency': [50.0, 'Hz'], 'AC Output Apparent Power': [364, 'VA'], 'AC Output Active Power': [150, 'W'], 'AC Output Load': [7, '%'], 'BUS Voltage': [420, 'V'], 'Battery Voltage': [50.6, 'V'], 'Battery Charging Current': [0, 'A'], 'Battery Capacity': [44, '%'], 'Inverter Heat Sink Temperature': [24, '°C'], 'PV Input Current for Battery': [0.3, 'A'], 'PV Input Voltage': [390.8, 'V'], 'Battery Voltage from SCC': [0.0, 'V'], 'Battery Discharge Current': [0, 'A'], 'Is SBU Priority Version Added': [0, 'bool'], 'Is Configuration Changed': [0, 'bool'], 'Is SCC Firmware Updated': [0, 'bool'], 'Is Load On': [1, 'bool'], 'Is Battery Voltage to Steady While Charging': [0, 'bool'], 'Is Charging On': [0, 'bool'], 'Is SCC Charging On': [0, 'bool'], 'Is AC Charging On': [0, 'bool'], 'RSV1': [0, 'A'], 'RSV2': [0, 'A'], 'PV Input Power': [156, 'W'], 'Is Charging to Float': [0, 'bool'], 'Is Switched On': [1, 'bool'], 'Is Reserved': [0, 'bool']}
2025-07-22 18:30:20,834:INFO:init:get_output@40: attempting to create output processor: mqtt
2025-07-22 18:30:20,836:DEBUG:mqtt:init@16: init: kwargs {}
2025-07-22 18:30:20,836:DEBUG:init:main@641: Using output filter: None
2025-07-22 18:30:20,837:INFO:mqtt:output@91: Using output processor: mqtt
2025-07-22 18:30:20,837:DEBUG:mqtt:output@92: kwargs {'data': {'_command': 'QPIGS', '_command_description': 'General Status Parameters inquiry', 'raw_response': ['(000.0 00.0 228.1 50.0 0364 0150 007 420 50.60 000 044 0024 00.3 390.8 00.00 00000 00010000 00 00 00156 010n0\r', ''], 'AC Input Voltage': [0.0, 'V', {'icon': 'mdi:lightning'}], 'AC Input Frequency': [0.0, 'Hz'], 'AC Output Voltage': [228.1, 'V'], 'AC Output Frequency': [50.0, 'Hz'], 'AC Output Apparent Power': [364, 'VA'], 'AC Output Active Power': [150, 'W'], 'AC Output Load': [7, '%'], 'BUS Voltage': [420, 'V'], 'Battery Voltage': [50.6, 'V'], 'Battery Charging Current': [0, 'A'], 'Battery Capacity': [44, '%'], 'Inverter Heat Sink Temperature': [24, '°C'], 'PV Input Current for Battery': [0.3, 'A'], 'PV Input Voltage': [390.8, 'V'], 'Battery Voltage from SCC': [0.0, 'V'], 'Battery Discharge Current': [0, 'A'], 'Is SBU Priority Version Added': [0, 'bool'], 'Is Configuration Changed': [0, 'bool'], 'Is SCC Firmware Updated': [0, 'bool'], 'Is Load On': [1, 'bool'], 'Is Battery Voltage to Steady While Charging': [0, 'bool'], 'Is Charging On': [0, 'bool'], 'Is SCC Charging On': [0, 'bool'], 'Is AC Charging On': [0, 'bool'], 'RSV1': [0, 'A'], 'RSV2': [0, 'A'], 'PV Input Power': [156, 'W'], 'Is Charging to Float': [0, 'bool'], 'Is Switched On': [1, 'bool'], 'Is Reserved': [0, 'bool']}, 'tag': 'PIP5048GK', 'name': 'unnamed', 'mqtt_broker': <mppsolar.libs.mqttbroker_legacy.MqttBroker object at 0x761cc841a1e0>, 'udp_port': 5555, 'postgres_url': None, 'mongo_url': None, 'mongo_db': 'mppsolar', 'push_url': 'http://localhost:9091/metrics/job/pushgateway', 'prom_output_dir': '/var/lib/node_exporter', 'mqtt_topic': None, 'filter': None, 'excl_filter': None, 'keep_case': False, 'dev': None}
2025-07-22 18:30:20,839:DEBUG:mqtt:build_msgs@71: output data: {'ac_input_voltage': [0.0, 'V', {'icon': 'mdi:lightning'}], 'ac_input_frequency': [0.0, 'Hz'], 'ac_output_voltage': [228.1, 'V'], 'ac_output_frequency': [50.0, 'Hz'], 'ac_output_apparent_power': [364, 'VA'], 'ac_output_active_power': [150, 'W'], 'ac_output_load': [7, '%'], 'bus_voltage': [420, 'V'], 'battery_voltage': [50.6, 'V'], 'battery_charging_current': [0, 'A'], 'battery_capacity': [44, '%'], 'inverter_heat_sink_temperature': [24, '°C'], 'pv_input_current_for_battery': [0.3, 'A'], 'pv_input_voltage': [390.8, 'V'], 'battery_voltage_from_scc': [0.0, 'V'], 'battery_discharge_current': [0, 'A'], 'is_sbu_priority_version_added': [0, 'bool'], 'is_configuration_changed': [0, 'bool'], 'is_scc_firmware_updated': [0, 'bool'], 'is_load_on': [1, 'bool'], 'is_battery_voltage_to_steady_while_charging': [0, 'bool'], 'is_charging_on': [0, 'bool'], 'is_scc_charging_on': [0, 'bool'], 'is_ac_charging_on': [0, 'bool'], 'rsv1': [0, 'A'], 'rsv2': [0, 'A'], 'pv_input_power': [156, 'W'], 'is_charging_to_float': [0, 'bool'], 'is_switched_on': [1, 'bool'], 'is_reserved': [0, 'bool']}
2025-07-22 18:30:20,839:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_input_voltage, value 0.0, unit V
2025-07-22 18:30:20,839:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_input_frequency, value 0.0, unit Hz
2025-07-22 18:30:20,839:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_output_voltage, value 228.1, unit V
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_output_frequency, value 50.0, unit Hz
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_output_apparent_power, value 364, unit VA
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_output_active_power, value 150, unit W
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key ac_output_load, value 7, unit %
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key bus_voltage, value 420, unit V
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key battery_voltage, value 50.6, unit V
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key battery_charging_current, value 0, unit A
2025-07-22 18:30:20,840:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key battery_capacity, value 44, unit %
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key inverter_heat_sink_temperature, value 24, unit °C
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key pv_input_current_for_battery, value 0.3, unit A
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key pv_input_voltage, value 390.8, unit V
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key battery_voltage_from_scc, value 0.0, unit V
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key battery_discharge_current, value 0, unit A
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_sbu_priority_version_added, value 0, unit bool
2025-07-22 18:30:20,841:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_configuration_changed, value 0, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_scc_firmware_updated, value 0, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_load_on, value 1, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_battery_voltage_to_steady_while_charging, value 0, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_charging_on, value 0, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_scc_charging_on, value 0, unit bool
2025-07-22 18:30:20,842:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_ac_charging_on, value 0, unit bool
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key rsv1, value 0, unit A
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key rsv2, value 0, unit A
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key pv_input_power, value 156, unit W
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_charging_to_float, value 0, unit bool
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_switched_on, value 1, unit bool
2025-07-22 18:30:20,843:DEBUG:mqtt:build_msgs@79: build_msgs: prefix PIP5048GK/status, key is_reserved, value 0, unit bool
2025-07-22 18:30:20,846:DEBUG:mqtt:build_msgs@87: build_msgs: [{'topic': 'PIP5048GK/status/ac_input_voltage/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/ac_input_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/ac_input_frequency/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/ac_input_frequency/unit', 'payload': 'Hz'}, {'topic': 'PIP5048GK/status/ac_output_voltage/value', 'payload': 228.1}, {'topic': 'PIP5048GK/status/ac_output_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/ac_output_frequency/value', 'payload': 50.0}, {'topic': 'PIP5048GK/status/ac_output_frequency/unit', 'payload': 'Hz'}, {'topic': 'PIP5048GK/status/ac_output_apparent_power/value', 'payload': 364}, {'topic': 'PIP5048GK/status/ac_output_apparent_power/unit', 'payload': 'VA'}, {'topic': 'PIP5048GK/status/ac_output_active_power/value', 'payload': 150}, {'topic': 'PIP5048GK/status/ac_output_active_power/unit', 'payload': 'W'}, {'topic': 'PIP5048GK/status/ac_output_load/value', 'payload': 7}, {'topic': 'PIP5048GK/status/ac_output_load/unit', 'payload': '%'}, {'topic': 'PIP5048GK/status/bus_voltage/value', 'payload': 420}, {'topic': 'PIP5048GK/status/bus_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_voltage/value', 'payload': 50.6}, {'topic': 'PIP5048GK/status/battery_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_charging_current/value', 'payload': 0}, {'topic': 'PIP5048GK/status/battery_charging_current/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/battery_capacity/value', 'payload': 44}, {'topic': 'PIP5048GK/status/battery_capacity/unit', 'payload': '%'}, {'topic': 'PIP5048GK/status/inverter_heat_sink_temperature/value', 'payload': 24}, {'topic': 'PIP5048GK/status/inverter_heat_sink_temperature/unit', 'payload': '°C'}, {'topic': 'PIP5048GK/status/pv_input_current_for_battery/value', 'payload': 0.3}, {'topic': 'PIP5048GK/status/pv_input_current_for_battery/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/pv_input_voltage/value', 'payload': 390.8}, {'topic': 'PIP5048GK/status/pv_input_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_voltage_from_scc/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/battery_voltage_from_scc/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_discharge_current/value', 'payload': 0}, {'topic': 'PIP5048GK/status/battery_discharge_current/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/is_sbu_priority_version_added/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_sbu_priority_version_added/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_configuration_changed/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_configuration_changed/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_scc_firmware_updated/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_scc_firmware_updated/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_load_on/value', 'payload': 1}, {'topic': 'PIP5048GK/status/is_load_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_battery_voltage_to_steady_while_charging/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_battery_voltage_to_steady_while_charging/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_scc_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_scc_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_ac_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_ac_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/rsv1/value', 'payload': 0}, {'topic': 'PIP5048GK/status/rsv1/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/rsv2/value', 'payload': 0}, {'topic': 'PIP5048GK/status/rsv2/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/pv_input_power/value', 'payload': 156}, {'topic': 'PIP5048GK/status/pv_input_power/unit', 'payload': 'W'}, {'topic': 'PIP5048GK/status/is_charging_to_float/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_charging_to_float/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_switched_on/value', 'payload': 1}, {'topic': 'PIP5048GK/status/is_switched_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_reserved/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_reserved/unit', 'payload': 'bool'}]
2025-07-22 18:30:20,846:DEBUG:mqtt:output@109: mqtt.output msgs [{'topic': 'PIP5048GK/status/ac_input_voltage/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/ac_input_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/ac_input_frequency/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/ac_input_frequency/unit', 'payload': 'Hz'}, {'topic': 'PIP5048GK/status/ac_output_voltage/value', 'payload': 228.1}, {'topic': 'PIP5048GK/status/ac_output_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/ac_output_frequency/value', 'payload': 50.0}, {'topic': 'PIP5048GK/status/ac_output_frequency/unit', 'payload': 'Hz'}, {'topic': 'PIP5048GK/status/ac_output_apparent_power/value', 'payload': 364}, {'topic': 'PIP5048GK/status/ac_output_apparent_power/unit', 'payload': 'VA'}, {'topic': 'PIP5048GK/status/ac_output_active_power/value', 'payload': 150}, {'topic': 'PIP5048GK/status/ac_output_active_power/unit', 'payload': 'W'}, {'topic': 'PIP5048GK/status/ac_output_load/value', 'payload': 7}, {'topic': 'PIP5048GK/status/ac_output_load/unit', 'payload': '%'}, {'topic': 'PIP5048GK/status/bus_voltage/value', 'payload': 420}, {'topic': 'PIP5048GK/status/bus_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_voltage/value', 'payload': 50.6}, {'topic': 'PIP5048GK/status/battery_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_charging_current/value', 'payload': 0}, {'topic': 'PIP5048GK/status/battery_charging_current/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/battery_capacity/value', 'payload': 44}, {'topic': 'PIP5048GK/status/battery_capacity/unit', 'payload': '%'}, {'topic': 'PIP5048GK/status/inverter_heat_sink_temperature/value', 'payload': 24}, {'topic': 'PIP5048GK/status/inverter_heat_sink_temperature/unit', 'payload': '°C'}, {'topic': 'PIP5048GK/status/pv_input_current_for_battery/value', 'payload': 0.3}, {'topic': 'PIP5048GK/status/pv_input_current_for_battery/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/pv_input_voltage/value', 'payload': 390.8}, {'topic': 'PIP5048GK/status/pv_input_voltage/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_voltage_from_scc/value', 'payload': 0.0}, {'topic': 'PIP5048GK/status/battery_voltage_from_scc/unit', 'payload': 'V'}, {'topic': 'PIP5048GK/status/battery_discharge_current/value', 'payload': 0}, {'topic': 'PIP5048GK/status/battery_discharge_current/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/is_sbu_priority_version_added/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_sbu_priority_version_added/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_configuration_changed/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_configuration_changed/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_scc_firmware_updated/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_scc_firmware_updated/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_load_on/value', 'payload': 1}, {'topic': 'PIP5048GK/status/is_load_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_battery_voltage_to_steady_while_charging/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_battery_voltage_to_steady_while_charging/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_scc_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_scc_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_ac_charging_on/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_ac_charging_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/rsv1/value', 'payload': 0}, {'topic': 'PIP5048GK/status/rsv1/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/rsv2/value', 'payload': 0}, {'topic': 'PIP5048GK/status/rsv2/unit', 'payload': 'A'}, {'topic': 'PIP5048GK/status/pv_input_power/value', 'payload': 156}, {'topic': 'PIP5048GK/status/pv_input_power/unit', 'payload': 'W'}, {'topic': 'PIP5048GK/status/is_charging_to_float/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_charging_to_float/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_switched_on/value', 'payload': 1}, {'topic': 'PIP5048GK/status/is_switched_on/unit', 'payload': 'bool'}, {'topic': 'PIP5048GK/status/is_reserved/value', 'payload': 0}, {'topic': 'PIP5048GK/status/is_reserved/unit', 'payload': 'bool'}]
2025-07-22 18:30:20,847:DEBUG:mqtt_manager:_generate_client_id@98: Generated client ID: mppsolar_openhabian_87bc0a91 for connection: openhabian:192.168.178.84:1883:user
2025-07-22 18:30:20,848:INFO:mqtt_manager:_connection_loop@255: Attempting to connect to 192.168.178.84:1883
2025-07-22 18:30:20,861:INFO:mqtt_manager:start@234: Started MQTT connection manager for 192.168.178.84:1883
2025-07-22 18:30:20,862:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_input_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,866:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_input_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,867:WARNING:mqtt_manager:_publish_loop@310: Cannot publish to PIP5048GK/status/ac_input_voltage/value - not connected
2025-07-22 18:30:20,871:WARNING:mqtt_manager:_publish_loop@310: Cannot publish to PIP5048GK/status/ac_input_voltage/unit - not connected
2025-07-22 18:30:20,868:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_input_frequency/value with QoS=0, retain=False
2025-07-22 18:30:20,871:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_input_frequency/unit with QoS=0, retain=False
2025-07-22 18:30:20,870:INFO:mqtt_manager:_on_connect@137: MQTT connection to 192.168.178.84:1883 - Connection successful
2025-07-22 18:30:20,873:WARNING:mqtt_manager:_publish_loop@310: Cannot publish to PIP5048GK/status/ac_input_frequency/value - not connected
2025-07-22 18:30:20,873:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,874:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,874:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_input_frequency/unit with QoS=0, retain=False
2025-07-22 18:30:20,876:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_input_frequency/unit: Hz… (QoS=0, retain=False)
2025-07-22 18:30:20,877:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,874:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_frequency/value with QoS=0, retain=False
2025-07-22 18:30:20,879:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_frequency/unit with QoS=0, retain=False
2025-07-22 18:30:20,879:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_apparent_power/value with QoS=0, retain=False
2025-07-22 18:30:20,879:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_apparent_power/unit with QoS=0, retain=False
2025-07-22 18:30:20,879:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_active_power/value with QoS=0, retain=False
2025-07-22 18:30:20,879:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_active_power/unit with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_load/value with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/ac_output_load/unit with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/bus_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/bus_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,880:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_charging_current/value with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_charging_current/unit with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_capacity/value with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_capacity/unit with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/inverter_heat_sink_temperature/value with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/inverter_heat_sink_temperature/unit with QoS=0, retain=False
2025-07-22 18:30:20,881:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_current_for_battery/value with QoS=0, retain=False
2025-07-22 18:30:20,882:DEBUG:mqtt_manager:_on_publish@222: Message 1 published successfully
2025-07-22 18:30:20,882:DEBUG:mqtt_manager:_on_publish@222: Message 2 published successfully
2025-07-22 18:30:20,878:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_voltage/value: 228.1… (QoS=0, retain=False)
2025-07-22 18:30:20,883:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,883:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_voltage/unit: V… (QoS=0, retain=False)
2025-07-22 18:30:20,884:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_frequency/value with QoS=0, retain=False
2025-07-22 18:30:20,884:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_frequency/value: 50.0… (QoS=0, retain=False)
2025-07-22 18:30:20,884:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_frequency/unit with QoS=0, retain=False
2025-07-22 18:30:20,885:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_frequency/unit: Hz… (QoS=0, retain=False)
2025-07-22 18:30:20,885:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_apparent_power/value with QoS=0, retain=False
2025-07-22 18:30:20,885:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_apparent_power/value: 364… (QoS=0, retain=False)
2025-07-22 18:30:20,886:DEBUG:mqtt_manager:_on_publish@222: Message 3 published successfully
2025-07-22 18:30:20,886:DEBUG:mqtt_manager:_on_publish@222: Message 4 published successfully
2025-07-22 18:30:20,886:DEBUG:mqtt_manager:_on_publish@222: Message 5 published successfully
2025-07-22 18:30:20,886:DEBUG:mqtt_manager:_on_publish@222: Message 6 published successfully
2025-07-22 18:30:20,882:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_current_for_battery/unit with QoS=0, retain=False
2025-07-22 18:30:20,887:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,887:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_voltage/unit with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_voltage_from_scc/value with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_voltage_from_scc/unit with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_discharge_current/value with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/battery_discharge_current/unit with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_sbu_priority_version_added/value with QoS=0, retain=False
2025-07-22 18:30:20,888:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_sbu_priority_version_added/unit with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_configuration_changed/value with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_configuration_changed/unit with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_scc_firmware_updated/value with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_scc_firmware_updated/unit with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_load_on/value with QoS=0, retain=False
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_load_on/unit with QoS=0, retain=False
2025-07-22 18:30:20,886:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_apparent_power/unit with QoS=0, retain=False
2025-07-22 18:30:20,893:DEBUG:mqtt_manager:_on_publish@222: Message 7 published successfully
2025-07-22 18:30:20,894:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_apparent_power/unit: VA… (QoS=0, retain=False)
2025-07-22 18:30:20,894:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_active_power/value with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:_on_publish@222: Message 8 published successfully
2025-07-22 18:30:20,889:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_battery_voltage_to_steady_while_charging/value with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_battery_voltage_to_steady_while_charging/unit with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_charging_on/value with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_charging_on/unit with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_scc_charging_on/value with QoS=0, retain=False
2025-07-22 18:30:20,895:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_scc_charging_on/unit with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_ac_charging_on/value with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_ac_charging_on/unit with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/rsv1/value with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/rsv1/unit with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/rsv2/value with QoS=0, retain=False
2025-07-22 18:30:20,896:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/rsv2/unit with QoS=0, retain=False
2025-07-22 18:30:20,897:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_power/value with QoS=0, retain=False
2025-07-22 18:30:20,897:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_active_power/value: 150… (QoS=0, retain=False)
2025-07-22 18:30:20,897:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_active_power/unit with QoS=0, retain=False
2025-07-22 18:30:20,898:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_active_power/unit: W… (QoS=0, retain=False)
2025-07-22 18:30:20,898:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_load/value with QoS=0, retain=False
2025-07-22 18:30:20,898:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_load/value: 7… (QoS=0, retain=False)
2025-07-22 18:30:20,898:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/ac_output_load/unit with QoS=0, retain=False
2025-07-22 18:30:20,899:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/ac_output_load/unit: %… (QoS=0, retain=False)
2025-07-22 18:30:20,899:DEBUG:mqtt_manager:_publish_loop@299: Publishing to PIP5048GK/status/bus_voltage/value with QoS=0, retain=False
2025-07-22 18:30:20,897:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/pv_input_power/unit with QoS=0, retain=False
2025-07-22 18:30:20,900:DEBUG:mqtt_manager:_on_publish@222: Message 9 published successfully
2025-07-22 18:30:20,900:DEBUG:mqtt_manager:_on_publish@222: Message 10 published successfully
2025-07-22 18:30:20,901:DEBUG:mqtt_manager:_on_publish@222: Message 11 published successfully
2025-07-22 18:30:20,901:DEBUG:mqtt_manager:_on_publish@222: Message 12 published successfully
2025-07-22 18:30:20,900:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_charging_to_float/value with QoS=0, retain=False
2025-07-22 18:30:20,901:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_charging_to_float/unit with QoS=0, retain=False
2025-07-22 18:30:20,901:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_switched_on/value with QoS=0, retain=False
2025-07-22 18:30:20,901:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_switched_on/unit with QoS=0, retain=False
2025-07-22 18:30:20,902:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_reserved/value with QoS=0, retain=False
2025-07-22 18:30:20,902:DEBUG:mqtt_manager:publish@327: Queuing message for PIP5048GK/status/is_reserved/unit with QoS=0, retain=False
2025-07-22 18:30:20,902:DEBUG:init:main@671: Not daemon, so not looping
2025-07-22 18:30:20,902:INFO:mqtt_manager:stop@238: Stopping MQTT connection to 192.168.178.84:1883
2025-07-22 18:30:20,899:DEBUG:mqtt_manager:_publish_loop@308: Published to PIP5048GK/status/bus_voltage/value: 420… (QoS=0, retain=False)
2025-07-22 18:30:20,973:INFO:mqtt_manager:stop_all@385: Stopped all MQTT connections

[RookieRon]

Ok, found it:
in "mqtt_manager.py" the stop function is way quicker than the remaining queued messages are published. So I used the woodhammer method:

`
def stop(self):

    """Stop the connection and all background threads"""
    log.info(f"Stopping MQTT connection to {self.config.name}:{self.config.port}")
    time.sleep(3) # <--------------------------- this was added--------------------------
    self.should_stop.set()
    if self.connected:
        self.client.disconnect()
    if self.connection_thread and self.connection_thread.is_alive():
        self.connection_thread.join(timeout=5)
    if self.publish_thread and self.publish_thread.is_alive():
        self.publish_thread.join(timeout=5)`

[cordelster]

time.sleep(3)

Thank you for the feed back, and what you found.
I think rather than just adding time, I'll add some checks for the publish que, add insure all messages are sent prior to exit like so:

    def stop(self):
        """Stop the connection and all background threads"""
        log.info(f"Stopping MQTT connection to {self.config.name}:{self.config.port}")

        self.should_stop.set()
        timeout = 10  # Wait for the publish queue to empty, with a timeout
        start_time = time.time()
        while not self.publish_queue.empty() and (time.time() - start_time) < timeout:
            log.debug(f"Waiting for publish queue to empty... {self.publish_queue.qsize()} items remaining")
            time.sleep(0.5)

        if not self.publish_queue.empty():
            log.warning(f"Publish queue was not empty after {timeout} seconds. {self.publish_queue.qsize()} messages lost.")

        if self.connected:
            self.client.disconnect()

        if self.connection_thread and self.connection_thread.is_alive():
            self.connection_thread.join(timeout=5)

        if self.publish_thread and self.publish_thread.is_alive():
            self.publish_thread.join(timeout=5)
    
        log.info("Stopped all MQTT connections")

If you want to try this change, let me know, else I will start testing within a week and have a PR in a couple weeks for John once it tests out. I have the patch at https://github.com/cordelster/mpp-solar/tree/mqtt_que_check

[RookieRon]

sorry, have not much time for testing, but the solution above is not working. However, version with timeout has no problems.

2025-08-17 20:34:21,082:DEBUG:mqtt_manager:publish@338: Queuing message for PIP5048GK/status/is_reserved/unit with QoS=0, retain=False 2025-08-17 20:34:21,082:DEBUG:__init__:main@671: Not daemon, so not looping 2025-08-17 20:34:21,083:INFO:mqtt_manager:stop@238: Stopping MQTT connection to 192.168.178.84:1883 2025-08-17 20:34:21,083:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:21,081:DEBUG:mqtt_manager:_on_publish@222: Message 16 published successfully 2025-08-17 20:34:21,083:DEBUG:mqtt_manager:_on_publish@222: Message 17 published successfully 2025-08-17 20:34:21,083:DEBUG:mqtt_manager:_on_publish@222: Message 18 published successfully 2025-08-17 20:34:21,084:DEBUG:mqtt_manager:_on_publish@222: Message 19 published successfully 2025-08-17 20:34:21,084:DEBUG:mqtt_manager:_on_publish@222: Message 20 published successfully 2025-08-17 20:34:21,081:DEBUG:mqtt_manager:_publish_loop@310: Publishing to PIP5048GK/status/battery_capacity/value with QoS=0, retain=False 2025-08-17 20:34:21,085:DEBUG:mqtt_manager:_on_publish@222: Message 21 published successfully 2025-08-17 20:34:21,085:DEBUG:mqtt_manager:_publish_loop@319: Published to PIP5048GK/status/battery_capacity/value: 32… (QoS=0, retain=False) 2025-08-17 20:34:21,583:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:22,084:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:22,585:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:23,086:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:23,587:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:24,088:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:24,590:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:25,091:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:25,592:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:26,093:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:26,595:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:27,096:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:27,597:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:28,098:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:28,599:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:29,100:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:29,601:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:30,102:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:30,603:DEBUG:mqtt_manager:stop@245: Waiting for publish queue to empty... 39 items remaining 2025-08-17 20:34:31,104:WARNING:mqtt_manager:stop@249: Publish queue was not empty after 10 seconds. 39 messages lost. 2025-08-17 20:34:31,105:INFO:mqtt_manager:stop_all@401: Stopped all MQTT connections

[s650mb]

Good afternoon.
The same problem started as the author of the topic.
Couldn't track down when the problem occurred.
Of the two proposed solutions, the topic author's solution helps.
Unfortunately, the solution only works in DEBUG mode when using an application with the -D key.
Are there any plans to fix the problem so that it can work correctly?

[s650mb]

And unfortunately, with this solution, some of the values are still not sent to mqtt.

[LMMKnight]

There are two problems. The program stops before the mqqt publish queue can finish, and the queue gets processed even if the mqqt connection fails so messages get missed.

I fixed it with the following code:

def _publish_loop(self):
"""Background thread for publishing queued messages"""
while not self.should_stop.is_set():
try:

            if self.connected:
                # Get message from queue with timeout
                msg_data = self.publish_queue.get(timeout=1)
                topic = msg_data['topic']
                payload = msg_data['payload']
                # FIXED: Use direct dictionary access instead of .get() with defaults
                # This preserves the QoS and retain values that were explicitly set
                qos = msg_data['qos']
                retain = msg_data['retain']

                log.debug(f"Publishing to {topic} with QoS={qos}, retain={retain}")
                result = self.client.publish(topic, payload, qos=qos, retain=retain)
                if result.rc != mqtt_client.MQTT_ERR_SUCCESS:
                    log.warning(f"Failed to publish to {topic}: {result.rc}")
                else:
                    if isinstance(payload, (bytes, str)):
                        preview = payload[:100]
                    else:
                        preview = str(payload)[:100]
                    log.debug(f"Published to {topic}: {preview}… (QoS={qos}, retain={retain})")

        except Empty:
            continue
        except KeyError as e:
            log.error(f"Missing required key in message data: {e}")
        except Exception as e:
            log.error(f"Error in publish loop: {e}")

def stop(self):
"""Stop the connection and all background threads"""
while not self.publish_queue.empty():
time.sleep(1)
log.info(f"Stopping MQTT connection to {self.config.name}:{self.config.port}")
self.should_stop.set()

    if self.connected:
        self.client.disconnect()

    if self.connection_thread and self.connection_thread.is_alive():
        self.connection_thread.join(timeout=5)

    if self.publish_thread and self.publish_thread.is_alive():
        self.publish_thread.join(timeout=5)

[JakobTewes]

And unfortunately, with this solution, some of the values are still not sent to mqtt.

Got the same prob. Reason might be:

2025-10-15 08:36:27,695:WARNING:mqtt_manager:_on_disconnect@153: Unexpected MQTT disconnection from 1.2.3.4. RC: 7
2025-10-15 08:36:25,242:WARNING:mqtt_manager:_publish_loop@311: Cannot publish to TOPIC - not connected