diff options
author | Dennis Eriksen <d@ennis.no> | 2023-02-01 20:32:11 +0100 |
---|---|---|
committer | Dennis Eriksen <d@ennis.no> | 2023-02-01 20:32:11 +0100 |
commit | 8d186d39483beff64a1c11f80c6ca5e56dd7bbc5 (patch) | |
tree | 2c5a64ace4bd8eabd4d65014c5313bd7edd76191 /elvia2pgsql.py | |
parent | run queue in batches (diff) | |
download | energyscripts-8d186d39483beff64a1c11f80c6ca5e56dd7bbc5.tar.gz |
moving and renaming/breaking everything
Diffstat (limited to 'elvia2pgsql.py')
-rwxr-xr-x | elvia2pgsql.py | 57 |
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) |