如何获取 S3 存储桶中所有不同前缀的列表？

Question

如果我的目录结构如下，前缀是/folder1，

/folder1/folder11/folder12/folder13/*.files
               /folder21/folder22/folder23/*.files
               /folder31/folder32/*.files

我想动态循环遍历这些目录，以便分别读取每个叶子文件夹中的文件，即我需要一个列表

[
 /folder1/folder11/folder12/folder13/, 
 /folder1/folder21/folder22/folder23/,
 /folder1/folder31/folder32/
]

除了递归遍历每个前缀、获取下一级前缀、连接、获取下一级等，还有更好的方法来获取它，直到到达最后一个（叶）文件夹？

Answer 1

在列出来自 Amazon S3 的对象时，如果您指定 Delimiter='/'，那么它将返回 CommonPrefixes 的列表。这实际上是给定Prefix 的子目录列表。

但是，我建议您不要考虑目录。相反，只需遍历 所有 个对象并查看 Key 即可知道该对象的路径。

如果您只想要包含文件的路径列表，请使用：

import boto3

BUCKET = 'my-bucket'

s3_resource = boto3.resource('s3')
folders = set()

# Find paths of all non-empty objects (to exclude zero-length 'folder' objects)
for object in s3_resource.Bucket(BUCKET).objects.all():
    if object.size > 0 and '/' in object.key:
        folders.add(object.key[:object.key.rfind('/')])

print (folders)

Answer 2

您可以在循环中使用它来获取前缀

def get_list_of_prefixes_from_prefix(bucket, prefix):
    """gets list of prefixes for given bucket and prefix"""
    list_of_prefixes = []
    paginator = boto3.resource('s3').meta.client.get_paginator('list_objects')
    for result in paginator.paginate(Bucket=bucket, Prefix=prefix, Delimiter='/'):
        # print(result)
        if 'CommonPrefixes' in result:
            prefixes = [f['Prefix'] for f in result['CommonPrefixes']]
            list_of_prefixes.extend(prefixes)
    return list_of_prefixes

list_of_prefixes = get_list_of_prefixes_from_prefix('my-bucket', 'my-prefix/')

Answer 3

生成S3 inventory report 并使用 Athena 处理数据。报告的 Athena 表结构也在同一篇 AWS 文章中提到。这是做同样事情的无服务器方法。

Answer 4

import boto3

list_of_prefixes = []

def get_list_of_prefixes(bucket, prefix):
    global list_of_prefixes
    paginator = boto3.resource('s3').meta.client.get_paginator('list_objects')
    for result in paginator.paginate(Bucket=bucket, Prefix=prefix, Delimiter='/'):
        if 'CommonPrefixes' in result:
            for f in result['CommonPrefixes']:
                get_list_of_prefixes(bucket, f['Prefix'])
        else:
            list_of_prefixes.append(prefix)
    return list_of_prefixes

list_of_prefixes = get_list_of_prefixes('my-bucket', 'my-prefix/')

for i in list_of_prefixes:
    print(i)