aboutsummaryrefslogtreecommitdiffstats
path: root/elvia2pgsql.py
diff options
context:
space:
mode:
authorDennis Eriksen <d@ennis.no>2023-02-01 20:32:11 +0100
committerDennis Eriksen <d@ennis.no>2023-02-01 20:32:11 +0100
commit8d186d39483beff64a1c11f80c6ca5e56dd7bbc5 (patch)
tree2c5a64ace4bd8eabd4d65014c5313bd7edd76191 /elvia2pgsql.py
parentrun queue in batches (diff)
downloadenergyscripts-8d186d39483beff64a1c11f80c6ca5e56dd7bbc5.tar.gz
moving and renaming/breaking everything
Diffstat (limited to 'elvia2pgsql.py')
-rwxr-xr-xelvia2pgsql.py57
1 files changed, 0 insertions, 57 deletions
diff --git a/elvia2pgsql.py b/elvia2pgsql.py
deleted file mode 100755
index be5eaae..0000000
--- a/elvia2pgsql.py
+++ /dev/null
@@ -1,57 +0,0 @@
-#!/usr/bin/env python3
-''' elvia2pgsql '''
-
-import os
-import sys
-import requests
-
-from datetime import datetime
-from datetime import timedelta
-from tzlocal import get_localzone
-
-from common import dbi
-
-apiKey = os.environ['el_elvia_token']
-apiUrl = "https://elvia.azure-api.net/customer/metervalues/api/v1/metervalues"
-
-pg_table = "elvia"
-
-startTime = datetime.now(get_localzone()) - timedelta(days = 2)
-startTime = startTime.isoformat('T')
-endTime = datetime.now(get_localzone()).isoformat('T')
-
-
-### Get the data
-try:
- url = apiUrl + "?startTime=" + startTime + "&endTime=" + endTime
-
- # Request headers
- hdr = {
- 'Cache-Control': 'no-cache',
- 'Authorization': "Bearer " + apiKey,
- }
-
- response = requests.get(url, headers=hdr)
- if response.status_code != 200:
- print(response.status_code)
- print("Oh shit")
- response.raise_for_status()
-
-except Exception as e:
- print("oh lol")
- sys.exit(e)
-
-data = response.json()
-print("Got "+ str(len(data['meteringpoints'][0]['metervalue']['timeSeries'])) +" items from between "+ startTime + " and " + endTime)
-
-### insert data into database
-
-values = []
-for item in data['meteringpoints'][0]['metervalue']['timeSeries']:
- # Only deal with verified items.
- if item['verified']:
- values.append((data['meteringpoints'][0]['meteringPointId'], item['startTime'], item['endTime'], item['value'], item['uom'], item['production']))
-
-
-# Count new rows and insert
-dbi("INSERT INTO " + pg_table + " VALUES(%s,%s,%s,%s,%s,%s) ON CONFLICT (startTime,endTime) DO NOTHING", values, verbose=True)