-
-
Notifications
You must be signed in to change notification settings - Fork 4.2k
SNS: support passing MessageGroupId
to non-FIFO topic
#13019
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
007ecdb
to
227c351
Compare
Test Results - Preflight, Unit22 139 tests 20 404 ✅ 6m 27s ⏱️ Results for commit 8a98ce0. ♻️ This comment has been updated with latest results. |
Test Results (amd64) - Acceptance7 tests 5 ✅ 3m 10s ⏱️ Results for commit 8a98ce0. ♻️ This comment has been updated with latest results. |
Test Results (amd64) - Integration, Bootstrap 5 files 5 suites 1h 31m 18s ⏱️ Results for commit 8a98ce0. ♻️ This comment has been updated with latest results. |
LocalStack Community integration with Pro 2 files 2 suites 1h 3m 6s ⏱️ Results for commit 8a98ce0. ♻️ This comment has been updated with latest results. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
that's a cool new feature! LGTM
standard_message = SqsMessage( | ||
time.time(), | ||
message, | ||
message_group_id=message_group_id, | ||
) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks for catching and fixing this!
Motivation
Related to #13008 -> https://aws.amazon.com/about-aws/whats-new/2025/07/amazon-sns-standard-topics-sqs-fair-queues/
Since adding support for SQS Fair Queues, we can now pass a
MessageGroupId
to non-FIFO topic.This PR implements that behavior in SNS, removing the previously raised exception, and properly passing the attribute.
This also fixes the behavior in SQS itself following #12930, because we were not adding the
MessageGroupId
to theAttributes
of the received Message, as this only done for FIFO queue. I've updated the SQS test to verify thisChanges
SQS.SendMessage
MessageGroupId
asAttributes
of the message