airflow 相关问题

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

如何停止/杀死UI

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

python hadoop airflow

回答 6 投票 0

404找不到：桌子气流项目-446808：零售。我正在尝试在气流中运行DBT变换，我的表RAW_INVOICES已经在美国位置创建。我仍然在气流中低于错误。 -dim_customer.sql - 创建尺寸表 ...

google-cloud-platform google-bigquery airflow dbt

回答 0 投票 0

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

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

airflow

回答 1 投票 0

如何对云作曲家气流RESTAPI

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

airflow google-cloud-composer

回答 0 投票 0

不同工作流程之间的AirFlow DAG依赖关系 /编排

airflow airflow-scheduler airflow-2.x mwaa

回答 0 投票 0

不能将后驱动器导入到Python

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

python postgresql airflow postgres-operator

回答 1 投票 0

为什么气流的“最后一个运行日期”实际上不显示最后一个运行日期？

airflow

回答 1 投票 0

databricksworkflowtaskgroup和Spark_jar task的模板任务参数

Task_group= databricksworkflowerator（ group_id =“测试”， databricks_conn_id = dbx_conn_id， job_clusters = [ { “ job_cluster_key”：...

airflow databricks azure-databricks

回答 1 投票 0

如何使用taskflow API将Jinja2模板参数传递到任务？如果我将其传递给“ {{var.json.my_api_key.api_key}}”，则我的任务无法正确呈现其参数之一： @任务 def generate_signature_headers（api_key =“ {{var.json.

"{{ var.json.my_api_key.api_key }}"

python jinja2 airflow

回答 0 投票 0

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

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

airflow global astronomer

回答 1 投票 0

有一种方法可以在气流中本地解析DAG文件？

阅读以下内容：

airflow

回答 1 投票 0

AirFlow-在气流UI中创建一个数月的回填，以每天运行的DAG 我的DAG每天从3/3/2022开始运行，但我需要以1/1-3/2进行回复。我知道我可以通过浏览 - > dag运行并为每个da添加一个dag的dag添加一个新的dag运行。

您可以利用气流cli运行

airflow airflow-scheduler airflow-2.x

回答 2 投票 0

在气流中使用Bashoperator的扩展任务组

airflow

回答 1 投票 0

bash google-cloud-platform ssh google-cloud-composer airflow

回答 1 投票 0

TimeOrror Ind ind lambda功能在气流中我有一个关于气流的AWS Lambda（首尔地区）的疑问（亚马逊管理东京地区的Apache Airflow的工作流程）。问题是当我从Airflo调用Lambda功能...

很奇怪的是，当我从AWS日志中检查这是否为真时，lambda功能效果很好；状态代码200.

amazon-web-services aws-lambda airflow mwaa

回答 0 投票 0

我试图在括号中理解以下示例。 airflow_proj_dir 是一个环境变量，该变量将由支架外部的$符号调用。但是我有很多问题...

AIRFLOW_PROJ_DIR

linux bash docker shell airflow

回答 1 投票 0

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

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

airflow aws-airflow-mwaa

回答 1 投票 0

GkestarPodoperator/kubectl API：错误500“无代理”

kubernetes airflow google-kubernetes-engine kubernetes-apiserver kubernetespodoperator

回答 0 投票 0

无法从气流连接到RedShift -ConnectionRefusedError

当输入参数到气流连接模板，我使用：

amazon-web-services airflow amazon-redshift amazon-vpc

回答 1 投票 0

我可以如何根据另一个任务进行任务，但也只能在某个时间运行？我有两个任务。 T05：30-我希望每天05:30运行。 T08：30-我希望每天08:30运行，但前提是今天T05：30成功。这可以在气流中实现吗？它

T05：30-我希望每天05:30运行。

python airflow task scheduled-tasks directed-acyclic-graphs

回答 0 投票 0

airflow 相关问题

最新问题