golang函数的云服务集成

import (

    "context"

    "fmt"

    "io"

    "github.com/aws/aws-sdk-go/aws"

    "github.com/aws/aws-sdk-go/aws/session"

    "github.com/aws/aws-sdk-go/service/s3"

)

// uploadFileToS3 上传文件到 Amazon S3 存储桶中。

func uploadFileToS3(w io.Writer, bucket, key, filePath string) error {

    // 创建一个新的 S3 客户端。

    sess := session.Must(session.NewSession())

    client := s3.New(sess)

    // 使用文件路径打开一个文件。

    file, err := os.Open(filePath)

    if err != nil {

        return fmt.Errorf("os.Open: %v", err)

    }

    defer file.Close()

    // 上传文件到指定的存储桶和键中。

    _, err = client.PutObjectWithContext(context.Background(), &s3.PutObjectInput{

        Bucket: aws.String(bucket),

        Key:    aws.String(key),

        Body:   file,

    })

    if err != nil {

        return fmt.Errorf("PutObjectWithContext: %v", err)

    }

    fmt.Fprintf(w, "Uploaded file to %s/%s\n", bucket, key)

    return nil

}

import (

    "context"

    "fmt"

    "log"

    vision "cloud.google.com/go/vision/apiv1"

    "cloud.google.com/go/vision/v2/apiv1/visionpb"

)

// detectLabelsFromGCS 分析存储在 Google Cloud Storage 的图像。

func detectLabelsFromGCS(w io.Writer, gcsURI string) error {

    ctx := context.Background()

    c, err := vision.NewImageAnnotatorClient(ctx)

    if err != nil {

        return fmt.Errorf("vision.NewImageAnnotatorClient: %v", err)

    }

    defer c.Close()

    image := &visionpb.Image{

        Source: &visionpb.ImageSource{

            GcsImageUri: gcsURI,

        },

    }

    annotations, err := c.DetectLabels(ctx, image, nil, 10)

    if err != nil {

        return fmt.Errorf("DetectLabels: %v", err)

    }

    if len(annotations) == 0 {

        fmt.Fprintln(w, "No labels found.")

    } else {

        fmt.Fprintln(w, "Labels:")

        for _, annotation := range annotations {

            fmt.Fprintln(w, annotation.Description)

        }

    }

    return nil

}