Process SQS records, validate order messages, and send valid orders to a Kinesis stream for the data lake.
The SQS event containing records to process.
An object with batchItemFailures, an array of entries each containing itemIdentifier for records that failed processing.
batchItemFailures
itemIdentifier
Error If sending a record to Kinesis fails.
Process SQS records, validate order messages, and send valid orders to a Kinesis stream for the data lake.