From 69a3f4034e508767cea5eb3e3d8e1e3256df1543 Mon Sep 17 00:00:00 2001 From: Jason Sia Date: Thu, 9 Nov 2023 18:23:19 +0800 Subject: [PATCH 1/6] added go snippet for integration-sqs-to-lambda --- integration-sqs-to-lambda/Function.go | 29 +++++++++++++++++++++ integration-sqs-to-lambda/snippet-data.json | 13 ++++++++- 2 files changed, 41 insertions(+), 1 deletion(-) create mode 100644 integration-sqs-to-lambda/Function.go diff --git a/integration-sqs-to-lambda/Function.go b/integration-sqs-to-lambda/Function.go new file mode 100644 index 0000000..a3d656b --- /dev/null +++ b/integration-sqs-to-lambda/Function.go @@ -0,0 +1,29 @@ +package integration_sqs_to_lambda + +import ( + "context" + "fmt" + "github.com/aws/aws-lambda-go/events" + "github.com/aws/aws-lambda-go/lambda" +) + +func handler(ctx context.Context, event events.SQSEvent) error { + for _, record := range event.Records { + err := processMessage(record) + if err != nil { + return err + } + } + fmt.Println("done") + return nil +} + +func processMessage(record events.SQSMessage) error { + fmt.Printf("Processed message %s\n", record.Body) + // TODO: Do interesting work based on the new message + return nil +} + +func main() { + lambda.Start(handler) +} diff --git a/integration-sqs-to-lambda/snippet-data.json b/integration-sqs-to-lambda/snippet-data.json index 894d8f1..266f719 100644 --- a/integration-sqs-to-lambda/snippet-data.json +++ b/integration-sqs-to-lambda/snippet-data.json @@ -3,7 +3,7 @@ "description": "Sample Amazon SQS function code", "type": "Integration", "services": ["lambda", "sqs"], - "languages": ["Node", ".NET", "TypeScript", "Java","Python"], + "languages": ["Node", ".NET", "TypeScript", "Java","Python","Golang"], "tags": [], "introBox": { "headline": "How it works", @@ -74,6 +74,17 @@ "language": "py" } ] + }, + { + "id": "Golang", + "title": "Usage Example with Golang:", + "description": "Sample Amazon SQS function code using Golang without batch item handling.", + "snippets": [ + { + "snippetPath": "Function.py", + "language": "go" + } + ] } ] } From 40b1631f045cc1e1cbe185cb38d6c7a9b7ec7dcc Mon Sep 17 00:00:00 2001 From: Jason Sia Date: Thu, 9 Nov 2023 18:24:29 +0800 Subject: [PATCH 2/6] fixed typo --- integration-sqs-to-lambda/snippet-data.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration-sqs-to-lambda/snippet-data.json b/integration-sqs-to-lambda/snippet-data.json index 266f719..c69c632 100644 --- a/integration-sqs-to-lambda/snippet-data.json +++ b/integration-sqs-to-lambda/snippet-data.json @@ -81,7 +81,7 @@ "description": "Sample Amazon SQS function code using Golang without batch item handling.", "snippets": [ { - "snippetPath": "Function.py", + "snippetPath": "Function.go", "language": "go" } ] From 5de6c15134f6b5ee4565865db912008c5fbfad0f Mon Sep 17 00:00:00 2001 From: Jason Sia Date: Thu, 16 Nov 2023 09:15:59 +0800 Subject: [PATCH 3/6] refactored func handler --- integration-sqs-to-lambda/Function.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/integration-sqs-to-lambda/Function.go b/integration-sqs-to-lambda/Function.go index a3d656b..d079825 100644 --- a/integration-sqs-to-lambda/Function.go +++ b/integration-sqs-to-lambda/Function.go @@ -1,13 +1,12 @@ package integration_sqs_to_lambda import ( - "context" "fmt" "github.com/aws/aws-lambda-go/events" "github.com/aws/aws-lambda-go/lambda" ) -func handler(ctx context.Context, event events.SQSEvent) error { +func handler(event T) error { for _, record := range event.Records { err := processMessage(record) if err != nil { From 1b67f2e141e6a298b3da66dd4648630b3adf23b8 Mon Sep 17 00:00:00 2001 From: Jason Sia Date: Thu, 16 Nov 2023 09:27:53 +0800 Subject: [PATCH 4/6] refactored func handler --- integration-sqs-to-lambda/Function.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration-sqs-to-lambda/Function.go b/integration-sqs-to-lambda/Function.go index d079825..0b57043 100644 --- a/integration-sqs-to-lambda/Function.go +++ b/integration-sqs-to-lambda/Function.go @@ -6,7 +6,7 @@ import ( "github.com/aws/aws-lambda-go/lambda" ) -func handler(event T) error { +func handler(event events.SQSEvent) error { for _, record := range event.Records { err := processMessage(record) if err != nil { From 7307be3670d61d4957f4bb6cb00092721ff312b5 Mon Sep 17 00:00:00 2001 From: David Boyne Date: Tue, 5 Dec 2023 16:00:55 +0000 Subject: [PATCH 5/6] Update integration-sqs-to-lambda/snippet-data.json --- integration-sqs-to-lambda/snippet-data.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration-sqs-to-lambda/snippet-data.json b/integration-sqs-to-lambda/snippet-data.json index c69c632..ef25204 100644 --- a/integration-sqs-to-lambda/snippet-data.json +++ b/integration-sqs-to-lambda/snippet-data.json @@ -3,7 +3,7 @@ "description": "Sample Amazon SQS function code", "type": "Integration", "services": ["lambda", "sqs"], - "languages": ["Node", ".NET", "TypeScript", "Java","Python","Golang"], + "languages": ["Node", ".NET", "TypeScript", "Java","Python","Go"], "tags": [], "introBox": { "headline": "How it works", From 9aa5dad72e6116c6d220f33c00e8cdc4bb6914e4 Mon Sep 17 00:00:00 2001 From: David Boyne Date: Tue, 5 Dec 2023 16:00:59 +0000 Subject: [PATCH 6/6] Update integration-sqs-to-lambda/snippet-data.json --- integration-sqs-to-lambda/snippet-data.json | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/integration-sqs-to-lambda/snippet-data.json b/integration-sqs-to-lambda/snippet-data.json index ef25204..45d4a89 100644 --- a/integration-sqs-to-lambda/snippet-data.json +++ b/integration-sqs-to-lambda/snippet-data.json @@ -76,7 +76,7 @@ ] }, { - "id": "Golang", + "id": "Go", "title": "Usage Example with Golang:", "description": "Sample Amazon SQS function code using Golang without batch item handling.", "snippets": [