0

我正在用 aws lambda 编写我的第一个 golang api。这个想法是能够从浏览器录制音频并保存为 s3 中的对象。我已经能够将对象保存在 s3 存储桶中的所需位置，但文件的大小始终为 0 / 0 kbs。但是当我创建一个文件并写入它时，它有大小。

这是我的代码：

func Handler(ctx context.Context, event PutAudiosEvent) (string, error) {
    decoded, err := base64.StdEncoding.DecodeString(event.FileContents)
    if err != nil {
        fmt.Println("Error decoding string")
        return "", err
    }
    //fmt.Println("Decoded is:", decoded)

    f, err := os.Create("/tmp/" + event.FileName)
    if err != nil {
        fmt.Println("Error creating file")
        return "", err
    }
    defer f.Close()

    numBytes, err := f.Write(decoded)
    fmt.Println("Num bytes:", numBytes)
    if err != nil {
        fmt.Println("Error writing")
        return "", err
    }

    if err = f.Sync(); err != nil {
        fmt.Println("Error syncing")
        return "", err
    }

    fileInfo, err := f.Stat()
    fmt.Println("Size:", fileInfo.Size())
    fmt.Println("Name:", fileInfo.Name())
    fmt.Println("Is dir:", fileInfo.IsDir())
    fmt.Println("Mode:", fileInfo.Mode())
    fmt.Println("Modtime", fileInfo.ModTime())
    fmt.Println("fileSys:", fileInfo.Sys())

    fmt.Println(event.UserName + "/" + event.Course + "/" + event.FileName)
    resp, err := s3Uploader.Upload(&s3manager.UploadInput{
        Bucket: aws.String(BUCKET_NAME),
        Key: aws.String(event.UserName + "/" + event.Course + "/" + event.Type + "/" + event.FileName),
        Body: f,
        ContentType: aws.String("audio/mpeg"),
    })

    if err != nil {
        fmt.Println("Error uploading", err)
        fmt.Println("Resp is:", resp)
        return "Error2", nil
    }

    return "File named '" + event.FileName + "' successfully uploaded", nil
}

以下是 cloudwatch 的一些输出：在此处输入图像描述

这是空对象：

在此处输入图像描述

那么我做错了什么？

4

1 回答 1

3

您刚刚创建并写入文件f，然后将其用作上传Body。发生的情况是文件中的当前位置在最后——这意味着有 0 个字节要读取。

您需要到Seek文件的开头，以便有数据可以读取。

无论哪种方式，对于这个用例，在上传之前都没有必要将文件写入存储——您可以使用您已经拥有的内存表示将其直接上传到 S3 decoded。

于 2021-02-27T00:04:36.870 回答