Update the use of temperature reading, now outside temp is fetched from the web

Added prelim support to upload Smart meter (slimme meter) data

Author: Infern1

LiveStats.py

@@ -63,6 +63,11 @@
 #sock.close
 
 msg = InverterMsg(data)  # This is where the magic happens ;)
+now = datetime.datetime.now()
+
+print "Time: ", now.strftime('%H:%M')
+print "Date: ", now.strftime('%Y%m%d')
+
 print "ID: {0}".format(msg.getID())
 
 print "E Today: {0:>5}   Total: {1:<5}".format(msg.getEToday(), msg.getETotal())

OmnikExport.py

@@ -5,8 +5,11 @@
 import socket               # Needed for talking to inverter
 import datetime             # Used for timestamp
 import sys
+import re
 import logging
 import ConfigParser, os
+from os import path
+
 
 # For PVoutput 
 import urllib, urllib2
@@ -29,10 +32,17 @@
 mysql_pass      = config.get('mysql','mysql_pass')
 mysql_db        = config.get('mysql','mysql_db')
 
+smartmeter      = config.getboolean('smartmeter','read_smartmeter')
+smartmeter_file = config.get('smartmeter', 'data_file')
+
 pvout_enabled   = config.getboolean('pvout','pvout_enabled')
 pvout_apikey    = config.get('pvout','pvout_apikey')
 pvout_sysid     = config.get('pvout','pvout_sysid')
 
+read_remote_temperature = config.getboolean('temperature','read_remote_temperature')
+temperature_city = config.get('temperature','city')
+temperature_country = config.get('temperature','country')
+
 log_enabled     = config.getboolean('log','log_enabled')
 log_filename    = mydir + '/' + config.get('log','log_filename')
 
@@ -46,6 +56,17 @@
 logger.addHandler(hdlr) 
 logger.setLevel(logging.DEBUG)
 
+if read_remote_temperature:
+    import serial
+    import yweather
+    client = yweather.Client()
+    loc = temperature_city + ', ' + temperature_country
+    id =  client.fetch_woeid(loc)
+    loc_weather = client.fetch_weather(id,  metric=True)
+    local_temp = float(loc_weather["condition"]["temp"])
+    logger.debug("Local temperature is %s" % local_temp)
+
+
 for res in socket.getaddrinfo(ip, port, socket.AF_INET , socket.SOCK_STREAM):
     af, socktype, proto, canonname, sa = res
     try:
@@ -58,6 +79,7 @@
         continue
     try:
         s.connect(sa)
+        inverter_online = True
     except socket.error as msg:
         s.close()
         s = None
@@ -67,17 +89,22 @@
 if s is None:
     if log_enabled:
         logger.error('could not open socket')
-    sys.exit(1)
+        inverter_online = False
 
-s.sendall(InverterMsg.generate_string(wifi_serial))
-data = s.recv(1024)
-s.close()
 
-msg = InverterMsg.InverterMsg(data)  # This is where the magic happens ;)
+if inverter_online:
+    s.sendall(InverterMsg.generate_string(wifi_serial))
+    data = s.recv(1024)
+    s.close()
+
+    msg = InverterMsg.InverterMsg(data)  # This is where the magic happens ;)
+
+
 now = datetime.datetime.now()
 
 if log_enabled:
-    logger.info("ID: {0}".format(msg.getID())) 
+    if inverter_online:
+        logger.info("ID: {0}".format(msg.getID())) 
 
 
 if mysql_enabled:
@@ -105,38 +132,60 @@
           msg.getFAC(2), msg.getFAC(3), msg.getPAC(1), msg.getPAC(2), 
           msg.getPAC(3)) );
 
+
+if smartmeter:
+    logger.info('Reading smartmeter file')
+    with open(smartmeter_file , "r") as f:
+      for line in f:
+          if line.startswith('actual_usage.'):
+                s =  line
+                actual_usage = s.split()[-1]
+                actual_usage.rstrip()
+
+    f.close()
+    logger.debug("Actual usage was read %s", actual_usage)
+
 if pvout_enabled and (now.minute % 5) == 0:
     if log_enabled:
         logger.info('Uploading to PVoutput')
     url = "http://pvoutput.org/service/r2/addstatus.jsp"
-    
-    if use_temp:
-        get_data = {
-            'key': pvout_apikey, 
-            'sid': pvout_sysid, 
-            'd': now.strftime('%Y%m%d'),
-            't': now.strftime('%H:%M'),
-            'v1': msg.getEToday() * 1000,
-            'v2': msg.getPAC(1),
-            'v5': msg.getTemp(),
-            'v6': msg.getVPV(1)
-        }
-    else:
+
+
+    if (inverter_online == True or smartmeter == True):
+        #Only send data to pvoutput if the inverter is online or we have a smartmeter (consumption)
         get_data = {
-            'key': pvout_apikey, 
-            'sid': pvout_sysid, 
-            'd': now.strftime('%Y%m%d'),
-            't': now.strftime('%H:%M'),
-            'v1': msg.getEToday() * 1000,
-            'v2': msg.getPAC(1),
-            'v6': msg.getVPV(1)
-        }
-
-    get_data_encoded = urllib.urlencode(get_data)                       # UrlEncode the parameters
-    
-    request_object = urllib2.Request(url + '?' + get_data_encoded)      # Create request object
-    response = urllib2.urlopen(request_object)                          # Make the request and store the response
+                'key' : pvout_apikey,
+                'sid' : pvout_sysid,
+                'd'   : now.strftime('%Y%m%d'),
+                't'   : now.strftime('%H:%M')
+            } 
+        if inverter_online:
+            get_data['v1'] = msg.getEToday() * 1000
+            get_data['v2'] = msg.getPAC(1)
+            get_data['v6'] = msg.getVPV(1)
+
+        if ( ( use_temp == True and inverter_online == True) or read_remote_temperature == True):
+            if (use_temp == True and inverter_online == True):
+                temp_reading = msg.getTemp()
+            if (read_remote_temperature == True):
+                #Overwrite the reading from real value
+                temp_reading = local_temp
+            
+            get_data['v5'] = temp_reading
+
+        if smartmeter:
+            get_data['v4'] = actual_usage
+
+        get_data_encoded = urllib.urlencode(get_data)                       # UrlEncode the parameters
 
-    if log_enabled:
-        logger.info(response.read())                                               # Show the response
+        logger.debug("Sending url: %s " % url + '?' + get_data_encoded)
+
+        request_object = urllib2.Request(url + '?' + get_data_encoded)      # Create request object
+        response = urllib2.urlopen(request_object)                          # Make the request and store the response
 
+        if log_enabled:
+            logger.info("Response from server: %s" % response.read())                                               # Show the response
+    else:
+        if log_enabled:
+            logger.debug("Inverter is offline and no smartmeter installed")                                               # Show the response
+

README.md

@@ -12,6 +12,7 @@ status.
 ## Installation and Setup
 
 * Install Python
+* To use your local weather install yweather `pip install yweather`, and update your config with city and country
 * Git clone the source with `git clone https://github.com/Woutrrr/Omnik-Data-Logger.git`
 * Copy the config-org.cfg to config.cfg
 * Change the settings in config.cfg
@@ -20,6 +21,13 @@ data from your inverter
 * Run the script with `python OmnikExport.py` or better set a scheduled task or 
 cronjob.
 
+### Smart meter (Slimme meter)
+To upload your current usage to pvoutput, there must be a file to read in which this data can be found
+In this file there must by a string like this:
+`actual_usage   120.0`
+Which means current usage is 120W
+See the example is the Resources folder `slimme_meter.txt`
+
 ### Example cronjob
 With these options this will execute the script every minute.
 

Resources/slimme_meter.txt

@@ -0,0 +1,7 @@
+low tariff.value  27.365
+normal_tariff.value   0.000
+low_tariff_produced.value  13.471
+normal_tariff_produced.value   0.000
+actual_usage.value 0.0
+actual_production.value 270.0
+gas_usage.value  10.601

config-org.cfg

@@ -10,7 +10,7 @@ port = 8899
 # S/N of the wifi kit
 wifi_sn = 602123456
 #use temperature of inverter for pvoutput
-use_temperature = true
+use_temperature = false
 
 [mysql]
 # Enable for exporting to a mysql database
@@ -21,6 +21,16 @@ mysql_user =
 mysql_pass =             
 mysql_db   =             
 
+[smartmeter]
+read_smartmeter = true
+data_file = /home/robl/p1/P1uitlezer.txt
+
+
+[temperature]
+read_remote_temperature = true
+city = Haarlem
+country = The Netherlands
+
 [pvout]
 # Enable or disable uploading to PVoutput
 pvout_enabled = true