GetObject/HeadObject 永远阻塞问题解决方法

从现在开始，我们要努力学习啦！今天我给大家带来《GetObject/HeadObject 永远阻塞问题解决方法》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

我正在使用 aws-sdk-go 从 s3 下载文件，但是，我发现如果存储桶中不存在密钥，则调用 getobject 将永远阻塞（我从 aws-cli 发现了这一事实）。谁能告诉我发生了什么事吗？这是我的代码片段：

// newS3Session return a s3 session with AddrInfo
func newS3Session(addr AddrInfo) *session.Session {
    cred := credentials.NewStaticCredentials(addr.AccessKey, addr.SecretKey, "")
    sess := session.Must(session.NewSession(&aws.Config{
        Region:           aws.String("default"),
        Credentials:      cred,
        Endpoint:         aws.String(addr.EndPoint),
        S3ForcePathStyle: aws.Bool(false),
        DisableSSL:       aws.Bool(true),
    }))
    return sess
}

func download(_ context.Context, s *session.Session, filename string) error {
    downloader := s3manager.NewDownloader(s)

    file, err := os.Create(tmpPath + filename)
    if err != nil {
        return fmt.Errorf("file_create_error|err=%w,filename=%s", err, filename)
    }
    defer func() {
        err = file.Close()
    }()

    svc := s3.New(s)
    _, err = svc.HeadObjectWithContext(context.Background(), &s3.HeadObjectInput{
        Bucket: aws.String(srcAddr.Bucket),
        Key:    aws.String(filepath.Join(srcAddr.FilePath, filename)),
    })
    if err != nil {
        panic(err)
    }
    fmt.Printf("file_found|filepath:%s\n", filepath.Join(srcAddr.FilePath, filename))

    n, err := downloader.Download(file, &s3.GetObjectInput{
        Bucket: aws.String(srcAddr.Bucket),
        Key:    aws.String(filepath.Join(srcAddr.FilePath, filename)),
    })
    if err != nil {
        return fmt.Errorf("fail_to_download_file|err=%w,filepath=%s", err,
            filepath.Join(srcAddr.FilePath, filename))
    }
    fmt.Printf("file %s downloaded, size=%dB", filename, n)
    return nil
}

当 s3 中存在密钥时，代码可以正常工作

正确答案

我也遇到过类似的问题，这就是问题 - https://tracker.ceph.com/issues/38638

我能够绕过 aws 错误：

if awsErr, ok := err.(awserr.Error); ok && (awsErr.Code() == "Forbidden" || awsErr.Code() == "NotFound") {
    return false, nil
} else if err != nil {
    return false, err
} else {
    return true, nil
}

以上就是《GetObject/HeadObject 永远阻塞问题解决方法》的详细内容，更多关于的资料请关注golang学习网公众号！