update id

2025-11-07 16:09:01 -03:00
parent c8b4d9beeb
commit 4c50692cd9
27 changed files with 210 additions and 517 deletions
--- a/streams-events/app/events/replicate_into_postgres.py
+++ b/streams-events/app/events/replicate_into_postgres.py
@@ -53,6 +53,9 @@ def lambda_handler(event: DynamoDBStreamEvent, context: LambdaContext):
                new_image = record.dynamodb.new_image  # type: ignore
                table_name = table_from_arn(record.event_source_arn)  # type: ignore
                keys = record.dynamodb.keys  # type: ignore
+                # Pay attention - key order matters
+                # e.g., {"id": ..., "sk": ...} and {"sk": ..., "id": ...}
+                # generate different MD5 hashes
                _id = md5_hash(str(keys))

                match record.event_name: