adding utils

Author: geospatial-jeff

stac_updater/utils.py

@@ -0,0 +1,39 @@
+import json
+
+
+def stac_to_sns(stac_item):
+    """Convert a STAC item to SNS message (with attributes)"""
+
+    try:
+        collection = stac_item['collection']
+    except KeyError:
+        collection = stac_item['properties']['collection']
+
+    attributes = {
+        'bbox.xmin': {
+            "DataType": "Number",
+            "StringValue": str(stac_item['bbox'][0])
+        },
+        'bbox.ymin': {
+            "DataType": "Number",
+            "StringValue": str(stac_item['bbox'][1])
+        },
+        'bbox.xmax': {
+            "DataType": "Number",
+            "StringValue": str(stac_item['bbox'][2])
+        },
+        'bbox.ymax': {
+            "DataType": "Number",
+            "StringValue": str(stac_item['bbox'][3])
+        },
+        'collection': {
+            "DataType": "String",
+            "StringValue": collection
+        },
+    }
+
+    return {
+        "Message": json.dumps(stac_item),
+        "MessageAttributes": attributes
+    }
+