我正在尝试使用airflow REST api (v1.10.2)，但每当我尝试查询有关特定dag的信息时都会遇到问题。"items": [ "dag_id": "test_dag",
"dag_run_url": "/admin/airflow/graph?时，我得到一个错误：
浏览 33提问于2019-03-08得票数 3
回答已采纳
其目的是通过rest api调用从UI中删除airflow dag。我尝试了调用.../delete?dag_id=<dag_id>，这个rest调用失败了，报告缺少CSRF令牌。如何从airflow服务器获取CSRF令牌？或者有没有更好的方法从airflow UI中自动删除dag？(不是从airflow UI手动按下删除按钮)
浏览 3提问于2020-06-11得票数 0
1回答
我使用的是Airflow v1.10.2，指的是experimental REST API documentation。当我尝试进行API调用时 GET /api/experimental/dags/<DAG_ID>/dag_runs或 POST /api/experimental/dags/<DAG_ID>/<
浏览 17提问于2019-04-10得票数 0
回答已采纳
我想知道dag的状态是运行、失败还是成功。我正在通过CL参数airflow trigger触发dag，在作业执行之后，我想知道运行的状态。我找不到任何方法。我尝试了airflow dag_state，但它没有提供任何帮助。如果一天中有不止一次运行，通过命令行参数或python代码获取最近一次运行的状态，我应该怎么做？
浏览 35提问于2019-11-07得票数 3
回答已采纳
我正在尝试使用AirFlow rest API触发我的dag。但是，不能理解如何进行身份验证。 下面的URL在我的浏览器中运行良好。http://localhost:8181/api/experimental/dags/demo/dag_runs 但是，下面的代码会给出身份验证错误。import requestsfrom pprint import pprint
resu
浏览 24提问于2020-04-21得票数 2
我使用REST API将参数传递给基于任务流的Dag。看看在这个论坛上提出的类似问题，下面似乎是访问传递的参数的常见方式。#From inside a template field or file:#Or when context is available, e.g.within a python callable of the PythonOperator:
context['dag_run'].conf[&#
浏览 29提问于2021-01-07得票数 6
我正在使用Apache Airflow REST API。 支持许多基本命令。例如，我可以通过运行以下命令返回特定DAG的信息： https://8080/my_url/api/experimental/dags/example_pig_operator/dag_runs ...which返回： [{
"dag_id": "exampl
浏览 61提问于2021-06-19得票数 0
气流修补程序rest不适用于JAVA 11，这里的是代码片段。(IOException e1) { e1.printStackTrace();String url = "airflowIOException e) { e.printStackTrace();google正在尝试将com.google.api.c
浏览 18提问于2022-08-05得票数 1
回答已采纳
以前，我有在DAG步骤中获取这些参数的代码(我使用的是气流2中的Taskflow API ) --类似于这样：from airflow.decoratorstasks here现在，这会在DAG导入上中断，出现以下错误(更改名称以匹配上面的示例)：
Broken DAG:Are you runnin
浏览 5提问于2021-10-21得票数 3
回答已采纳
我正在尝试使用REST API触发气流dags。它不起作用。我得到一个错误400，响应如下： { "status": 400, "type": "https://airflow.apache.org&#x
浏览 67提问于2021-04-15得票数 1
回答已采纳
DAG代码：from airflowrun_function", python_callable= run_function, provide_context= True )
run.py导入aux_functions，它在运行时导入出现的错误是：ImportError: cannot import name 'settings&#x
浏览 1提问于2018-08-23得票数 2
1回答
我编写了一个python程序来创建一个DAG文件。在创建这个DAG文件之后，我想要触发这个DAG运行。我试着用下面的代码-c.trigger_dag(dag_id='local_job_md', run_id='local_job_md', conf={})
但是，由于无法在sql
浏览 6提问于2022-03-04得票数 0
6回答
当气流we服务器出现像Broken DAG: [<path/to/dag>] <error>这样的错误时，我们如何在哪里找到这些异常的完整堆栈跟踪？我试过这些地点：
/var/log/airflow/webserver --在执行的时间范围内没有日志，其他日志是二进制的，使用strings解码没有提供有用的信息。/var/log/airflow/scheduler
浏览 9提问于2017-05-12得票数 29
回答已采纳
Airflow似乎跳过了我添加到/usr/local/airflow/dags中的dags。example_passing_params_via_test_commandexample_short_circuit_operatorexample_subdag_operator.section-1exam
浏览 0提问于2017-08-07得票数 29
1回答
我创建了一个变量(从Airflow UI)： Key: env_variables
Value: {'xx': 'yy`} 并尝试使用var.json.env_variables.xx内部bash操作符进行访问但是"xx“的值是动态的，我是从REST API传递的，并使用dag_run.conf['param']访问它(dag_run.conf['param']应该返回xx)。如何在Airflow中实现内部b
浏览 58提问于2021-09-23得票数 0
回答已采纳
我已经在EKS上托管了Airflow和Spark-operator。我已经在Airflow上创建了一个连接，通过使用"in cluster configuration“连接到Kubernetes集群。我只是运行示例应用程序，只是为了通过Airflow检查Kubernetes上spark的执行情况。a DAG
# Operators; we need this to operate!=d
浏览 2提问于2021-07-14得票数 3
我在代码中定义了以下DAG： from datetime import timedelta, datetimefrom airflow import DAG
from这看起来很好，当我运行时： airflow list_dags 我看到列出了我的dag： data-push 当我跑的时候： airflow list_tasks data-push 我看到我的三个任务出现了它们应该出现的
浏览 49提问于2020-08-02得票数 1
回答已采纳
我正在写一个气流DAG，有一些函数的问题。我尝试通过将数据打印到标准输出并使用logging库来进行调试。=dag,在运行期间，我得到一个错误：airflow[9490]: Traceback= 'ok':但是，我登录到的所有内容都不是在调度
浏览 45提问于2019-08-08得票数 7
1回答
我正在尝试创建一个使用DockerOperator执行某些脚本的DAG。在我的DockerOperator中，脚本试图读取气流变量并使用BaseHook获取连接。但是，我的DockerOperator中的脚本似乎连接到(空的) sqlalchemy数据库，而不是通过UI设置填充连接和变量的初始化postgres数据库。是否有一种方法可以将DockerOperator上下文提供给包含通过UI设置的连接和变量的气流数据库？",
image="sync-script:latest",
浏览 6提问于2022-06-02得票数 1
回答已采纳
我正在使用气流稳定舵图和Kubernetes Executor，新的pod正在为dag调度，但它与dag_id的故障无法找到问题。我正在使用git-sync来获取dags。下面是错误和kubernetes配置值。有人能帮我解决这个问题吗？错误：[2020-07-01 23:18:/airflow/bin
浏览 9提问于2020-07-02得票数 6
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
