Skip to content

Commit

Permalink
Update S3 Object Lambda sample code
Browse files Browse the repository at this point in the history
  • Loading branch information
kdnakt committed Dec 22, 2023
1 parent 90a9fb6 commit 0de482b
Showing 1 changed file with 11 additions and 6 deletions.
17 changes: 11 additions & 6 deletions events/README_S3_Object_Lambda.md
Original file line number Diff line number Diff line change
Expand Up @@ -20,16 +20,16 @@ import (
"github.com/aws/aws-sdk-go-v2/service/s3"
)

func handler(ctx context.Context, event events.S3ObjectLambdaEvent) (*s3.WriteGetObjectResponseOutput, error) {
func handler(ctx context.Context, event events.S3ObjectLambdaEvent) error {
url := event.GetObjectContext.InputS3Url
resp, err := http.Get(url)
if err != nil {
return nil, err
return err
}
defer resp.Body.Close()
bodyBytes, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
return err
}
transformedObject := TransformedObject{
Metadata: Metadata{
Expand All @@ -39,19 +39,24 @@ func handler(ctx context.Context, event events.S3ObjectLambdaEvent) (*s3.WriteGe
}
jsonData, err := json.Marshal(transformedObject)
if err != nil {
return nil, err
return err
}
cfg, err := config.LoadDefaultConfig(context.TODO())
if err != nil {
return nil, err
return err
}
svc := s3.NewFromConfig(cfg)
input := &s3.WriteGetObjectResponseInput{
RequestRoute: &event.GetObjectContext.OutputRoute,
RequestToken: &event.GetObjectContext.OutputToken,
Body: strings.NewReader(string(jsonData)),
}
return svc.WriteGetObjectResponse(ctx, input)
res, err := svc.WriteGetObjectResponse(ctx, input)
if err != nil {
return err
}
fmt.Printf("%v", res)
return nil
}

func toMd5(data []byte) string {
Expand Down

0 comments on commit 0de482b

Please sign in to comment.