ProBackup-nl · February 6, 2024 13:45 · Feb 6, 2024 · Dec 25, 2021 · Dec 25, 2021 · Dec 18, 2021
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -2,6 +2,8 @@
 # Store  DSMR telegrams from P1 into influxdb 2.0 and pvoutput.org
 # EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
 
+# WARNING: influxdb will crash/become a memory hog after collecting a few months of data !!!
+
 #- Requires python2+
 #- Install deps
 #  # pacman -S python-requests python-pytz

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -211,7 +211,7 @@ def handle(values):
 	with open(filename, 'a') as file:
             if filesize == 0:
                 file.write('#!/bin/sh' + "\n")
-            file.write('curl -X POST ' + url + '?org=Organization&bucket=dsm&precision=s ' + \
+            file.write('curl -X POST "' + url + '?org=Organization&bucket=dsm&precision=s" ' + \
                        '-H "Authorization: Token ' + auth_token + '" ' + \
                        '-H "Content-Type: application/x-www-form-urlencoded" ' + \
                        '-d "' + postdata.replace('\n','') + '"' + "\n")

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -200,7 +200,7 @@ def handle(values):
                           timeout=0.9)
     except requests.exceptions.Timeout:
         # Log request to file
-        filename = 'insert-failed-influx-posts.sh'
+        filename = '/root/insert-failed-influx-posts.sh'
         try:
             with open(filename, 'r') as file:
                 file.seek(0, os.SEEK_END)
@@ -214,7 +214,7 @@ def handle(values):
             file.write('curl -X POST ' + url + '?org=Organization&bucket=dsm&precision=s ' + \
                        '-H "Authorization: Token ' + auth_token + '" ' + \
                        '-H "Content-Type: application/x-www-form-urlencoded" ' + \
-                       '-d "' + postdata + '"' + "\n")
+                       '-d "' + postdata.replace('\n','') + '"' + "\n")
     except requests.exceptions.ConnectionError:
         print('Connection refused')
     except requests.exceptions.RequestException as e:

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -236,6 +236,7 @@ def post_pvoutput():
         hivolt = 0.0
         postdata = "&".join([d, t, v1, v3, v6, 'c1=1'])
 
+	# Try posting data 9 times
         for i in range(1, 9):
             try:
                 r = requests.post(

diff --git a/help.txt b/help.txt
@@ -11,17 +11,10 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   # systemctl enable dsm_reader.service && systemctl start dsm_reader
 - ToDo: 
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
-  3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
+  2. use this name@ to create a separate backlog file per serial device?
+  3. auto insert backlog to influxdb
   4. implement retries, with backoff? like 
      - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
      - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88
-  5. fire off influxdb posting as separate thread, limit amount of threads?
-  6. handle influxdb related error: socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
-  Dec 08 08:39:20 influxPi4B socat[320]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
-Dec 08 08:39:20 influxPi4B socat[320]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
-Dec 08 08:39:20 influxPi4B socat[320]: Traceback (most recent call last):
-Dec 08 08:39:20 influxPi4B socat[320]:   File "/root/dsm_reader.py", line 259, in <module>
-Dec 08 08:39:20 influxPi4B socat[320]:     values = verify_and_parse(buf)
-Dec 08 08:39:20 influxPi4B socat[320]:   File "/root/dsm_reader.py", line 133, in verify_and_parse
-Dec 08 08:39:20 influxPi4B socat[320]:     crc = int(buf[-1][1:5], 16)
-Dec 08 08:39:20 influxPi4B socat[320]: ValueError: invalid literal for int() with base 16: '-0:6'
+  5. also backlog pvoutput temp. errors, note: The date parameter must not be older than 14 days from the current date
+
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -201,11 +201,14 @@ def handle(values):
     except requests.exceptions.Timeout:
         # Log request to file
         filename = 'insert-failed-influx-posts.sh'
-        filesize = 0
-        with open(filename, 'r') as file:
-            file.seek(0, os.SEEK_END)
-            filesize = file.tell()
-        with open(filename, 'a') as file:
+        try:
+            with open(filename, 'r') as file:
+                file.seek(0, os.SEEK_END)
+                filesize = file.tell()
+        except FileNotFoundError:
+            filesize = 0
+
+	with open(filename, 'a') as file:
             if filesize == 0:
                 file.write('#!/bin/sh' + "\n")
             file.write('curl -X POST ' + url + '?org=Organization&bucket=dsm&precision=s ' + \

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -281,4 +281,4 @@ def post_pvoutput():
 
                 if called_once == False:
                      called_once = True
-                     post_pvoutput() # threaded
+                     post_pvoutput() # threaded
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -10,11 +10,10 @@
 #- Create config
 #  # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
 
-# ToDo: handle influxdb socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
 # ToDo: handle influxPi4B socat[137394]: HTTPSConnectionPool(host='pvoutput.org', port=443): Max retries exceeded with url: /service/
-# currently this error breaks both influx and pvoutput logging
 
 import logging
+import os
 import re
 import sys
 import threading
@@ -194,11 +193,25 @@ def handle(values):
 
     # use InfluxDB 1.x compatibility API - Line protocol // db = bucket, precision = seconds
     try:
-        r = requests.post(url, 
-                          params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, 
-                          data=postdata, 
-                          headers={'Authorization': 'Token ' + auth_token}, 
+        r = requests.post(url,
+                          params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'},
+                          data=postdata,
+                          headers={'Authorization': 'Token ' + auth_token},
                           timeout=0.9)
+    except requests.exceptions.Timeout:
+        # Log request to file
+        filename = 'insert-failed-influx-posts.sh'
+        filesize = 0
+        with open(filename, 'r') as file:
+            file.seek(0, os.SEEK_END)
+            filesize = file.tell()
+        with open(filename, 'a') as file:
+            if filesize == 0:
+                file.write('#!/bin/sh' + "\n")
+            file.write('curl -X POST ' + url + '?org=Organization&bucket=dsm&precision=s ' + \
+                       '-H "Authorization: Token ' + auth_token + '" ' + \
+                       '-H "Content-Type: application/x-www-form-urlencoded" ' + \
+                       '-d "' + postdata + '"' + "\n")
     except requests.exceptions.ConnectionError:
         print('Connection refused')
     except requests.exceptions.RequestException as e:
@@ -223,15 +236,15 @@ def post_pvoutput():
         for i in range(1, 9):
             try:
                 r = requests.post(
-                    urlpv, 
-                    data=postdata, 
+                    urlpv,
+                    data=postdata,
                     headers={
-                      'Content-Type': 'application/x-www-form-urlencoded',
+                        'Content-Type': 'application/x-www-form-urlencoded',
                         'X-Pvoutput-Apikey': pvoutput_token_6,
                         'X-Pvoutput-SystemId': pvoutput_sid_6,
                         'Accept': 'text/plain'
                     },
-                   timeout=30)
+                    timeout=30)
                 if print_output:
                     print(r.text)
                     #print(postdata)
@@ -268,4 +281,4 @@ def post_pvoutput():
 
                 if called_once == False:
                      called_once = True
-                     post_pvoutput() # threaded
+                     post_pvoutput() # threaded
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -11,6 +11,8 @@
 #  # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
 
 # ToDo: handle influxdb socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+# ToDo: handle influxPi4B socat[137394]: HTTPSConnectionPool(host='pvoutput.org', port=443): Max retries exceeded with url: /service/
+# currently this error breaks both influx and pvoutput logging
 
 import logging
 import re

diff --git a/help.txt b/help.txt
@@ -16,4 +16,12 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
      - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
      - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88
   5. fire off influxdb posting as separate thread, limit amount of threads?
-  6. handle influxdb related error: socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+  6. handle influxdb related error: socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+  Dec 08 08:39:20 influxPi4B socat[320]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+Dec 08 08:39:20 influxPi4B socat[320]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+Dec 08 08:39:20 influxPi4B socat[320]: Traceback (most recent call last):
+Dec 08 08:39:20 influxPi4B socat[320]:   File "/root/dsm_reader.py", line 259, in <module>
+Dec 08 08:39:20 influxPi4B socat[320]:     values = verify_and_parse(buf)
+Dec 08 08:39:20 influxPi4B socat[320]:   File "/root/dsm_reader.py", line 133, in verify_and_parse
+Dec 08 08:39:20 influxPi4B socat[320]:     crc = int(buf[-1][1:5], 16)
+Dec 08 08:39:20 influxPi4B socat[320]: ValueError: invalid literal for int() with base 16: '-0:6'
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -9,6 +9,9 @@
 #  # nano /root/dsm_reader.py && chmod +x /root/dsm_reader.py
 #- Create config
 #  # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
+
+# ToDo: handle influxdb socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
+
 import logging
 import re
 import sys

diff --git a/help.txt b/help.txt
@@ -15,4 +15,5 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   4. implement retries, with backoff? like 
      - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
      - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88
-  5. fire off influxdb posting as separate thread, limit amount of threads?
+  5. fire off influxdb posting as separate thread, limit amount of threads?
+  6. handle influxdb related error: socat[291]: HTTPConnectionPool(host='127.0.0.1', port=8086): Read timed out. (read timeout=0.9)
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -194,6 +194,8 @@ def handle(values):
                           data=postdata, 
                           headers={'Authorization': 'Token ' + auth_token}, 
                           timeout=0.9)
+    except requests.exceptions.ConnectionError:
+        print('Connection refused')
     except requests.exceptions.RequestException as e:
         print(str(e))
     else:

diff --git a/dsm_reader.service.d b/dsm_reader.service.d
@@ -1,6 +1,6 @@
 # nano /lib/systemd/system/dsm_reader.service
 [Unit]
-Description=Read smart meter P1 data and store the numeric values in Influxdb
+Description=Read smart meter P1 data and store the numeric values in Influxdb and pvoutput
 Requires=influxdb2-bin
 After=influxdb2-bin
 

diff --git a/help.txt b/help.txt
@@ -11,10 +11,7 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   # systemctl enable dsm_reader.service && systemctl start dsm_reader
 - ToDo: 
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
-  2. timeout exception handler with retries for pvoutput
-     - https://github.com/jrbenito/eastron-pvoutput/blob/e55bfb7ac4df8b46a265e38045c4ab2f68f0e42e/sdm2pvoutput.py#L54
   3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
-     - https://github.com/jakezp/gw2pvo-alt/blob/b551763222c7dc4264c0bb2556e9804040de634d/gw2pvo/pvo_api.py#L116
   4. implement retries, with backoff? like 
      - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
      - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -9,6 +9,7 @@
 #  # nano /root/dsm_reader.py && chmod +x /root/dsm_reader.py
 #- Create config
 #  # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
+import logging
 import re
 import sys
 import threading
@@ -212,25 +213,32 @@ def post_pvoutput():
         hivolt = 0.0
         postdata = "&".join([d, t, v1, v3, v6, 'c1=1'])
 
-        try:
-            r = requests.post(
-                urlpv, 
-                data=postdata, 
-                headers={
-                    'Content-Type': 'application/x-www-form-urlencoded',
-                    'X-Pvoutput-Apikey': pvoutput_token_6,
-                    'X-Pvoutput-SystemId': pvoutput_sid_6,
-                    'Accept': 'text/plain'
-                },
-                timeout=30)
-            if print_output:
-                print(r.text)
-                #print(postdata)
-        except requests.exceptions.RequestException as e:
-            print(str(e))
-        else:
-            if print_output:
-                print(str(r))
+        for i in range(1, 9):
+            try:
+                r = requests.post(
+                    urlpv, 
+                    data=postdata, 
+                    headers={
+                      'Content-Type': 'application/x-www-form-urlencoded',
+                        'X-Pvoutput-Apikey': pvoutput_token_6,
+                        'X-Pvoutput-SystemId': pvoutput_sid_6,
+                        'Accept': 'text/plain'
+                    },
+                   timeout=30)
+                if print_output:
+                    print(r.text)
+                    #print(postdata)
+                if r.status_code == 200:
+                    return
+                if 400 <= r.status_code < 500:
+                    warningMsg = ("Unable to connect to pvoutput.org - Reason: " + r.reason)
+                    logging.warning(warningMsg)
+                    return
+            except requests.exceptions.RequestException as e:
+                print(str(e))
+            else:
+                if print_output:
+                    print(str(r))
 
 if __name__ == '__main__':
     buf = []

diff --git a/help.txt b/help.txt
@@ -18,6 +18,4 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   4. implement retries, with backoff? like 
      - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
      - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88
-  5. fire off influxdb posting as separate thread, limit amount of threads?
-  6. pvoutput post header "Accept": "text/plain"?
-     - https://github.com/dkruyt/ginlong-scraper/blob/c756d01b72ce2dd626b5f32996a7e462ea067cd7/ginlong-scraper.py#L96
+  5. fire off influxdb posting as separate thread, limit amount of threads?
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -219,7 +219,9 @@ def post_pvoutput():
                 headers={
                     'Content-Type': 'application/x-www-form-urlencoded',
                     'X-Pvoutput-Apikey': pvoutput_token_6,
-                    'X-Pvoutput-SystemId': pvoutput_sid_6},
+                    'X-Pvoutput-SystemId': pvoutput_sid_6,
+                    'Accept': 'text/plain'
+                },
                 timeout=30)
             if print_output:
                 print(r.text)

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -195,11 +195,9 @@ def handle(values):
                           timeout=0.9)
     except requests.exceptions.RequestException as e:
         print(str(e))
-        continue
     else:
         if print_output:
             print(str(r))
-        continue
 
 def post_pvoutput():
     global arr_vals, pts, hivolt
@@ -228,11 +226,9 @@ def post_pvoutput():
                 #print(postdata)
         except requests.exceptions.RequestException as e:
             print(str(e))
-            continue
         else:
             if print_output:
                 print(str(r))
-            continue
 
 if __name__ == '__main__':
     buf = []

diff --git a/help.txt b/help.txt
@@ -12,6 +12,12 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
 - ToDo: 
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
   2. timeout exception handler with retries for pvoutput
+     - https://github.com/jrbenito/eastron-pvoutput/blob/e55bfb7ac4df8b46a265e38045c4ab2f68f0e42e/sdm2pvoutput.py#L54
   3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
-  4. implement retries, with backoff? like solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
-  5. fire off influxdb posting as separate thread, limit amount of threads?
+     - https://github.com/jakezp/gw2pvo-alt/blob/b551763222c7dc4264c0bb2556e9804040de634d/gw2pvo/pvo_api.py#L116
+  4. implement retries, with backoff? like 
+     - solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
+     - https://github.com/pvl7/emu-to-pvoutput/blob/2edf7fff8d1af180fa203968b2d33acb80485dec/rainforest-to-pvoutput.py#L88
+  5. fire off influxdb posting as separate thread, limit amount of threads?
+  6. pvoutput post header "Accept": "text/plain"?
+     - https://github.com/dkruyt/ginlong-scraper/blob/c756d01b72ce2dd626b5f32996a7e462ea067cd7/ginlong-scraper.py#L96
diff --git a/help.txt b/help.txt
@@ -13,4 +13,5 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
   2. timeout exception handler with retries for pvoutput
   3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
-  4. implement retries, with backoff? like solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
+  4. implement retries, with backoff? like solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
+  5. fire off influxdb posting as separate thread, limit amount of threads?
diff --git a/help.txt b/help.txt
@@ -12,4 +12,5 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
 - ToDo: 
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
   2. timeout exception handler with retries for pvoutput
-  3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
+  3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
+  4. implement retries, with backoff? like solution 4 from https://izziswift.com/can-i-set-max_retries-for-requests-request/
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -14,6 +14,7 @@
 import threading
 import time
 import requests
+import urllib3
 from datetime import datetime
 from pytz import timezone, utc
 from dsm_reader_config import auth_token, pvoutput_token_6, pvoutput_sid_6
@@ -22,6 +23,7 @@
 url = 'http://127.0.0.1:8086/api/v2/write'
 urlpv = 'https://pvoutput.org/service/r2/addstatus.jsp'
 fp = sys.stdin
+urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 
 table = [
 0x0000, 0xc0c1, 0xc181, 0x0140, 0xc301, 0x03c0, 0x0280, 0xc241,
@@ -213,12 +215,14 @@ def post_pvoutput():
         postdata = "&".join([d, t, v1, v3, v6, 'c1=1'])
 
         try:
-            r = requests.post(urlpv, 
+            r = requests.post(
+                urlpv, 
                 data=postdata, 
                 headers={
                     'Content-Type': 'application/x-www-form-urlencoded',
                     'X-Pvoutput-Apikey': pvoutput_token_6,
-                    'X-Pvoutput-SystemId': pvoutput_sid_6})
+                    'X-Pvoutput-SystemId': pvoutput_sid_6},
+                timeout=30)
             if print_output:
                 print(r.text)
                 #print(postdata)
@@ -228,7 +232,7 @@ def post_pvoutput():
         else:
             if print_output:
                 print(str(r))
-            continue        
+            continue
 
 if __name__ == '__main__':
     buf = []

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -190,16 +190,14 @@ def handle(values):
                           params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, 
                           data=postdata, 
                           headers={'Authorization': 'Token ' + auth_token}, 
-                          timout=0.9)
-    except requests.exceptions.Timeout as e:
-        if print_output:
-            print(e)
+                          timeout=0.9)
     except requests.exceptions.RequestException as e:
-        if print_output:
-            print(e)	
+        print(str(e))
+        continue
     else:
         if print_output:
-            print(r)
+            print(str(r))
+        continue
 
 def post_pvoutput():
     global arr_vals, pts, hivolt
@@ -214,14 +212,23 @@ def post_pvoutput():
         hivolt = 0.0
         postdata = "&".join([d, t, v1, v3, v6, 'c1=1'])
 
-        r = requests.post(urlpv, data=postdata, headers={
-            'Content-Type': 'application/x-www-form-urlencoded',
-            'X-Pvoutput-Apikey': pvoutput_token_6,
-            'X-Pvoutput-SystemId': pvoutput_sid_6})
-        if print_output:
-            print(r.text)
-            #print(postdata)
-
+        try:
+            r = requests.post(urlpv, 
+                data=postdata, 
+                headers={
+                    'Content-Type': 'application/x-www-form-urlencoded',
+                    'X-Pvoutput-Apikey': pvoutput_token_6,
+                    'X-Pvoutput-SystemId': pvoutput_sid_6})
+            if print_output:
+                print(r.text)
+                #print(postdata)
+        except requests.exceptions.RequestException as e:
+            print(str(e))
+            continue
+        else:
+            if print_output:
+                print(str(r))
+            continue        
 
 if __name__ == '__main__':
     buf = []

diff --git a/.editorconfig b/.editorconfig
@@ -1,11 +0,0 @@
-root = true
-
-[*]
-indent_style = space
-indent_size = 2
-end_of_line = lf
-insert_final_newline = true
-trim_trailing_whitespace = true
-
-[*.py]
-indent_size = 4

diff --git a/.editorconfig b/.editorconfig
@@ -1,2 +1,11 @@
+root = true
+
+[*]
 indent_style = space
+indent_size = 2
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true
+
+[*.py]
 indent_size = 4
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -9,7 +9,7 @@
 #  # nano /root/dsm_reader.py && chmod +x /root/dsm_reader.py
 #- Create config
 #  # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
-import re                        # regular expression
+import re
 import sys
 import threading
 import time

diff --git a/.editorconfig b/.editorconfig
@@ -0,0 +1,2 @@
+indent_style = space
+indent_size = 4
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -186,7 +186,11 @@ def handle(values):
 
     # use InfluxDB 1.x compatibility API - Line protocol // db = bucket, precision = seconds
     try:
-        r = requests.post(url, params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, data=postdata, headers={'Authorization': 'Token ' + auth_token}, timout=0.9)
+        r = requests.post(url, 
+                          params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, 
+                          data=postdata, 
+                          headers={'Authorization': 'Token ' + auth_token}, 
+                          timout=0.9)
     except requests.exceptions.Timeout as e:
         if print_output:
             print(e)

diff --git a/help.txt b/help.txt
@@ -11,4 +11,5 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   # systemctl enable dsm_reader.service && systemctl start dsm_reader
 - ToDo: 
   1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
-  2. timeout exception handler met retries voor pvoutput
+  2. timeout exception handler with retries for pvoutput
+  3. post fluxdb exception handler that stores failing/missed posts to memory/disk and lator on insert the backlog
diff --git a/help.txt b/help.txt
@@ -9,4 +9,6 @@ EN-IEC 62056-21, Part 21: direct local data exchange, 2002-05
   # echo "auth_token='abcdefg'" > /root/dsm_reader_config.py
 - Start
   # systemctl enable dsm_reader.service && systemctl start dsm_reader
-- ToDo: modify service file to a template unit file (name@string.service), where the serial device becomes variable
+- ToDo: 
+  1. modify service file to a template unit file (name@string.service), where the serial device becomes variable
+  2. timeout exception handler met retries voor pvoutput
diff --git a/dsm_reader.py b/dsm_reader.py
@@ -188,10 +188,10 @@ def handle(values):
     try:
         r = requests.post(url, params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, data=postdata, headers={'Authorization': 'Token ' + auth_token}, timout=0.9)
     except requests.exceptions.Timeout as e:
-	if print_output:
+        if print_output:
             print(e)
     except requests.exceptions.RequestException as e:
-	if print_output:
+        if print_output:
             print(e)	
     else:
         if print_output:

diff --git a/dsm_reader.py b/dsm_reader.py
@@ -185,9 +185,17 @@ def handle(values):
         print(postdata)
 
     # use InfluxDB 1.x compatibility API - Line protocol // db = bucket, precision = seconds
-    r = requests.post(url, params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, data=postdata, headers={'Authorization': 'Token ' + auth_token})
-    if print_output:
-        print(r)
+    try:
+        r = requests.post(url, params={'org': 'Organization', 'bucket': 'dsm', 'precision': 's'}, data=postdata, headers={'Authorization': 'Token ' + auth_token}, timout=0.9)
+    except requests.exceptions.Timeout as e:
+	if print_output:
+            print(e)
+    except requests.exceptions.RequestException as e:
+	if print_output:
+            print(e)	
+    else:
+        if print_output:
+            print(r)
 
 def post_pvoutput():
     global arr_vals, pts, hivolt
No results found