Function handleRequest

go/lambda-dynamodb/lambda-handler/main.go:26–53

(ctx context.Context, event MyEvent)

}

func handleRequest(ctx context.Context, event MyEvent) {

	cfg, err := config.LoadDefaultConfig(ctx)
	if err != nil {
		log.Fatalf("Got error loading config: %s", err)
	}

	svc := dynamodb.NewFromConfig(cfg)

	av, err := attributevalue.MarshalMap(event)
	if err != nil {
		log.Fatalf("Got error marshalling new movie item: %s", err)
	}

	tableName := "MyDynamoDB"

	input := &dynamodb.PutItemInput{
		Item:      av,
		TableName: aws.String(tableName),
	}

	_, err = svc.PutItem(ctx, input)
	if err != nil {
		log.Fatalf("Got error calling PutItem: %s", err)
	} else {
		log.Println("Successfully added '" + event.Message + "' to table " + tableName)
	}
}

func main() {
	lambda.Start(handleRequest)