Solar is back online

 #!/usr/bin/env python3

 #This code uses a few libraries - could probably reduce this to subsets within these...but moving on...
 import requests
 import json
 import os
 import re
 import datetime

 # Define some variables first...we'll update these as we go, so we need them in global scope.
 myaccesstoken=""
 myTemp=""
 pvenergy=""
 pvpower=""
 pvvolts=""

 # These variables are needed to drive the show...
 pvoSysID="FIXME: Your PVOutput System ID"
 pvoAPIKey="FIXME: Your PVOutput API Key"
 pvoSvcURL="https://pvoutput.org/service/r2/addstatus.jsp"
 aurorainverter="/dev/ttyUSB0"
 address=2   # Default Aurora RS425 address
 tries=5     # Number of times to attempt communication with the inverter
 poller="/usr/local/bin/aurora"  # Where your compiled "aurora" binary lives
 pollopts=" -a " + str(address) + " -Y " + str(tries) + " -c -d 0 -e " + aurorainverter
 outdoor_module="FIXME: Your Netatmo Outdoor module NAME"
 pvOutputLog="/usr/local/logs/pvout.csv"      # CSV copy of data we want to send - can be fed into PVOutput.org if necessary.
 appLog="/usr/local/logs/pvout-uploader.log"  # A log of what this program does

 # Open the log file...
 logf=open(appLog, "a+")

 # Function to log messgaes to log file and screen...
 def log_it(message, fh):

     # Add the date/time to the front of the message
     # For some reason %z/%Z timezone not working for me - hard coded time zone
     message=datetime.datetime.now().strftime("%a %d %b %T AEST %Y ") + message

     # Now display and log it
     print(message)
     fh.write(message + "\n")

 # Now we start the process to poll the solar inverter
 log_it("Polling the solar inverter", logf)

 # First grab a time stamp to tie to the inverter's data
 # This avoids any potential delay in the program skewing the
 # sample collection details - unlikely, but you never know.
 currentDT=datetime.datetime.now()
 myDate=currentDT.strftime("%Y%m%d")
 myTime=currentDT.strftime("%H:%M")

 # The actual system call to the "aurora" binary...
 output=os.popen(poller + pollopts + " 2>&1").readlines()

 # Tidy up the output so we have usable data
 # If the inverter responded, all the data was output in space-delimited columns
 output[0]=output[0].lstrip()          # Strip leading whitespace
 output[0]=re.sub(' +',' ',output[0])  # Replace repeated spaces with a single space
 output[0]=re.sub('\n','',output[0])   # Remove new line characters
 solarparams=output[0].split(" ")      # Now split all the values retrieved into a list :)

 # Check if the inverter is online or not (last element in list will be "OK" if it all worked).
 if solarparams[-1] == "OK":

     # Inverter online - do all the time-consuming stuff and grok the output, then send to PVOutput

     # Get a token to authenticate to Netatmo
     # See https://dev.netatmo.com/myaccount/createanapp for client ID/Secret etc.
     payload = {
         'grant_type'   : 'password',
         'username'     : "FIXME: Your Netatmo Login",
         'password'     : "FIXME: Your Netatmo Password",
         'client_id'    : "FIXME: Your Netatmo client ID",
         'client_secret': "FIXME: Your Netatmo client secret",
         'scope'        : 'read_station'}
     try:
         response = requests.post("https://api.netatmo.com/oauth2/token", data=payload)
         response.raise_for_status()
         access_token=response.json()["access_token"]
         myaccesstoken=access_token
         refresh_token=response.json()["refresh_token"]
         scope=response.json()["scope"]
     except requests.exceptions.HTTPError as error:
         print(error.response.status_code, error.response.text)

     # If we get this far, we successfully authenticated and have an access token in 'myaccesstoken' (duh)
     log_it("Fetching current weather data", logf)

     params = {
         'access_token': myaccesstoken,
         'device_id'   : 'FIXME: Your Netatmo Weather Station MAC address'
     }

     # Poll my Netatmo weather station for the current weather information
     try:
         response = requests.post("https://api.netatmo.com/api/getstationsdata", params=params)
         response.raise_for_status()
         data = response.json()["body"]

         # Iterate over the modules, until we find the outside station named in 'outdoor_module'
         for item in data['devices'][0]['modules']:
             if item['module_name'] == outdoor_module:
                 # Found the outdoor module - grab the temp and store as a string.
                 myTemp=str(item['dashboard_data'].get('Temperature'))
                 log_it("Outside Temp: " + myTemp + "ºC", logf)
     except requests.exceptions.HTTPError as error:
         print(error.response.status_code, error.response.text)

     # We should now have a value for the outside temperature in 'myTemp' stored as a string.

     # Process the values we're interested in, using the supported precision (see https://pvoutput.org/help.html) etc.
     # Store as strings to save conversion later - we don't need to manipulate the values further.
     # Because we used "-d 0 -e" to pull data via the "aurora" binary, the resultant output columns are:
     # NOTE: All values are floats with varying precision
     #   solarparams[0]  = Input 1 Voltage (V)
     #   solarparams[1]  = Input 1 Current (A)
     #   solarparams[2]  = Input 1 Power (W)
     #   solarparams[3]  = Input 2 Voltage (V)
     #   solarparams[4]  = Input 2 Current (A)
     #   solarparams[5]  = Input 2 Power (W)
     #   solarparams[6]  = Grid Voltage Reading (V)
     #   solarparams[7]  = Grid Current Reading (A)
     #   solarparams[8]  = Grid Power Reading (W)
     #   solarparams[9]  = Frequency Reading (Hz)
     #   solarparams[10] = DC/AC Conversion Efficiency
     #   solarparams[11] = Inverter Temperature (ºC)
     #   solarparams[12] = Booster Temperature (ºC)
     #   solarparams[13] = Daily Energy (kWh cumulative)
     #   solarparams[14] = Weekly Energy (kWh cumulative)
     #   solarparams[15] = Monthly Energy (kWh cumulative)
     #   solarparams[16] = Yearly Energy (kWh cumulative)
     #   solarparams[17] = Total Energy (kWh cumulative)
     #   solarparams[18] = Partial Energy (kWh cumulative)
     #   solarparams[19] = Status (should always be "OK")

     pvenergy=str(int(float(solarparams[13])*1000))   # Inverter output kWh, PVOutput needs Wh
     pvpower=str(int(round(float(solarparams[8]),0))) # Convert a float to rounded integer for PVOutput
     pvvolts=str(round(float(solarparams[6]),1))      # Reduce precision to 1 decimal place for PVOutput

     # Dump some debug info.
     print("Data to send to PVOutput")
     print("    Date:   ",myDate)
     print("    Time:   ",myTime)
     print("    Temp:   ",myTemp)
     print("    Energy: ",pvenergy)
     print("    Power:  ",pvpower)
     print("    Volts:  ",pvvolts)

     # Open the CSV data file for capturing exactly what we want upload
     outf=open(pvOutputLog, "a+")
     outf.write(myDate + "," + myTime + "," + pvenergy + "," + pvpower + "," + myTemp + "," + pvvolts + "\n")

     # Create POST payload (the data)
     payload={
         'd'  : myDate,
         't'  : myTime,
         'v1' : pvenergy,
         'v2' : pvpower,
         'v5' : myTemp,
         'v6' : pvvolts
         }
     # Add the headers so PVOutput.org know what system this is for
     headers={
         'X-Pvoutput-Apikey'   : pvoAPIKey,
         'X-Pvoutput-SystemId' : pvoSysID
     }

     # Now send the data to PVOutput.org (ie, svcURL web API)
     postit=requests.post(pvoSvcURL, data=payload, headers=headers)
     log_it("Attempting upload to PVOutput: " + str(postit.status_code) + " " + postit.reason, logf)

 else:
     log_it("No response from inverter - probably sleeping", logf)