WIS2 MQTT client side filtering: add platform as wigos_station_identifier

Author: istvans-mn

ingest/api/generate_wis2_payload.py

@@ -63,6 +63,7 @@ def generate_wis2_payload(message: dict, request_url: str) -> Wis2MessageSchema:
             metadata_id=WIS2_METADATA_RECORD_ID,  # Need to figure out how we generate this? Is it staic or dynamic?
             datetime=message["properties"]["datetime"],
             pubtime=message["properties"]["pubtime"],
+            wigos_station_identifier=message["properties"]["platform"],
             standard_name=standard_name,
             hamsl=message["properties"]["hamsl"],
             function=message["properties"]["function"],

ingest/api/wis2_model.py

@@ -86,6 +86,10 @@ class Properties(BaseModel):
         None,
         description="Identifies the end date/time date of the data being recorded, in RFC3339 format.",
     )
+    wigos_station_identifier: Optional[str] = Field(
+        None,
+        description="WIGOS-ID of the platform(s) (if exists), or a generated WIGOS-like ID.",
+    )
     standard_name: Optional[str] = Field(
         None,
         description="CF standard for the data included in this message.",