sqs to lambda in cdk

sqs to lambda in cdk

import { SQSEvent } from 'aws-lambda'

export const handler = async (event: SQSEvent) => {
  const batchItemFailures: { itemIdentifier: string }[] = []
  try {
    const sqsMessages = event.Records
    for (const message of sqsMessages) {
      const messageId = message.messageId
      try { // your Logic goes here

        console.log(`OK: Message processed successfully`)
      } catch (err) {
        console.log(`FAIL: ${err}`)
        batchItemFailures.push({ itemIdentifier: messageId })
      }
    }
    return {
      statusCode: 200,
      batchItemFailures: batchItemFailures,
      body: 'OK: Message processed successfully',
    }
  } catch (err) {
    return {
      statusCode: 500,
      // Allow functions to return partially successful responses for a batch of records
      batchItemFailures: event.Records.map(e => ({ itemIdentifier: e.messageId })),
      body: err,
    }
  }
}