tests.system.amazon.aws.example_appflow_run¶

属性¶

`create_s3_to_s3_flow`(flow_name, bucket_name, source_folder)	创建一个流，该流接收 CSV 文件并将其转换为包含相同数据的 JSON 文件
`setup_bucket_permissions`(bucket_name)
`delete_flow`(flow_name)

tests.system.amazon.aws.example_appflow_run.DAG_ID = 'example_appflow_run'[source]¶

tests.system.amazon.aws.example_appflow_run.create_s3_to_s3_flow(flow_name, bucket_name, source_folder)[source]¶

创建一个流，该流接收 CSV 文件并将其转换为包含相同数据的 JSON 文件

tests.system.amazon.aws.example_appflow_run.setup_bucket_permissions(bucket_name)[source]¶

tests.system.amazon.aws.example_appflow_run.delete_flow(flow_name)[source]¶