【发布时间】:2020-10-16 05:01:52
【问题描述】:
我已阅读 this Medium 文章,这是搜索自动缩放和 Cloud Composer 时最热门的文章之一。它显示了一些“hacks”,您可以在 Composer 仍然配置为使用 CeleryExecutor 时使用它们来自动缩放 Composer。
我还阅读了 GCP docs 关于将 KubernetesPodOperator (KPO) 与 Cloud Composer 结合使用的内容,并且之前已经实现了。
但是,使用 KPO 意味着您无法使用所有其他 Airflow Operators - 您必须每次都编写自己的容器和代码。
KubernetesExecutor 似乎是最好的前进方式 - 您可以使用 Airflow Operators,并且可以从 it will create a new Kubernetes Pod for every task instance 启用自动缩放。
Google Cloud Composer 目前在CeleryExecutor 上运行,它目前在Blocked Airflow Configurations 中声明
Cloud Composer 将 Airflow 配置为使用 Celery 执行器 对于
core-executor设置。
KubernetesExecutor 是否会成为 Composer 的选项?
【问题讨论】:
标签: airflow google-cloud-composer