SQS

[nzoschke]

SQS is an event source worth demoing and documenting

[StevenACoffman]

Resources:

• AWS Golang SQS Lambda Function example
• AWS Golang SQS example code (Source code for the following examples):
  • Using Amazon SQS Queues
  • Sending and Receiving Messages in Amazon SQS
  • Managing Visibility Timeout in Amazon SQS Queues
  • Enabling Long Polling in Amazon SQS Queues
  • Using Dead Letter Queues in Amazon SQS
  • Setting Attributes on an Amazon SQS Queue

Sample Function

The following is a sample class and Lambda function that receives Amazon SQS event message data as input, writes some of the message data to CloudWatch Logs, and responds with a 200 status and the same body as the request. (Note that by default anything written to Console will be logged as CloudWatch Logs events.)

package main

import (
    "context"
    "fmt"

    "github.com/aws/aws-lambda-go/events"
    "github.com/aws/aws-lambda-go/lambda"
)

func handler(ctx context.Context, sqsEvent events.SQSEvent) error {
    for _, message := range sqsEvent.Records {
        fmt.Printf("The message %s for event source %s = %s \n", message.MessageId, message.EventSource, message.Body)
    }

    return nil
}

func main() {
    lambda.Start(handler)
}

[StevenACoffman]

While I know that the following resources are not golang or SAM, this might be a useful template for what to cover in this repo on SQS and Lambda:

• Using SQS with AWS Lambda and Serverless

Topics Covered:

• Using SQS with the Serverless Framework
• Batch Size and Error Handling with the SQS integration
• Protecting your downstream services with concurrency control