@org/source
    Preparing search index...

    Function orderLakeHandler

    • Process SQS records, validate order messages, and send valid orders to a Kinesis stream for the data lake.

      Parameters

      • event: SQSEvent

        The SQS event containing records to process.

      Returns Promise<{ batchItemFailures: { itemIdentifier: string }[] }>

      An object with batchItemFailures, an array of entries each containing itemIdentifier for records that failed processing.

      Error If sending a record to Kinesis fails.