Merge pull request #7 from asfadmin/dms/feat/attributes

PR-5870: Add MessageAttribute
asfadmin · May 3, 2024 · f3f4d4d · f3f4d4d
2 parents 1a27b1c + 3708f10
commit f3f4d4d
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