使用airflow版本2.1.2ENDPOINT_URL="http://localhost:8080/" "${ENDPOINT_URL}/api/v1/pools"{ "sta
浏览 4提问于2021-07-30得票数 1
我查看了Airflow提供的不同API端点，但我找不到一个适合我的需求。本质上，我希望监视DAG中每个任务的状态，而不必指定我试图监视的每个任务。
浏览 20提问于2021-10-28得票数 0
我正在尝试使用AirFlow rest API触发我的dag。但是，不能理解如何进行身份验证。 下面的URL在我的浏览器中运行良好。http://localhost:8181/api/experimental/dags/demo/dag_runs 但是，下面的代码会给出身份验证错误。import requestsfrom pprint import pprint
result = requ
浏览 24提问于2020-04-21得票数 2
Apache气流REST失败，403被禁止调用：在airflow.cfg中的配置Trueauth_backend = airflow.contrib.auth.backends.password_auth=Trueauth_backend = airflow.contrib.auth.backends.password_auth =
在设置所有这些之后，将生成码头映像并作为码头容器运
浏览 2提问于2020-04-12得票数 3
1回答
它通过AD进行身份验证，这在web视图中很好，AD凭据允许访问，但在rest中不起作用。我的airflow.cfg是：airflow.api.auth.backend.basic_auth和服务是重新启动的，一切都是基于气流的文档。如果我们在气流服务中运行命令，$ airflow config get-value api auth_backends返回airflow.api.auth.backend.basic_auth。{
&quo
浏览 4提问于2022-06-13得票数 0
回答已采纳
我有一个正在运行的dag，我可以使用REST API停止它吗？有一种方法可以删除正在运行的dag：https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#operation但是没有REST API如何停止一个正在运行的dag？ 谢谢!
浏览 145提问于2021-10-09得票数 1
回答已采纳
Airflow提供rest API功能来提取dag/任务状态。https://airflow.apache.org/docs/apache-airflow/stable/stable-rest-api-ref.html#section/Trying-the-API
浏览 27提问于2021-08-26得票数 0
我在Airflow中有一个任务，它使用持续运行的bash操作符。有没有办法让任务实例在下一次计划运行之前成功？我知道如何在api中将其标记为成功。感谢您的回复
浏览 26提问于2021-05-04得票数 0
我需要通过REST API与get服务连接，获取数据并将该数据插入Azure SQL数据库中。我们使用的是Apache Airflow，但是我们的工程师要离开了。要使用Apache Airflow，需要具备编程技能(Python)。 这就是为什么我正在研究是否使用can Datafactory，因为它需要较少的编程技能。然而，看起来REST连接器只理解JSON，而我们的源代码正在传递XML。 使用datafactory从REST API</em
浏览 17提问于2020-04-01得票数 0
回答已采纳
4回答
我试图通过气流2.0 REST触发一个新的dag运行。如果我登录到远程机器上的气流API服务器，然后转到swagger文档页测试API，则调用是成功的。curl -X POST --user "admin:blabla" "http://10.0.0.3:7863/api/v1/dags/tutorial_taskflow_api_etl/dagRunsdag_run_id\":\"st
浏览 8提问于2021-01-05得票数 3
回答已采纳
我想做一个管道，这将登录到API上的用户，并使用API执行一些操作。我正在使用SimpleHttpOperator开发我的REST API，该API构建在FLASK上，并且一些端点需要用户登录。我无法在Airflow DAG上维护会话，以便在调用登录路由后可以调用这些端点。
浏览 0提问于2020-10-13得票数 0
我可以在命令行中使用'airflow trigger_dag‘并指定'run_id’来指定此名称，但我不知道如何在通过when服务器触发DAG时指定此ID？ 有没有人找到了这样做的方法？
浏览 84提问于2021-04-26得票数 2
我见过Apache Nifi与类似的ETL工具进行比较，如Apache Flume、Airflow和Kafka。这些是ETL工具，而不是ESB或请求中介器。我的问题是，我可以将Apache Nifi用于相同的目的吗？使用Nifi的处理器(如HandleHttpRequest )来提供服务编排和服务代理服务端点？它的设计是为了有效地处理实时并发请求吗？
浏览 63提问于2019-12-14得票数 1
回答已采纳
我想知道有没有人能解释一下这个问题：Apache实验应用编程接口：http://airflow_hostname/api/experimental&#
浏览 19提问于2018-03-06得票数 9
1回答
简介：POST: http://{{url}}:{{port}}/api/experimental/dags/MY_DAG_ID', }
(答案: Status 200)工作得很好，但我需要一些安全性，因为它不能对公众开放，所以我读到了API
浏览 3提问于2020-03-18得票数 5
回答已采纳
2回答
当我试图在v1上访问 REST时，我会得到状态代码403 Forbidden。
是否有可能在MWAA中启用实验API？多么?
浏览 20提问于2021-02-24得票数 4
目的:利用apache气流稳定apis在REST外部触发dags。我们试图通过在composer: airflow.api.auth.backend.default中设置气流覆盖配置和发出IAP请求，使用气流实验apis在外部触发dags。效果很好。新的稳定api不支持airflow.api.auth.backend.default。因此，它是投掷:403被禁止。我们也尝试过使用auth_backend : airflow.api.a
浏览 4提问于2021-08-06得票数 3
所以就像这样： airflow connections -a \--conn_type sftp \
--conn_login **ux*
浏览 26提问于2020-10-13得票数 0
1回答
在Python语言编写的Airflow operator (DataprocWorkflowTemplateInstantiateInlineOperator)的帮助下，我使用Dataproc工作流模板提交了一个由于我无法获取jobId，所以我尝试将jobId作为参数从REST API传递，但这并不起作用。 我可以获取jobId吗?或者，如果不可能，我可以将jobId作为参数传递吗？
浏览 17提问于2019-02-06得票数 2
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
