ExternalVendorCode/sondehub-infra
1
0
Fork 0
mirror of https://github.com/projecthorus/sondehub-infra.git synced 2025-01-18 18:56:26 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add files via upload

Browse Source
This commit is contained in:
Luke Prior 2022-01-26 15:21:51 +11:00 committed by GitHub
parent 97b5541d17
commit c21c549778
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
lambda/recovery_ingest/__init__.py
View File

@ -1,14 +1,18 @@
from datetime import datetime,timezone
from datetime import datetime
import urllib.request
import json
import os
params = "?token=eZNqv6dLjzFzv2bseAQTxDS3pER5uSh8&period=2"
apiKey = os.environ["radiosondy-apikey"]
params = "?token={}&period=2".format(apiKey)
url = "https://radiosondy.info/api/v1/sonde-logs{}".format(params)
recoveryUrl = "https://api.v2.sondehub.org/recovered"
searchUrl = "https://api.v2.sondehub.org/sondes"
response = urllib.request.urlopen(url)
data = json.load(response)
# Check exisiting SondeHub recovery reports
def checkExisting(serial, recovered):
# Get SondeHub recoveries for serial
recoveryCheckParams = "?serial={}".format(serial)
@ -27,6 +31,7 @@ def checkExisting(serial, recovered):
# Valid recovery report already exists
return False
# Attempt to find SondeHub serial for a Radiosony.info serial
def findSonde(recovery, lat, lon):
# Get facts to compare against
launchTime = datetime.strptime(recovery["start_time"], "%Y-%m-%d %H:%M:%S")
@ -52,6 +57,7 @@ def findSonde(recovery, lat, lon):
return serial
# Process each recovery report from Radiosondy.info
for recovery in data["results"]:
# Get recovery status
@ -89,18 +95,20 @@ for recovery in data["results"]:
else:
serial = findSonde(recovery, lat, lon)
if serial is None:
print(recovery["sonde_number"] + ": could not match to SondeHub serial")
continue
# Check if a valid recovery already exists
if checkExisting(serial, recovered) == False:
print(serial + ": recovery already exists")
continue
# Format data for upload
recoveryPutData = {"datetime": recovered_time.isoformat(), "serial": serial, "lat": lat, "lon": lon, "recovered": recovered, "recovered_by": recovered_by, "description": description}
recoveryPutData = str(json.dumps(recoveryPutData)).encode('utf-8')
print(recoveryPutData)
print(serial + ": " + recoveryPutData)
# Upload data
recoveryPutRequest = urllib.request.Request(recoveryUrl, data=recoveryPutData, method="PUT")
print(urllib.request.urlopen(recoveryPutRequest).read().decode('utf-8'))
print(serial + ": " + urllib.request.urlopen(recoveryPutRequest).read().decode('utf-8'))