README
¶
lambda-partialbatch 
Support for AWS Lambda's Partial Batch Response for DynamoDB, Kinesis and SQS in Golang
Example
package main
import (
"context"
"log"
"github.com/aws/aws-lambda-go/events"
"github.com/aws/aws-lambda-go/lambda"
partialbatch "github.com/bored-engineer/lambda-partialbatch"
)
func handler(ctx context.Context, msg events.SQSMessage) error {
// TODO: Some processing that could fail
return nil
}
func main() {
// Process batches of SQS messages
lambda.Start(partialbatch.SQS(
handler,
// Recover from any panics, treating as a failed record
partialbatch.WithRecovery(true),
// For FIFO queues, halt after the first failure
partialbatch.WithHalt(true),
// Log any errors for debugging/alerting
partialbatch.WithErrorCallback(func(_ context.Context, itemIdentifier string, err error) {
log.Printf("failed to process SQS message %q: %s", itemIdentifier, err)
}),
))
}
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamoDBHandler ¶
type DynamoDBHandler interface {
func(context.Context, events.DynamoDBEventRecord) error |
func(context.Context, events.DynamoDBEventRecord) |
func(events.DynamoDBEventRecord) error |
func(events.DynamoDBEventRecord)
}
DynamoDBHandler processes a single events.DynamoDBEventRecord
type DynamoDBProcessor ¶
type DynamoDBProcessor func(context.Context, events.DynamoDBEvent) (events.DynamoDBEventResponse, error)
DynamoDBProcessor can be passed directly to lamdba.Handle
func DynamoDB ¶
func DynamoDB[THandler DynamoDBHandler](handler THandler, opts ...Option) DynamoDBProcessor
DynamoDB processes each DynamoDBEventRecord in a DynamoDBEvent by invoking the provided DynamoDBHandler
type KinesisEventHandler ¶
type KinesisEventHandler interface {
func(context.Context, events.KinesisEventRecord) error |
func(context.Context, events.KinesisEventRecord) |
func(events.KinesisEventRecord) error |
func(events.KinesisEventRecord)
}
KinesisEventHandler processes a single events.KinesisEventRecord
type KinesisProcessor ¶
type KinesisProcessor func(context.Context, events.KinesisEvent) (events.KinesisEventResponse, error)
DynamoDBProcessor can be passed directly to lamdba.Handle
func Kinesis ¶
func Kinesis[THandler KinesisEventHandler](handler THandler, opts ...Option) KinesisProcessor
Kinesis processes each DynamoDBEventRecord in a DynamoDBEvent by invoking the provided DynamoDBHandler
type Option ¶
type Option func(*options)
Option modifies the behavior of the event processing
func WithErrorCallback ¶
WithErrorCallback is invoked (if non-nil) when an error occurs processing an item Typically this is used to log the error for debugging/alerting
func WithRecovery ¶
WithRecovery captures any panics treating them as a returned error
type SQSHandler ¶
type SQSHandler interface {
func(context.Context, events.SQSMessage) error |
func(context.Context, events.SQSMessage) |
func(events.SQSMessage) error |
func(events.SQSMessage)
}
SQSHandler processes a single events.SQSMessage
type SQSProcessor ¶
SQSProcessor can be passed directly to lamdba.Handle
func SQS ¶
func SQS[THandler SQSHandler](handler THandler, opts ...Option) SQSProcessor
SQS processes each SQSMessage in a SQSEvent by invoking the provided SQSHandler
Source Files