Go SDK V2 を使用して MinIO コンテナにファイルをアップロードする方法

package main

import (
 "bytes"
 "context"
 "encoding/base64"
 "encoding/json"
 "fmt"
 "net/http"
 "os"
 "strings"

 "github.com/aws/aws-lambda-go/events"
 "github.com/aws/aws-lambda-go/lambda"
 "github.com/aws/aws-sdk-go-v2/aws"
 "github.com/aws/aws-sdk-go-v2/config"
 "github.com/aws/aws-sdk-go-v2/credentials"
 "github.com/aws/aws-sdk-go-v2/service/s3"
)

type PatchCommand struct {
 Image   string `json:"image"`
}

type Response struct {
 Message string `json:"message"`
}

func Handler(ctx context.Context, request events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {
 // 省略: ロガーの初期化とリクエストのログ記録

 contentType := shared.GetHeaderValue(request.Headers, "content-type")
 if contentType == "" {
  return events.APIGatewayProxyResponse{StatusCode: http.StatusBadRequest, Body: "Content-Type header is missing"}, nil
 }

 fileExt, err := getFileExtension(content.image/jpeg)
 if err != nil {
  return events.APIGatewayProxyResponse{StatusCode: http.StatusBadRequest, Body: err.Error()}, nil
 }

 cfg, err := config.LoadDefaultConfig(ctx, config.WithRegion(os.Getenv("AWS_REGION_CODE")))
 if err != nil {
  // 省略: エラーハンドリング
 }

 s3Client := s3.NewFromConfig(cfg, func(o *s3.Options) {
  o.Credentials = credentials.NewStaticCredentialsProvider("アクセスキー", "シークレットキー", "")
  o.UsePathStyle = true
  o.EndpointResolver = aws.EndpointResolverFunc(func(service, region string) (aws.Endpoint, error) {
   return aws.Endpoint{URL: os.Getenv("S3_ENDPOINT")}, nil
  })
 })

 var cmd PatchCommand
 err = json.Unmarshal([]byte(request.Body), &cmd)
 if err != nil {
  // 省略: エラーハンドリング
 }

 imageData, err := base64.StdEncoding.DecodeString(cmd.Image)
 if err != nil {
  // 省略: エラーハンドリング
 }

 bucket := os.Getenv("S3_BUCKET_NAME")
 key := fmt.Sprintf("images/%s%s", "save-file", fileExt)

 input := &s3.PutObjectInput{
  Bucket:      aws.String(bucket),
  Key:         aws.String(key),
  Body:        bytes.NewReader(imageData),
  ContentType: aws.String(contentType),
 }

 _, err = s3Client.PutObject(ctx, input)
 if err != nil {
  // 省略: エラーハンドリング
 }

 return shared.CreateSuccessResponse(http.StatusOK, "Image uploaded successfully")
}

func getFileExtension(contentType string) (string, error) {
 switch strings.ToLower(contentType) {
 case "image/jpeg":
  return ".jpg", nil
 case "image/png":
  return ".png", nil
 default:
  return "", fmt.Errorf("unsupported content type: %s", contentType)
 }
}

func main() {
 lambda.Start(Handler)
}