janolehuebner/tibber-influx
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

add logger

Browse source
This commit is contained in:
Jan-Ole Hübner 2023-09-02 23:02:50 +02:00
parent 8c45fe8e1f
commit fbd90b8206
1 changed files with 18 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

23
pulse.py
View file

@ -1,6 +1,6 @@
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
import os import os
import random import sys
import tibber.const import tibber.const
import asyncio import asyncio
@ -9,6 +9,7 @@ import tibber
from influxdb_client import InfluxDBClient from influxdb_client import InfluxDBClient
from influxdb_client.client.write_api import SYNCHRONOUS from influxdb_client.client.write_api import SYNCHRONOUS
from DataPoints import Pulse from DataPoints import Pulse
import logging
TOKEN=os.getenv('TOKEN', '') TOKEN=os.getenv('TOKEN', '')
TIBBERTOKEN=os.getenv('TIBBERTOKEN', '') TIBBERTOKEN=os.getenv('TIBBERTOKEN', '')
@ -16,9 +17,21 @@ URL = os.getenv('URL',"" )
BUCKET = os.getenv('BUCKET',"tibber" ) BUCKET = os.getenv('BUCKET',"tibber" )
ORG = os.getenv('ORG',"Default" ) ORG = os.getenv('ORG',"Default" )
__version__ = "v0.0.2" #logging
print(f"tibber_{__version__}") logger = logging.getLogger("TibberInflux")
formatter = logging.Formatter(
'%(asctime)s - %(name)s - %(levelname)s - %(message)s')
ch=logging.StreamHandler(sys.stdout)
#fh = logging.FileHandler('log.log')
ch.setFormatter(formatter)
#fh.setFormatter(formatter)
logger.addHandler(ch)
#logger.addHandler(fh)
logger.setLevel(logging.INFO)
__version__ = "v0.0.3"
logger.info(__version__)
client = InfluxDBClient(url=URL, token=TOKEN, org=ORG) client = InfluxDBClient(url=URL, token=TOKEN, org=ORG)
write_api = client.write_api(write_options=SYNCHRONOUS) write_api = client.write_api(write_options=SYNCHRONOUS)
@ -31,7 +44,7 @@ def _incoming(pkg):
exit(1) exit(1)
p = Pulse(data).get_datapoint() p = Pulse(data).get_datapoint()
write_api.write(record=p, bucket=BUCKET) write_api.write(record=p, bucket=BUCKET)
print(p) logger.info(p)
return True return True
except: except:
exit(1) exit(1)
@ -39,7 +52,7 @@ def _incoming(pkg):
async def run(): async def run():
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
if session.closed: if session.closed:
print("session closed") logger.error("session closed")
exit(1) exit(1)
tibber_connection = tibber.Tibber(TIBBERTOKEN, websession=session, user_agent="python") tibber_connection = tibber.Tibber(TIBBERTOKEN, websession=session, user_agent="python")
await tibber_connection.update_info() await tibber_connection.update_info()