Das deutsche Python-Forum

Code: Alles auswählen

	while True:	
		try:
			devList = lnetatmo.DeviceList(authorization)
			break
		except:
			print ("Netatmo server did not respond, will retry in 60 seconds")
			time.sleep(60)

Code: Alles auswählen

authorization = lnetatmo.ClientAuth()

Code: Alles auswählen

def postRequest(url, params):
    if version_info.major == 3:
        req = urllib.request.Request(url)
        req.add_header("Content-Type","application/x-www-form-urlencoded;charset=utf-8")
        params = urllib.parse.urlencode(params).encode('utf-8')
        resp = urllib.request.urlopen(req, params).readall().decode("utf-8")
    else:
        params = urlencode(params)
        headers = {"Content-Type" : "application/x-www-form-urlencoded;charset=utf-8"}
        req = urllib2.Request(url=url, data=params, headers=headers)
        resp = urllib2.urlopen(req).read()
    return json.loads(resp)

Code: Alles auswählen

#!/usr/bin/python3
# encoding=utf-8

import time
import sqlite3
import lnetatmo

# Make a connection to the database and check to see if it succeeded.
try:
	conn = sqlite3.connect("netatmo.db")
	cur = conn.cursor()
except Exception as e:
	print("FATAL Netatmo: Database not found")
	sys.exit()
	
def set_date_time(date):
	if len(date) == 1:
		return "0" + date
	else:
		return date

while True:
	# 1 : Authenticate
	authorization = lnetatmo.ClientAuth()

	# 2 : Get devices list
	while True:	# funktioniert nicht
		try:
			devList = lnetatmo.DeviceList(authorization)
			break
		except:
			print ("Netatmo server did not respond, will retry in 60 seconds")
			time.sleep(60)
		
	theData = devList.lastData()
	for i in theData:
		# check for new devices
		zu_lesen = "SELECT * FROM geraete WHERE geraet = '" + i + "'" 
		cur.execute(zu_lesen)
		res = cur.fetchall()
		if not res:
			zu_erfassen = "INSERT INTO geraete VALUES ('" + i + "')"
			print (zu_erfassen)
			cur.execute(zu_erfassen)
		# get actual data from devices
		mintemp = 0
		maxtemp = 0
		luftdruck = 0
		geraeusch = 0
		co2 = 0
		luftfeuchtigkeit = 0
		batterie = 0
		temperatur = devList.lastData()[i]['Temperature']
		timestamp = str(time.localtime()[0]) + set_date_time(str(time.localtime()[1])) + set_date_time(str(time.localtime()[2])) + '-' + set_date_time(str(time.localtime()[3])) + set_date_time(str(time.localtime()[4]))
		print (i, timestamp)
		try:
			mintemp = devList.lastData()[i]['min_temp']
		except:
			pass
		try:
			maxtemp = devList.lastData()[i]['max_temp']
		except:
			pass
		try:
			luftdruck = devList.lastData()[i]['Pressure']
		except:
			pass
		try:
			geraeusch = devList.lastData()[i]['Noise']
		except:
			pass
		try:
			co2 = devList.lastData()[i]['CO2']
		except:
			pass
		try:
			luftfeuchtigkeit = devList.lastData()[i]['Humidity']
		except:
			pass
		try:
			batterie = devList.lastData()[i]['battery_vp']
#			print(i, "Batteriestatus   :", "OK" if int(batterie) > 5000 else "ersetzen" )
		except:
			pass
		
		werte = (i, timestamp, temperatur, luftdruck, geraeusch, co2, luftfeuchtigkeit, batterie)
		zu_erfassen = "INSERT INTO daten VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
		cur.execute(zu_erfassen, werte)
		
		timestamp = str(time.localtime()[0]) + set_date_time(str(time.localtime()[1])) + set_date_time(str(time.localtime()[2]))
		zu_lesen = "SELECT * FROM minmaxtemperatur WHERE geraet = '" + i + "' AND datum = " + timestamp
		cur.execute(zu_lesen)
		res = cur.fetchall()
		if not res or res[0][1] != timestamp:
			zu_erfassen = "INSERT INTO minmaxtemperatur VALUES (?, ?, ?, ?)"
			werte = (i, timestamp, mintemp, maxtemp)
			cur.execute(zu_erfassen, werte)
		elif res[0][2] != mintemp or res[0][3] != maxtemp:
			zu_erfassen = "UPDATE minmaxtemperatur SET mintemp = " + str(mintemp) + ", maxtemp = " + str(maxtemp) + " where geraet = '" + i + "' and datum = " + timestamp
			cur.execute(zu_erfassen)
		
		while True:
			try:
				conn.commit()
				break
			except:
				print ("Database seems to be locked, will retry in 60 seconds")
				time.sleep(60)
		
	time.sleep(600)

Code: Alles auswählen

for geraet, data in devList.lastData().items():
    [...]

Code: Alles auswählen

cur.execute("INSERT OR IGNORE INTO geraete VALUES (?)", (geraet, ))

Code: Alles auswählen

timestamp = "{:%Y%m%d-%H%M}".format(datetime.datetime.now())

Code: Alles auswählen

mintemp = data.get('min_temp', 0)

Code: Alles auswählen

#!/usr/bin/env python
# coding: utf8
from __future__ import absolute_import, division, print_function

import sqlite3
from datetime import datetime as DateTime
from time import sleep
from urllib2 import URLError

import lnetatmo


def main():
    connection = sqlite3.connect('netatmo.db')
    cursor = connection.cursor()

    while True:
        try:
            devices = lnetatmo.DeviceList(lnetatmo.ClientAuth())
        except URLError:
            print('Problem with Netatmo server, will retry in 60 seconds')
            sleep(60)
        else:
            for name, values in devices.lastData().items():
                cursor.execute(
                    'SELECT id FROM device WHERE name=?', (name,)
                )
                result = cursor.fetchone()
                if result:
                    device_id = result[0]
                else:
                    cursor.execute(
                        'INSERT INTO device(name) VALUES (?)', (name,)
                    )
                    device_id = cursor.lastrowid

                timestamp = DateTime.now()
                cursor.execute(
                    'INSERT INTO daten(device_id, `timestamp`, temperature,'
                    ' pressure, noise, co_2, humidity, battery_vp)'
                    ' VALUES (?, ?, ?, ?, ?, ?, ?, ?)',
                    (
                        device_id,
                        timestamp,
                        values['Temperature'],
                        values.get('Pressure', 0),
                        values.get('Noise', 0),
                        values.get('CO2', 0),
                        values.get('Humidity', 0),
                        values.get('battery_vp', 0),
                    )
                )

                date = format(timestamp, '%Y-%m-%d')
                cursor.execute(
                    'INSERT OR REPLACE INTO extrema(device_id, `date`,'
                    '   min_value, max_value)'
                    'VALUES (?, ?, ?, ?)'
                    'WHERE device_id=? AND `date`=?',
                    (
                        device_id,
                        date,
                        values.get('min_temp', 0),
                        values.get('max_temp', 0),
                        device_id,
                        date,
                    )
                )
                while True:
                    try:
                        connection.commit()
                        break
                    except sqlite3.Error:
                        print(
                            'Database seems to be locked,'
                            ' will retry in 5 seconds'
                        )
                        sleep(5)

            sleep(600)


if __name__ == '__main__':
    main()