如果我查看不同的 Airflow Environment 类 （https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class....

我已经使用 docker toolbox 在 Windows 8 64 位上安装了 puckel-airflow 映像。 我在本地创建了一个hello world Python scrpit，即da...

我想每天安排一个 dag，但在一天中的不同时间，例如： 星期一 16H 星期二 9H 星期三 10H ... 星期一 15H 星期二 12H 等。。。 我怎样才能做到这一点？...

我正在尝试使用 Airflow 运算符来检查 BigQuery 表是否存在，并创建具有给定架构的表（如果它不存在），或者如果它确实存在，则转到下一个运算符。BigQueryCreateEmptyTab...

我有一个 DAG 气流任务，它进入一个特定的存储桶，并从里面的所有文件一起创建一个外部表。尝试在 bigquery 中查询外部表时，我收到错误（CSV 表引用列位置 19，但从 position：32...

我在 google cloud 存储桶中存储了多个 CSV 文件。我创建了一个气流 DAG 任务，该任务将所有这些文件放在同一个存储桶中并创建一个外部表，因为所有这些文件都遵循相同的架构，只是数据不同...

我在 AWS 中有一个很大的 Airflow dag，它仅针对某些任务失败，其他任务正在完成并显示日志。 *** Reading remote log from Cloudwatch log_gro...

使用 AppflowRunOperator 从气流 dag 调用 AWS appflow 作业时出现以下错误。 ValueError：AppflowRunOperator 不支持源 SAP ODat...

Helo我收到以下错误，我不明白为什么。我相信这与服务帐户有关，但服务帐户应该具有编辑权限 目的通过使用安装了 R 的 Docker 映像，使用 BashOperator 运行 R 脚本 错误 ...

我有一个简单的 DAG（启用了选项）。我正在尝试将 a 传递给 ，但是当它开始执行时，它失败并出现错误。render_template_as_native_obj{{ dag_run }}Python...