airflow - 从 Airflow REST Experimental API 读取配置/数据
问题描述
我想在 Airflow DAG 中阅读此配置,但我无法找到如何做到这一点。我在 StackOverFlow 上读到 dag_run 可以使用,但我仍然无法定义语法或如何使用它。任何帮助将不胜感激。
conf = '{"conf1":"Welcome to Airflow"}' url = "http://localhost:8080/api/experimental/dags/example_parameterized_dag/dag_runs" response = requests.post(url, data=conf, headers= headers) logging.info('Response: %s', response)
解决方案
推荐阅读
- c# - 在 C# 中使用秒表定期检查 5 秒
- java - selenium 无头测试无头模式
- angularjs - AngularJS:如何使用 UI-Router 的转换挂钩从 API 检查身份验证?
- laravel - 离子 3 + laravel。服务器上的http请求问题
- .net-core - .NET Core 2.1 + Identity as UI + windows service - 如何设置端口?
- java - 为什么 PDFBox 返回大小为 0 x 0 的图像尺寸
- c# - 如何在 C# winforms 中创建带有实线边框(3d)的按钮?
- python - HTTP 错误 404:启动 pdfbox 时未找到
- r - 在 R 中按分钟级的时间戳循环到子集数据帧
- algorithm - G和DFT的节点之间的深度优先遍历关系