1 files changed, 43 insertions, 0 deletions
diff --git a/europastats/weather.py b/europastats/weather.py
new file mode 100644
index 0000000..db0879c
--- /dev/null
+++ b/europastats/weather.py
@@ -0,0 +1,43 @@
+#!/usr/bin/env python
+"""
+"""
+from datetime import datetime as dt
+from europastats.attractions import get_db, get_live
+import sys
+import json
+import requests
+
+import json
+from os.path import join,dirname
+name = "weather"
+off = [ "Heute",
+        "Morgen",
+        "Übermorgen" ]
+
+def get_data(mock=False):
+    now = dt.utcnow()
+    if mock:
+        resp = get_db(name)
+    else:
+        resp = get_live(name)
+    offset = 0
+    for v in resp:
+        data = {
+                "_id": "europapark-weather-{}".format(offset),
+                "_name": "Europapark Wetter {}".format(off[offset]),
+                "_ts": now.isoformat(timespec="seconds") + "Z",
+                "_db": "weather"
+                }
+        data.update(v)
+        yield data
+        offset = offset + 1
+
+def main():
+    kvt = get_data(True)
+    print(json.dumps(list(kvt)))
+
+def get_mock_data():
+    return get_data(True)
+
+if __name__ == "__main__":
+    main()