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:26:34 +11:00 committed by GitHub
parent c21c549778
commit 693e5f064e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
lambda/recovery_ingest/__init__.py
View File

@ -95,20 +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")
print("{}: could not match to SondeHub serial".format(recovery["sonde_number"]))
continue
# Check if a valid recovery already exists
if checkExisting(serial, recovered) == False:
print(serial + ": recovery already exists")
print("{}: recovery already exists".format(serial))
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(serial + ": " + recoveryPutData)
print("{}: {}".format(serial, recoveryPutData))
# Upload data
recoveryPutRequest = urllib.request.Request(recoveryUrl, data=recoveryPutData, method="PUT")
print(serial + ": " + urllib.request.urlopen(recoveryPutRequest).read().decode('utf-8'))
print("{}: {}".format(serial, urllib.request.urlopen(recoveryPutRequest).read().decode('utf-8')))