我正在為我的項目開發一項服務，用于同步 AWS 中的 Lambda 工作。這個想法是編寫一個 TrackerFile 模塊來在 S3 上存儲結構。每次使用跟蹤器時，我都會檢查是否有一個文件的名稱分配給被調用的跟蹤器。我不知道如何安全地檢查 S3 上是否存在給定名稱的文件。你能展示一段代碼示例嗎？如果文件存在，它能夠返回 (bool, err) 其中 bool 為 True 嗎？
4 回答
翻翻過去那場雪
TA貢獻2065條經驗 獲得超14個贊
確保您具有以下權限：“s3:GetObject”、“s3:ListBucket”、
關于安全性，AWS剛剛為S3引入了強一致性
s3svc = s3.New(sess)
func keyExists(bucket string, key string) (bool, error) {
_, err := s3svc.HeadObject(&s3.HeadObjectInput{
Bucket: aws.String(bucket),
Key: aws.String(key),
})
if err != nil {
if aerr, ok := err.(awserr.Error); ok {
switch aerr.Code() {
case "NotFound": // s3.ErrCodeNoSuchKey does not work, aws is missing this error code so we hardwire a string
return false, nil
default:
return false, err
}
}
return false, err
}
return true, nil
}
隔江千里
TA貢獻1906條經驗 獲得超10個贊
如果您使用適用于 Go V2 的 AWS 開發工具包：
import (
? ? ...
? ? awshttp "github.com/aws/aws-sdk-go-v2/aws/transport/http"
? ? ...
)
func uploaded(ctx context.Context, client *s3.Client, bucket string, key string) (bool, error) {
? ? _, err := client.HeadObject(ctx, &s3.HeadObjectInput{
? ? ? ? Bucket: aws.String(bucket),
? ? ? ? Key:? ? aws.String(key),
? ? })
? ? if err != nil {
? ? ? ? var responseError *awshttp.ResponseError
? ? ? ? if errors.As(err, &responseError) && responseError.ResponseError.HTTPStatusCode() == http.StatusNotFound {
? ? ? ? ? ? return false, nil
? ? ? ? }
? ? ? ? return false, err
? ? }
? ? return true, nil
}
慕容3067478
TA貢獻1773條經驗 獲得超3個贊
您可以嘗試使用以下代碼來獲取對象元數據：
sess, err := session.NewSession(&aws.Config{
? ? Region: aws.String("your-region"),
})
if err != nil {
? ? //handle error here
}
svc := s3.New(session.Must(sess, err))
output, err := svc.HeadObject(&s3.HeadObjectInput{
? ? Bucket: aws.String("bucket_name"),
? ? Key:? ? aws.String("object_key"),
})
if err != nil {
? ? //handle error here
}
fmt.Println(output.LastModified) //do something with metadata
偶然的你
TA貢獻1841條經驗 獲得超3個贊
只需參考 AWS API S3 HeadObject 方法：AWS API 文檔。如果缺少對象，它將返回狀態代碼 404。
HEAD 請求與對象上的 GET 操作具有相同的選項。該響應與 GET 響應相同，只是沒有響應正文。因此，如果 HEAD 請求生成錯誤，它會返回通用的 404 Not Found 或 403 Forbidden 代碼。
import (
? "context"
? "github.com/aws/aws-sdk-go-v2/aws"
? "github.com/aws/aws-sdk-go-v2/service/s3"
? "log"
)
func IsObjectExistsInS3Bucket(bucketName string, objectKey string) bool{
? _, err := executeHeadObjectMethodOnS3Api(bucketName, objectKey)
? return ! handleErrorOnS3HeadObjectAction(bucketName, objectKey, err)
}
func executeHeadObjectMethodOnS3Api(bucketName string, objectKey string) (output *s3.HeadObjectOutput, err error){
? s3Client := getS3Client()
? return s3Client.HeadObject(context.TODO(), &s3.HeadObjectInput{
? ? Bucket:? ? ? ? ? ? ? ?aws.String(bucketName),
? ? Key:? ? ? ? ? ? ? ? ? aws.String(objectKey),
? })
}
func handleErrorOnS3HeadObjectAction(bucketName, objectKey string, err error) (hit bool){
? logUnableToHeadObjectFromS3Bucket(bucketName, objectKey, err)
? return err != nil
}
func logUnableToHeadObjectFromS3Bucket(bucketName string, objectKey string, err error) {
? if err != nil {
? ? log.Printf("Unable to head object {%s} from S3 bucket {%s}: { %v }", objectKey, bucketName, err)
? }
}
- 4 回答
- 0 關注
- 198 瀏覽
添加回答
舉報
0/150
提交
取消