我正在运行气流管道,但代码看起来不错,但实际上我得到了气流。异常。气流异常:在 DAG 中检测到循环。错误的任务:你能帮助解决这个问题吗
我正在尝试列出 S3 中子目录下的文件,但无法列出文件名:
import boto
from boto.s3.connection import S3Connection
access=''
secret=''
conn=S3Connection(access,secret)
bucket1=conn.get_bucket('bucket-name')
prefix='sub -directory -path'
print bucket1.list(prefix)
files_list=bucket1.list(prefix,delimiter='/')
print files_list
for files in files_list:
print files.name
Run Code Online (Sandbox Code Playgroud)
你能帮我解决这个问题吗?