airflow 相关问题

Airflow是一个工作流管理平台,可以编程方式创作,安排和监控工作流,作为任务的有向非循环图(DAG)。

选择哪个?也许还有其他更好的选择?

在您的用例上 - 触发工作流程为VM供电,运行过程并关闭它们,任务范围从几分钟到数小时不等 - 时间似乎更合适。暂时性是为长期运行,有弹性,状态工作流程而建造的,在使用可以动态和动态电源的VM时,它将提供更好的可靠性和容错性。

回答 0 投票 0

如何停止/杀死UI

如何停止/杀死气流UI上的运行任务?我正在使用Localexecutor。 即使我使用CeleryExecutor,我该如何杀死/停止运行任务?

回答 6 投票 0


AirFlow:删除文件的DAG导入错误

i在k8s上部署了气流(v2.10.4),其中git-sync sidecar填充了dags pvc。在对DAG进行了一些重构后,气流UI报告1 DAG导入错误: 破dag:[...

回答 1 投票 0

如何对云作曲家气流RESTAPI

我尝试从另一个项目中的云运行服务对云作曲家气流REST API进行身份验证。我想编程触发DAG运行。我不明白该怎么做...

回答 0 投票 0


不能将后驱动器导入到Python

我似乎找不到在我的VENV(我正在使用Conda)中安装的必要库来使其正常工作。 在此处输入图像描述 我安装了气流支持者。 我还尝试安装每个

回答 1 投票 0


databricksworkflowtaskgroup和Spark_jar task的模板任务参数

Task_group= databricksworkflowerator( group_id =“测试”, databricks_conn_id = dbx_conn_id, job_clusters = [ { “ job_cluster_key”:...

回答 1 投票 0


我如何动态分配Schedule_interval到气流DAG

我正在阅读桌子并创建一个像下面的字典。

回答 1 投票 0

回答 1 投票 0






没有按钮“触发dag w/ config”

一起看到带有触发dag的UI。

回答 1 投票 0


无法从气流连接到RedShift -ConnectionRefusedError

当输入参数到气流连接模板,我使用:

回答 1 投票 0

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.