问题内容
我在 airflow 中有一个使用 cloud composer 执行的 pythonoperator：
with DAG(
dag_id = config['dag_id'],
schedule_interval = config['schedule_interval'],
default_args = default_args
) as dag:
generate_data_task = PythonOperator(
task_id = 'generate_dummy_data',
python_callable = generate_data,
dag = dag
)
generate_data() 函数将随机生成的唯一命名的 csv 文件写入包含一些数据的存储桶中。按原样执行效果很好，但我想并行多次执行同一任务。如果我指定并行执行 10 次，我预计会在存储桶中写入 10 个文件。我尝试过并发和task_concurrency，但得到了相同的结果。
这可以在 cloud composer 之上使用 airflow 实现吗？
多线程技术在iOS开发中的使用 WORD版
下载
本文档主要讲述的是多线程技术在iOS开发中的使用；所谓进程对应的是一个应用程序,负责开辟内存空间供应用程序使用，但是进程不能执行任务(指令)。一个进程至少包含一条线程，线程是程序的执行流。 iOS程序启动时，在创建一个进程的同时， 会开始运行一个线程，该线程被称为主线程；希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看
正确答案
使用动态任务映射：
generate_data_task = PythonOperator.partial(
task_id = 'generate_dummy_data',
python_callable = generate_data,
dag = dag
).expand(op_args=[[]] * 10) 
