minor improvements

Author: pshirshov

README.md

@@ -92,7 +92,7 @@ uv run python ./demos/test-serial.py /tmp/serial 1
 ## How to run mongodb collector
 
 ```bash
-uv run poller 192.168.1.7 --mongo-url mongodb://mongodb.local:27017 --interval 1000 --interval 5
+uv run poller 192.168.1.7 --mongo-url mongodb://mongodb.local:27017 --interval 1000
 ```
 
 # Hardware wiring

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "python-pylontech-ext"
-version = "0.4.5"
+version = "0.4.6"
 description = "Interfaces with Pylontech Batteries using RS485 protocol"
 authors = [
     { name = "Frank Villaro-Dixon", email = "frank@villaro-dixon.eu" },

src/pylontechpoller/poller.py

@@ -96,6 +96,7 @@ def run(argv: list[str]):
     logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s', datefmt='%m/%d/%Y %I:%M:%S %p', level=level)
 
     cc = 0
+    errs = 0
     spinner = ['|', '/', '-', '\\']
 
     reporters = []
@@ -117,7 +118,7 @@ def run(argv: list[str]):
                 ))
 
             hass_url = args.hass_url
-            print(hass_url)
+
             if hass_url:
                 reporters.append(HassReporter(
                     hass_url,
@@ -147,18 +148,24 @@ def run(argv: list[str]):
                 for reporter in reporters:
                     reporter.report_state(mb)
 
+                if cc % 1000 == 0:
+                    logging.info("Updates submitted since startup: %d", cc)
                 if cc % 86400 == 0:
                     for reporter in reporters:
                         reporter.cleanup()
 
                 time.sleep(args.interval / 1000.0)
+                errs = 0
         except (KeyboardInterrupt, SystemExit):
             exit(0)
         except BaseException as e:
+            errs += 1
             logging.error("Exception occured: %s", e)
-
-
-
+            if errs > 10:
+                logging.error("Too many exceptions in a row, exiting just in casej")
+                exit(1)
+            else:
+                time.sleep(args.interval / 1000.0)
 def main():
     import sys
     run(sys.argv)