Function toLambdaHandler

Transform an effect into an SNSHandler.

import { SQSEvent, toLambdaHandler } from '@effect-lambda/Sqs'
import { Effect, Console } from 'effect'

// Define an effect that processes each message in the SQS event
const processSQSMessages = SQSEvent.pipe(
Effect.map((event) => event.Records),
Effect.tap((records) =>
Effect.forEach(records, (record) =>
Console.log(`Processing message: ${record.body}`)
)
)
)

// Convert the effect into a Lambda handler
export const handler = processSQSMessages.pipe(toLambdaHandler)
  • Parameters

    • effect: Effect<void | BatchResponse, never, HandlerContext | SQSEvent>

      Effect.Effect<void, never, SQSEvent | HandlerContext>

    Returns SQSHandler

    SNSHandler