diff options
Diffstat (limited to 'europastats/attractions.py')
| -rw-r--r-- | europastats/attractions.py | 21 |
1 files changed, 15 insertions, 6 deletions
diff --git a/europastats/attractions.py b/europastats/attractions.py index 9a6c087..53bbfa4 100644 --- a/europastats/attractions.py +++ b/europastats/attractions.py @@ -1,7 +1,15 @@ #!/usr/bin/env python """ - takes a list of openweathermap ids and a config dict with - "openweathermap_apikey" + tag fields: + status (open closed) + type + name + metrics: + statuscode (0-6) + waitingtime + unused: + _ts (timestamp) + """ from datetime import datetime as dt import sys @@ -24,7 +32,7 @@ status_codes = [ api_url = "https://api.europapark.de/api-5.4/" def get_db(id): - with open(abspath(join(dirname(__name__),"europastats/data",id+".json")),'rb') as f: + with open(abspath(join(dirname(__file__),"data",id+".json")),'rb') as f: return json.load(f) name_mapping = { a["code"]: a for a in get_db("attractions") } @@ -59,12 +67,13 @@ def get_data(mock=False): resp = get_live("waitingtimes") for v in resp: data = {} + data["status"] = status_codes[v["status"]] - data["_name"] = "Attraktion {}".format( name_mapping[v["code"]]["nameGerman"]) - data["_id"] = "europapark-{}-{}".format(name,v["code"]) + data["statuscode"] = v["status"] + data["name"] = "Attraktion {}".format( name_mapping[v["code"]]["nameGerman"]) + data["type"] = name data["waitingtime"] = v["time"] data["_ts"] = now.isoformat(timespec="seconds") + "Z" - data["_db"] = name yield data def main(): |