airflow专题提供airflow的最新资讯内容,帮你更好的了解airflow。
我有一个Airflow DAG,以前没有时间表。它在Airflow界面中已打开,而我正在手动运行它。刚才,我更新了
如果我使用puckel / docker-airflow的docker-compose-CeleryExecutor.yml使用Celery Executor启动Airflow容器,可以在<a href="ht
我对Apache Beam(尤其是数据流)有疑问。 我有一个从cloudsql数据库读取并写入GCS的管道。文件名中
我无法让Airflow使用FTPHook连接到远程计算机。我可以连接到它,但是当我对连接进行任何操作(例如<code>
<code>Couldn&#39;t find a tree builder with the features you requested: lxml. Do you need to install a parser library?</code>
我正在尝试使用ExternalTask​​Sensor添加交叉dag依赖性,但无法使其正常工作。 Dag A具有<code>schedule_interval
一个简单的问题: 定义后是否可以通过Api或CLI自动更改Dag的计划间隔? 示例:编写一个每天
我正在尝试编写一个测试用例,其中: <ul> <li>实例化(Python)运算符的集合(使用<code>unittest.mock.patc
当我从仪表板手动触发时,气流计划程序会崩溃。 executor = <code>DaskExecutor</code> 气流版本:=
我在DAG中具有以下任务: 任务1->任务2->任务3->任务4->任务5 <strong>我在dag中具有以下配置</str
我是DAG,Airflow和Python语法的新手(我从Java中学到了编码),但是我有一个DAG,其中包含大约10个彼此独
我已使用此<a href="https://vujade.co/install-apache-airflow-ubuntu-18-04/" rel="nofollow noreferrer">tutorial</a>安装了Airflow。
我正在<a href="https://github.com/helm/charts/tree/master/stable/airflow" rel="nofollow noreferrer">stable helm chart</a>的Kubernetes
我刚刚开始学习Airflow的插件。我想制作一个测试页,我使用了文档中的代码: <pre><code>from airflow.plugi
有人能成功在AirFlow上运行Snowflake和雪花连接器python吗? 我正在尝试使用这些命令进行安装 <code>pip
我正在使用Airflow 1.10.10,并且已经在内部成功设置了AD / LDAP集成,同时在气流配置文件中也有<code>rbac = T
气流任务没有排队到正确的池中。 Subdag任务占用了当前池中所有正在运行的插槽,因此我为sub-dag
我曾尝试在stackoverflow上查看与此问题类似的答案,但是我的情况略有不同。 我正在通过Airflow CLI执
当Airflow模板操作符参数包含以<em> .json </em>结尾的任何字符串时,似乎存在错误。有谁知道如何规避它?
我正在安排气流工作。但是,要验证我是否安排了正确的作业,我需要查看该作业将来何时运行。