misc.py 文件源码

def delete_keys(bucket_name, key_pattern):
    cfg = Config()
    # connect to the bucket
    conn = boto.connect_s3(cfg.get("aws", "access_key_id"),
                            cfg.get("aws", "secret_access_key"))

    ret_val = True

    try:
        print("# S3: Fetching Keys from Bucket: {0}".format(bucket_name))
        bucket = conn.get_bucket(bucket_name)

        for key in bucket.get_all_keys():
            print key
            if os.path.basename(key.name).startswith(key_pattern):
                key.delete()
                print 'Deleted {0}'.format(key.name)
    except boto.exception.S3ResponseError as err:
        print(err)
        ret_val = False

    return ret_val