Skip to content

Commit ba8ef0a

Browse files
yualexanyualexan
authored
Merge pull request #468 from awsdocs/go-handler-example
Go handler example
2 parents 227a6c0 + a1819af commit ba8ef0a

File tree

4 files changed

+159
-0
lines changed

4 files changed

+159
-0
lines changed

‎sample-apps/example-go/function/event.json

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
{
2+
"order_id": "12345",
3+
"amount": 199.99,
4+
"item": "Wireless Headphones"
5+
}

‎sample-apps/example-go/function/go.mod

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
module example-go
2+
3+
go 1.22.6
4+
5+
require (
6+
github.com/aws/aws-lambda-go v1.47.0
7+
github.com/aws/aws-sdk-go-v2/config v1.27.27
8+
github.com/aws/aws-sdk-go-v2/service/s3 v1.58.3
9+
)
10+
11+
require (
12+
github.com/aws/aws-sdk-go-v2 v1.30.3 // indirect
13+
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3 // indirect
14+
github.com/aws/aws-sdk-go-v2/credentials v1.17.27 // indirect
15+
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.11 // indirect
16+
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.15 // indirect
17+
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.15 // indirect
18+
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.0 // indirect
19+
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.15 // indirect
20+
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.3 // indirect
21+
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.17 // indirect
22+
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.17 // indirect
23+
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.15 // indirect
24+
github.com/aws/aws-sdk-go-v2/service/sso v1.22.4 // indirect
25+
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.26.4 // indirect
26+
github.com/aws/aws-sdk-go-v2/service/sts v1.30.3 // indirect
27+
github.com/aws/smithy-go v1.20.3 // indirect
28+
)

‎sample-apps/example-go/function/go.sum

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
github.com/aws/aws-lambda-go v1.47.0 h1:0H8s0vumYx/YKs4sE7YM0ktwL2eWse+kfopsRI1sXVI=
2+
github.com/aws/aws-lambda-go v1.47.0/go.mod h1:dpMpZgvWx5vuQJfBt0zqBha60q7Dd7RfgJv23DymV8A=
3+
github.com/aws/aws-sdk-go-v2 v1.30.3 h1:jUeBtG0Ih+ZIFH0F4UkmL9w3cSpaMv9tYYDbzILP8dY=
4+
github.com/aws/aws-sdk-go-v2 v1.30.3/go.mod h1:nIQjQVp5sfpQcTc9mPSr1B0PaWK5ByX9MOoDadSN4lc=
5+
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3 h1:tW1/Rkad38LA15X4UQtjXZXNKsCgkshC3EbmcUmghTg=
6+
github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.3/go.mod h1:UbnqO+zjqk3uIt9yCACHJ9IVNhyhOCnYk8yA19SAWrM=
7+
github.com/aws/aws-sdk-go-v2/config v1.27.27 h1:HdqgGt1OAP0HkEDDShEl0oSYa9ZZBSOmKpdpsDMdO90=
8+
github.com/aws/aws-sdk-go-v2/config v1.27.27/go.mod h1:MVYamCg76dFNINkZFu4n4RjDixhVr51HLj4ErWzrVwg=
9+
github.com/aws/aws-sdk-go-v2/credentials v1.17.27 h1:2raNba6gr2IfA0eqqiP2XiQ0UVOpGPgDSi0I9iAP+UI=
10+
github.com/aws/aws-sdk-go-v2/credentials v1.17.27/go.mod h1:gniiwbGahQByxan6YjQUMcW4Aov6bLC3m+evgcoN4r4=
11+
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.11 h1:KreluoV8FZDEtI6Co2xuNk/UqI9iwMrOx/87PBNIKqw=
12+
github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.11/go.mod h1:SeSUYBLsMYFoRvHE0Tjvn7kbxaUhl75CJi1sbfhMxkU=
13+
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.15 h1:SoNJ4RlFEQEbtDcCEt+QG56MY4fm4W8rYirAmq+/DdU=
14+
github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.15/go.mod h1:U9ke74k1n2bf+RIgoX1SXFed1HLs51OgUSs+Ph0KJP8=
15+
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.15 h1:C6WHdGnTDIYETAm5iErQUiVNsclNx9qbJVPIt03B6bI=
16+
github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.15/go.mod h1:ZQLZqhcu+JhSrA9/NXRm8SkDvsycE+JkV3WGY41e+IM=
17+
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.0 h1:hT8rVHwugYE2lEfdFE0QWVo81lF7jMrYJVDWI+f+VxU=
18+
github.com/aws/aws-sdk-go-v2/internal/ini v1.8.0/go.mod h1:8tu/lYfQfFe6IGnaOdrpVgEL2IrrDOf6/m9RQum4NkY=
19+
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.15 h1:Z5r7SycxmSllHYmaAZPpmN8GviDrSGhMS6bldqtXZPw=
20+
github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.15/go.mod h1:CetW7bDE00QoGEmPUoZuRog07SGVAUVW6LFpNP0YfIg=
21+
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.3 h1:dT3MqvGhSoaIhRseqw2I0yH81l7wiR2vjs57O51EAm8=
22+
github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.3/go.mod h1:GlAeCkHwugxdHaueRr4nhPuY+WW+gR8UjlcqzPr1SPI=
23+
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.17 h1:YPYe6ZmvUfDDDELqEKtAd6bo8zxhkm+XEFEzQisqUIE=
24+
github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.17/go.mod h1:oBtcnYua/CgzCWYN7NZ5j7PotFDaFSUjCYVTtfyn7vw=
25+
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.17 h1:HGErhhrxZlQ044RiM+WdoZxp0p+EGM62y3L6pwA4olE=
26+
github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.17/go.mod h1:RkZEx4l0EHYDJpWppMJ3nD9wZJAa8/0lq9aVC+r2UII=
27+
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.15 h1:246A4lSTXWJw/rmlQI+TT2OcqeDMKBdyjEQrafMaQdA=
28+
github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.15/go.mod h1:haVfg3761/WF7YPuJOER2MP0k4UAXyHaLclKXB6usDg=
29+
github.com/aws/aws-sdk-go-v2/service/s3 v1.58.3 h1:hT8ZAZRIfqBqHbzKTII+CIiY8G2oC9OpLedkZ51DWl8=
30+
github.com/aws/aws-sdk-go-v2/service/s3 v1.58.3/go.mod h1:Lcxzg5rojyVPU/0eFwLtcyTaek/6Mtic5B1gJo7e/zE=
31+
github.com/aws/aws-sdk-go-v2/service/sso v1.22.4 h1:BXx0ZIxvrJdSgSvKTZ+yRBeSqqgPM89VPlulEcl37tM=
32+
github.com/aws/aws-sdk-go-v2/service/sso v1.22.4/go.mod h1:ooyCOXjvJEsUw7x+ZDHeISPMhtwI3ZCB7ggFMcFfWLU=
33+
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.26.4 h1:yiwVzJW2ZxZTurVbYWA7QOrAaCYQR72t0wrSBfoesUE=
34+
github.com/aws/aws-sdk-go-v2/service/ssooidc v1.26.4/go.mod h1:0oxfLkpz3rQ/CHlx5hB7H69YUpFiI1tql6Q6Ne+1bCw=
35+
github.com/aws/aws-sdk-go-v2/service/sts v1.30.3 h1:ZsDKRLXGWHk8WdtyYMoGNO7bTudrvuKpDKgMVRlepGE=
36+
github.com/aws/aws-sdk-go-v2/service/sts v1.30.3/go.mod h1:zwySh8fpFyXp9yOr/KVzxOl8SRqgf/IDw5aUt9UKFcQ=
37+
github.com/aws/smithy-go v1.20.3 h1:ryHwveWzPV5BIof6fyDvor6V3iUL7nTfiTKXHiW05nE=
38+
github.com/aws/smithy-go v1.20.3/go.mod h1:krry+ya/rV9RDcV/Q16kpu6ypI4K2czasz0NC3qS14E=
39+
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
40+
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
41+
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
42+
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
43+
github.com/stretchr/testify v1.7.2 h1:4jaiDzPyXQvSd7D0EjG45355tLlV3VOECpq10pLC+8s=
44+
github.com/stretchr/testify v1.7.2/go.mod h1:R6va5+xMeoiuVRoj+gSkQ7d3FALtqAAGI1FQKckRals=
45+
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
46+
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

‎sample-apps/example-go/function/main.go

Lines changed: 80 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,80 @@
1+
package main
2+
3+
import (
4+
"context"
5+
"encoding/json"
6+
"fmt"
7+
"log"
8+
"os"
9+
"strings"
10+
11+
"github.com/aws/aws-lambda-go/lambda"
12+
"github.com/aws/aws-sdk-go-v2/config"
13+
"github.com/aws/aws-sdk-go-v2/service/s3"
14+
)
15+
16+
type Order struct {
17+
OrderID string `json:"order_id"`
18+
Amount float64 `json:"amount"`
19+
Item string `json:"item"`
20+
}
21+
22+
var (
23+
s3Client *s3.Client
24+
)
25+
26+
func init() {
27+
// Initialize the S3 client outside of the handler, during the init phase
28+
cfg, err := config.LoadDefaultConfig(context.TODO())
29+
if err != nil {
30+
log.Fatalf("unable to load SDK config, %v", err)
31+
}
32+
33+
s3Client = s3.NewFromConfig(cfg)
34+
}
35+
36+
func uploadReceiptToS3(ctx context.Context, bucketName, key, receiptContent string) error {
37+
_, err := s3Client.PutObject(ctx, &s3.PutObjectInput{
38+
Bucket: &bucketName,
39+
Key: &key,
40+
Body: strings.NewReader(receiptContent),
41+
})
42+
if err != nil {
43+
log.Printf("Failed to upload receipt to S3: %v", err)
44+
return err
45+
}
46+
return nil
47+
}
48+
49+
func handleRequest(ctx context.Context, event json.RawMessage) error {
50+
// Parse the input event
51+
var order Order
52+
if err := json.Unmarshal(event, &order); err != nil {
53+
log.Printf("Failed to unmarshal event: %v", err)
54+
return err
55+
}
56+
57+
// Access environment variables
58+
bucketName := os.Getenv("RECEIPT_BUCKET")
59+
if bucketName == "" {
60+
log.Printf("RECEIPT_BUCKET environment variable is not set")
61+
return fmt.Errorf("missing required environment variable RECEIPT_BUCKET")
62+
}
63+
64+
// Create the receipt content and key destination
65+
receiptContent := fmt.Sprintf("OrderID: %s\nAmount: $%.2f\nItem: %s",
66+
order.OrderID, order.Amount, order.Item)
67+
key := "receipts/" + order.OrderID + ".txt"
68+
69+
// Upload the receipt to S3 using the helper method
70+
if err := uploadReceiptToS3(ctx, bucketName, key, receiptContent); err != nil {
71+
return err
72+
}
73+
74+
log.Printf("Successfully processed order %s and stored receipt in S3 bucket %s", order.OrderID, bucketName)
75+
return nil
76+
}
77+
78+
func main() {
79+
lambda.Start(handleRequest)
80+
}

0 commit comments

Comments
 (0)