ExternalVendorCode/sondehub-infra
1
0
Fork 0
mirror of https://github.com/projecthorus/sondehub-infra.git synced 2025-04-22 17:51:03 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #144 from projecthorus/graw-ps15

Browse Source 
Handle Graw PS-15 sondes
This commit is contained in:
Mark Jessop 2024-06-20 17:27:02 +09:30 committed by GitHub
commit 0250d3fc41
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lambda/sonde_api_to_iot_core/__init__.py
View File

@ -260,8 +260,8 @@ def telemetry_filter(telemetry):
else:
vaisala_callsign_valid = False
# Just make sure we're not getting the 'xxxxxxxx' unknown serial from the DFM decoder.
if "DFM" in telemetry["type"]:
# Just make sure we're not getting the 'xxxxxxxx' unknown serial from the DFM decoder (Which also includes PS-15 pilotsondes)
if "DFM" in telemetry["type"] or telemetry["type"] == "PS-15":
dfm_callsign_valid = "x" not in _serial
else:
dfm_callsign_valid = False
@ -292,14 +292,9 @@ def telemetry_filter(telemetry):
or ("WxR" in telemetry["type"])
):
_id_msg = "Payload ID %s from Sonde type %s is invalid." % (telemetry["serial"], telemetry["type"])
# Add in a note about DFM sondes and their oddness...
if "DFM" in telemetry["serial"]:
_id_msg += " Note: DFM sondes may take a while to get an ID."
if "MRZ" in telemetry["serial"]:
_id_msg += " Note: MRZ sondes may take a while to get an ID."
return ("errors", _id_msg)
# https://github.com/projecthorus/sondehub-infra/issues/56
if "iMet-4" == telemetry["type"] or "iMet-1" == telemetry["type"]:
if telemetry["software_name"] == "radiosonde_auto_rx":

11
lambda/sonde_api_to_iot_core/__main__.py
View File

@ -233,5 +233,16 @@ class TestIngestion(unittest.TestCase):
self.assertEqual(output["body"], "^v^ telm logged")
self.assertEqual(output["statusCode"], 200)
def test_ps15_payload(self):
payload = copy.deepcopy(example_body)
payload[0]["datetime"] = datetime.datetime.now().isoformat()
payload[0]["type"] = "PS-15"
payload[0]["subtype"] = "PS-15"
payload[0]["serial"] = "21068595"
output = lambda_handler(compress_payload(payload), fakeContext())
sns.publish.assert_called()
self.assertEqual(output["body"], "^v^ telm logged")
self.assertEqual(output["statusCode"], 200)
if __name__ == '__main__':
unittest.main()