feat: add MessageAttribute

asfadmin · May 3, 2024 · 3708f10 · 3708f10
1 parent 1a27b1c
commit 3708f10
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/granule_to_sns.py b/src/granule_to_sns.py
@@ -38,6 +38,12 @@ def granule_to_sns(event: dict, _) -> dict:
         client.publish(
             TopicArn=sns_topic_arn,
             Message=message,
+            MessageAttributes={
+                "collection": {
+                    "DataType": "String",
+                    "StringValue": granule["dataType"],
+                },
+            },
         )
 
     return event