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

revert max time because pytibber bug is still there

Browse source
This commit is contained in:
Jan-Ole Hübner 2024-05-11 12:27:19 +02:00
parent 230391cb32
commit 34959edd9a
1 changed files with 14 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

14
pulse.py
View file

@ -12,7 +12,6 @@ from influxdb_client.client.write_api import SYNCHRONOUS
from DataPoints import Pulse from DataPoints import Pulse
import logging import logging
TOKEN = os.getenv('TOKEN', '') TOKEN = os.getenv('TOKEN', '')
TIBBERTOKEN = os.getenv('TIBBERTOKEN', '') TIBBERTOKEN = os.getenv('TIBBERTOKEN', '')
URL = os.getenv('URL', "") URL = os.getenv('URL', "")
@ -31,13 +30,14 @@ logger.addHandler(ch)
logger.setLevel(logging.INFO) logger.setLevel(logging.INFO)
__version__ = "v0.1.6" __version__ = "v0.1.0"
logger.info(__version__) 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)
query_api = client.query_api() query_api = client.query_api()
def _incoming(pkg): def _incoming(pkg):
try: try:
data = pkg.get("data") data = pkg.get("data")
@ -50,6 +50,7 @@ def _incoming(pkg):
except: except:
exit(1) exit(1)
async def run(): async def run():
conn = aiohttp.TCPConnector(limit_per_host=3) conn = aiohttp.TCPConnector(limit_per_host=3)
async with aiohttp.ClientSession(trust_env=True, connector=conn) as session: async with aiohttp.ClientSession(trust_env=True, connector=conn) as session:
@ -70,13 +71,12 @@ async def run():
home = tibber_connection.get_homes()[0] home = tibber_connection.get_homes()[0]
await home.rt_subscribe(_incoming) await home.rt_subscribe(_incoming)
timeout = time.time() + 1800 # Set a timeout for 3600 seconds (1 hour) timeout = time.time() + 18000 # Set a timeout for 3600 seconds (1 hour)
while time.time() < timeout: while time.time() < timeout:
await asyncio.sleep(2) await asyncio.sleep(5)
loop = asyncio.new_event_loop()
loop = asyncio.get_event_loop() asyncio.set_event_loop(loop)
loop.run_until_complete(run()) loop.run_until_complete(run())
exit(42) exit(42)