Merge pull request #96 from awsryancwj/main

add go snippet for lambda-kinesis

Author: yualexan

integration-kinesis-to-lambda/main.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"context"
+	"log"
+
+	"github.com/aws/aws-lambda-go/events"
+	"github.com/aws/aws-lambda-go/lambda"
+)
+
+func handler(ctx context.Context, kinesisEvent events.KinesisEvent) error {
+	if len(kinesisEvent.Records) == 0 {
+		log.Printf("empty Kinesis event received")
+		return nil
+	}
+
+	for _, record := range kinesisEvent.Records {
+		log.Printf("processed Kinesis event with EventId: %v", record.EventID)
+		recordDataBytes := record.Kinesis.Data
+		recordDataText := string(recordDataBytes)
+		log.Printf("record data: %v", recordDataText)
+		// TODO: Do interesting work based on the new data
+	}
+	log.Printf("successfully processed %v records", len(kinesisEvent.Records))
+	return nil
+}
+
+func main() {
+	lambda.Start(handler)
+}

integration-kinesis-to-lambda/snippet-data.json

@@ -3,7 +3,7 @@
   "description": "Using AWS Lambda with Amazon Kinesis without Batch Item Handling.",
   "type": "Integration",
   "services": ["lambda", "kinesis"],
-  "languages": ["Node", "TypeScript", ".NET","Java"],
+  "languages": ["Node", "TypeScript", ".NET", "Java"],
   "tags": [],
   "introBox": {
     "headline": "How it works",
@@ -63,6 +63,17 @@
               "language": "java"
             }
           ]
+        },
+        {
+          "id": "Go",
+          "title": "Usage Example with Go:",
+          "description": "Consuming Kinesis event with Lambda using Go without batch item handling.",
+          "snippets": [
+            {
+              "snippetPath": "main.go",
+              "language": "go"
+            }
+          ]
         }
       ]
     }