File tree Expand file tree Collapse file tree 2 files changed +41
-0
lines changed
integration-kinesis-to-lambda Expand file tree Collapse file tree 2 files changed +41
-0
lines changed Original file line number Diff line number Diff line change
1
+ package main
2
+
3
+ import (
4
+ "context"
5
+ "log"
6
+
7
+ "github.com/aws/aws-lambda-go/events"
8
+ "github.com/aws/aws-lambda-go/lambda"
9
+ )
10
+
11
+ func handler (ctx context.Context , kinesisEvent events.KinesisEvent ) error {
12
+ if len (kinesisEvent .Records ) == 0 {
13
+ log .Printf ("empty Kinesis event received" )
14
+ return nil
15
+ }
16
+
17
+ for _ , record := range kinesisEvent .Records {
18
+ log .Printf ("processed Kinesis event with EventId: %v" , record .EventID )
19
+ recordDataBytes := record .Kinesis .Data
20
+ recordDataText := string (recordDataBytes )
21
+ log .Printf ("record data: %v" , recordDataText )
22
+ // TODO: Do interesting work based on the new data
23
+ }
24
+ log .Printf ("successfully processed %v records" , len (kinesisEvent .Records ))
25
+ return nil
26
+ }
27
+
28
+ func main () {
29
+ lambda .Start (handler )
30
+ }
Original file line number Diff line number Diff line change 52
52
"language" : " dotnet"
53
53
}
54
54
]
55
+ },
56
+ {
57
+ "id" : " Go" ,
58
+ "title" : " Usage Example with Go:" ,
59
+ "description" : " Consuming Kinesis event with Lambda using Go without batch item handling." ,
60
+ "snippets" : [
61
+ {
62
+ "snippetPath" : " main.go" ,
63
+ "language" : " go"
64
+ }
65
+ ]
55
66
}
56
67
]
57
68
}
You can’t perform that action at this time.
0 commit comments