2

我在 AWS MWAA 中运行 Airflow，我想访问 REST API，有两种方法可以做到这一点，但似乎对我不起作用。

  1. 覆盖 api.auth_backend。这曾经有效，现在 AWS MWAA 不允许您添加它，它被视为“阻止列表”并且不允许。
    api.auth_backend = 气流.api.auth.backend.default

  2. 使用 MWAA Cli(Python)。如果任何 DAG 使用位于 request.txt 文件中的包，这将不起作用。
    一个。例如，我在 requirements.txt 中有“paramiko”，因为我有一个使用 SSHOperator 的任务。MWAA Cli 因“无模块 paramiko”而失败

    湾。此处还指出​​，https ://docs.aws.amazon.com/mwaa/latest/userguide/access-airflow-ui.html “如果 DAG 使用插件，任何解析 DAG 的命令（例如 list_dags、回填）都将失败这取决于通过 requirements.txt 安装的软件包。”

4

1 回答 1

0

我们正在使用 MWAA 2.0.2 并设法通过 MWAA CLI 使用 Airflow 的 Rest-API，基本上遵循Apache Airflow CLI 命令参考的说明和示例代码。您会注意到并非所有 Rest-API 调用都受支持，但其中许多都受支持（即使您有一个 requirements.txt）。

还可以查看GitHub 上的 AWS 示例代码。

于 2021-10-14T14:19:13.017 回答