From c14cb914eea2bb812fc42cf2c081b91392817cf7 Mon Sep 17 00:00:00 2001
From: Nis Wechselberg <enbewe@enbewe.de>
Date: Sat, 8 Dec 2018 13:59:05 +0100
Subject: [PATCH] Initial version

---
 PyPass.py | 41 +++++++++++++++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 PyPass.py

diff --git a/PyPass.py b/PyPass.py
new file mode 100644
index 0000000..e5d5dd3
--- /dev/null
+++ b/PyPass.py
@@ -0,0 +1,41 @@
+#!/usr/bin/env python3
+
+# pylint: disable=C0103
+
+"""
+Python Telekom Pass Parser
+
+Small script to request data from the portal pass.telekom.de and
+submit it to InfluxDB
+"""
+
+import requests
+from influxdb import InfluxDBClient
+
+REQUEST_API_URL = 'http://pass.telekom.de/api/service/generic/v1/status'
+REQUEST_HEADERS = {'User-Agent': 'Mozilla/4.0'}
+
+HOST_NAME = "Neutestorf-RasPi"
+
+# Send http request to telekom page and extract json response
+response = requests.get(REQUEST_API_URL, headers=REQUEST_HEADERS)
+respJson = response.json()
+
+# Prepare timedata for database
+measurement = [
+    {
+        "measurement": "pass_telekom_de",
+        "tags": {
+            "host": HOST_NAME
+        },
+        "fields": {
+            "initialVolume": respJson['initialVolume'],
+            "usedVolume": respJson['usedVolume'],
+            "remainingSeconds": respJson['remainingSeconds']
+        }
+    }
+]
+
+# Send data to InfluxDB
+influx = InfluxDBClient(host='10.91.12.10', database='network')
+influx.write_points(measurement)