dongzhuange2625 2017-10-17 17:35
浏览 263
已采纳

如何使用适用于GOlang的AWS开发工具包清空S3存储桶?

Goal: To empty an existing S3 bucket using the AWS SDK for GOlang.

  • 写回答

4条回答 默认 最新

  • duanfei8399 2017-10-17 18:00
    关注

    NOTE: These are code snippets that might require YOU to make changes on YOUR SIDE to make it run.

    You will need to implement the below method:

      //EmptyBucket empties the Amazon S3 bucket
        func (s awsS3) EmptyBucket(bucket string) error {
            log.Info("removing objects from S3 bucket : ", bucket)
            params := &s3.ListObjectsInput{
                Bucket: aws.String(bucket),
            }
            for {
                //Requesting for batch of objects from s3 bucket
                objects, err := s.Client.ListObjects(params)
                if err != nil {
                    return err
                }
                //Checks if the bucket is already empty
                if len((*objects).Contents) == 0 {
                    log.Info("Bucket is already empty")
                    return nil
                 }
                log.Info("First object in batch | ", *(objects.Contents[0].Key))
    
                //creating an array of pointers of ObjectIdentifier
                objectsToDelete := make([]*s3.ObjectIdentifier, 0, 1000)
                for _, object := range (*objects).Contents {
                    obj := s3.ObjectIdentifier{
                        Key: object.Key,
                    }
                    objectsToDelete = append(objectsToDelete, &obj)
                }
                //Creating JSON payload for bulk delete
                deleteArray := s3.Delete{Objects: objectsToDelete}
                deleteParams := &s3.DeleteObjectsInput{
                    Bucket: aws.String(bucket),
                    Delete: &deleteArray,
                }
                //Running the Bulk delete job (limit 1000)
                _, err = s.Client.DeleteObjects(deleteParams)
                if err != nil {
                    return err
                }
                if *(*objects).IsTruncated { //if there are more objects in the bucket, IsTruncated = true
                    params.Marker = (*deleteParams).Delete.Objects[len((*deleteParams).Delete.Objects)-1].Key
                    log.Info("Requesting next batch | ", *(params.Marker))
                } else { //if all objects in the bucket have been cleaned up.
                    break
                }
            }
            log.Info("Emptied S3 bucket : ", bucket)
            return nil
        } 
    

    UPDATE : The latest version of AWS SDK for GO has resolved the prior issue I had.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥100 set_link_state
  • ¥15 虚幻5 UE美术毛发渲染
  • ¥15 CVRP 图论 物流运输优化
  • ¥15 Tableau online 嵌入ppt失败
  • ¥100 支付宝网页转账系统不识别账号
  • ¥15 基于单片机的靶位控制系统
  • ¥15 真我手机蓝牙传输进度消息被关闭了,怎么打开?(关键词-消息通知)
  • ¥15 装 pytorch 的时候出了好多问题,遇到这种情况怎么处理?
  • ¥20 IOS游览器某宝手机网页版自动立即购买JavaScript脚本
  • ¥15 手机接入宽带网线,如何释放宽带全部速度