diff --git a/src/granule_to_sns.py b/src/granule_to_sns.py
index f1310e8..f30e297 100644
--- 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