WeatherDataProvider2.py

from datetime import datetime
import requests
import json
import FUNCTIONS.functions

def loadLatestWeatherData():
    api_key = basics.getVarConf('forecast.solar','api_key','str')
    api_pers_plus = basics.getVarConf('forecast.solar','api_pers_plus','str')
    lat = basics.getVarConf('forecast.solar','lat','eval')
    lon = basics.getVarConf('forecast.solar','lon','eval')
    dec = basics.getVarConf('forecast.solar','dec','eval')
    az = basics.getVarConf('forecast.solar','az','eval')
    kwp = basics.getVarConf('forecast.solar','kwp','eval')
    anzahl_strings = basics.getVarConf('pv.strings','anzahl','eval')
    dec2 = basics.getVarConf('forecast.solar2','dec','eval')
    az2 = basics.getVarConf('forecast.solar2','az','eval')
    kwp2 = basics.getVarConf('forecast.solar2','kwp','eval')

    # Unterscheidung zwischen Free, Personal und Personal Plus
    url_anfang ='https://api.forecast.solar'
    url = url_anfang+'/estimate/{}/{}/{}/{}/{}'.format(lat, lon, dec, az, kwp)
    url2 = url_anfang+'/estimate/{}/{}/{}/{}/{}'.format(lat, lon, dec2, az2, kwp2)
    if api_key != 'kein':
        url_anfang = 'https://api.forecast.solar/'+api_key
        url = url_anfang+'/estimate/{}/{}/{}/{}/{}'.format(lat, lon, dec, az, kwp)
        url2 = url_anfang+'/estimate/{}/{}/{}/{}/{}'.format(lat, lon, dec2, az2, kwp2)
        if anzahl_strings == 2 and api_pers_plus == 'ja':
            url = url_anfang+'/estimate/{}/{}/{}/{}/{}/{}/{}/{}'.format(lat, lon, dec, az, kwp, dec2, az2, kwp2)
            anzahl_strings = 1

    try:
        try:
            apiResponse = requests.get(url, timeout=52.50)
            #apiResponse.raise_for_status()
            if apiResponse.status_code == 200:
                json_data1 = dict(json.loads(apiResponse.text))
            else:
                print("### ERROR:  Keine forecasts-Daten von api.forecast.solar")
                print("### ERROR URL:", url)
                exit()
        except:
            print("### ERROR:  Timeout von api.forecast.solar")
            exit()

        #print(json_data1, "\n")
        # Hier werden fuer ein evtl. zweites Feld mit anderer Ausrichtung die Prognosewerte eingearbeitet
        # Koordinaten müssen gleich sein, wegen zeitgleichem Sonnenauf- bzw. untergang 
        if anzahl_strings == 2:
            dict_watts = {}
            dict_watt_hours = {}

            try:
                apiResponse2 = requests.get(url2, timeout=52.50)
                apiResponse2.raise_for_status()
                if apiResponse2.status_code != 204:
                    json_data2 = dict(json.loads(apiResponse2.text))
                else:
                    print("### ERROR:  Keine estimated_actuals-Daten von api.forecast.solar")
                    exit()
            except requests.exceptions.Timeout:
                print("### ERROR:  Timeout von api.forecast.solar")
                exit()
            #print(json_data2, "\n")
		
            if isinstance(json_data1['result'], dict) and isinstance(json_data2['result'], dict):
                for key, value in json_data1.get('result',{}).get('watts',{}).items():
                    dict_watts[key]=value
                for key, value in json_data2.get('result',{}).get('watts',{}).items():
                    if( key in dict_watts):
                        dict_watts[key]=dict_watts[key]+value
                for key, value in json_data1.get('result',{}).get('watt_hours',{}).items():
                    dict_watt_hours[key]=value
                for key, value in json_data2.get('result',{}).get('watt_hours',{}).items():
                    if( key in dict_watt_hours):
                        dict_watt_hours[key]=dict_watt_hours[key]+value
                json_data1['result']['watts']=dict_watts
                json_data1['result']['watt_hours']=dict_watt_hours

        for key in list(json_data1['result']['watts'].keys()):
            if ':15:00' in key or ':30:00' in key or ':45:00' in key:
                del json_data1['result']['watts'][key]
        #print(json_data1, "\n")
        return(json_data1)
    except OSError:
        exit()
        
    
if __name__ == '__main__':
    basics = FUNCTIONS.functions.basics()
    config = basics.loadConfig(['default', 'weather'])
    dataAgeMaxInMinutes = basics.getVarConf('forecast.solar','dataAgeMaxInMinutes','eval')
    
    format = "%Y-%m-%d %H:%M:%S"    
    now = datetime.now()    
    
    weatherfile = basics.getVarConf('forecast.solar','weatherfile','str')
    data = basics.loadWeatherData(weatherfile)
    dataIsExpired = True
    if (data):
        dateCreated = None
        if (data['messageCreated']):
            dateCreated = datetime.strptime(data['messageCreated'], format)
        
        if (dateCreated):
            diff = now - dateCreated
            dataAgeInMinutes = diff.total_seconds() / 60
            if (dataAgeInMinutes < dataAgeMaxInMinutes):                
                print_level = basics.getVarConf('env','print_level','eval')
                if ( print_level != 0 ):
                    print('forecast.solar ERROR: Die Minuten aus "dataAgeMaxInMinutes" ', dataAgeMaxInMinutes ,' Minuten sind noch nicht abgelaufen!!')
                    print(f'[Now: {now}] [Data created:  {dateCreated}] -> age in min: {dataAgeInMinutes}\n')
                dataIsExpired = False

    if (dataIsExpired):
        data = loadLatestWeatherData()
        if isinstance(data['result'], dict):
            if not data == "False":
                # hier evtl Begrenzungen der Prognose anbringen
                MaximalPrognosebegrenzung = basics.getVarConf('env','MaximalPrognosebegrenzung','eval')
                if (MaximalPrognosebegrenzung == 1):
                    data = basics.checkMaxPrognose(data)
                if (MaximalPrognosebegrenzung == 2):
                    data = basics.Prognoseoptimierung(data)
                basics.storeWeatherData(weatherfile, data, now, 'forecast.solar')
                dateCreated_new = data['messageCreated']
                print(f'forecast.solar OK: Prognosedaten vom {dateCreated_new} gespeichert.\n')
        else:
            print("Fehler bei Datenanforderung api.forecast.solar:")
            print(data)