diff --git a/packages/parser/src/schemas/sqs.ts b/packages/parser/src/schemas/sqs.ts index 09aed635ea..5484246e0d 100644 --- a/packages/parser/src/schemas/sqs.ts +++ b/packages/parser/src/schemas/sqs.ts @@ -17,6 +17,10 @@ const SqsAttributesSchema = z.object({ SentTimestamp: z.string(), SequenceNumber: z.string().optional(), AWSTraceHeader: z.string().optional(), + /** + * Undocumented, but used by AWS to support their re-drive functionality in the console + */ + DeadLetterQueueSourceArn: z.string().optional(), }); const SqsRecordSchema = z.object({ diff --git a/packages/parser/tests/events/sqsEvent.json b/packages/parser/tests/events/sqsEvent.json index 2bfcd1c7b8..9bc0a394b4 100644 --- a/packages/parser/tests/events/sqsEvent.json +++ b/packages/parser/tests/events/sqsEvent.json @@ -30,7 +30,8 @@ "ApproximateReceiveCount": "1", "SentTimestamp": "1545082650636", "SenderId": "AIDAIENQZJOLO23YVJ4VO", - "ApproximateFirstReceiveTimestamp": "1545082650649" + "ApproximateFirstReceiveTimestamp": "1545082650649", + "DeadLetterQueueSourceArn": "arn:aws:sqs:us-east-2:123456789012:my-queue-dead" }, "messageAttributes": {}, "md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",