matthias/EuropaParkCheck
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

repeat every 30 seconds

Browse Source
This commit is contained in:
Matthias Bilger
2019-09-05 17:43:07 +02:00
parent 3c70b1bca0
commit 0ba63e99c6
1 changed files with 39 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
epgrab.py
View File

@@ -4,7 +4,9 @@ import logging
import tinydb import tinydb
import json import json
import pushover import pushover
import time
logging.basicConfig(level=logging.DEBUG) logging.basicConfig(level=logging.DEBUG)
_logger = logging.getLogger(__name__)
pushover.init('abz8is31hd3m2e36g62w4msihj87cr') pushover.init('abz8is31hd3m2e36g62w4msihj87cr')
db = tinydb.TinyDB(os.getenv('DB_FILE',default='/data/grabbing.json')) db = tinydb.TinyDB(os.getenv('DB_FILE',default='/data/grabbing.json'))
@@ -17,9 +19,12 @@ def thash(inp: str):
cfgs = db.table('cfgs') cfgs = db.table('cfgs')
grabs = db.table('grabs') grabs = db.table('grabs')
Entry = tinydb.Query() Entry = tinydb.Query()
_logger.info('initialization done, start grabbing')
while True:
g = grab.Grab() g = grab.Grab()
for cfg in config['grab']: for cfg in config['grab']:
cfgid = thash(str(cfg)) cfgid = thash(str(cfg))
_logger.info('grabbing with config %s', cfgid)
cfgentry = {'id': cfgid} cfgentry = {'id': cfgid}
cfgentry.update(cfg) cfgentry.update(cfg)
if len(cfgs.search(Entry.id == cfgid)) == 0: if len(cfgs.search(Entry.id == cfgid)) == 0:
@@ -49,7 +54,7 @@ for cfg in config['grab']:
'info': info 'info': info
}) })
pushover.Client("u5w9h8gc7hpzvr5a2kh2xh4m9zpidq").send_message(txt, title=txt[:50], url=url) pushover.Client("u5w9h8gc7hpzvr5a2kh2xh4m9zpidq").send_message(txt, title=txt[:50], url=url)
_logger.info('news found %s', info)
_logger.info('sleeping')
time.sleep(30)