连接类型概述 - Amazon Managed Workflows for Apache Airflow

连接类型概述

Apache Airflow 将各个连接存储为连接 URI 字符串。它在 Apache Airflow UI 中提供了一个连接模板,用于生成连接 URI 字符串,无论连接类型如何。如果 Apache Airflow UI 中没有连接模板,则可以使用备用连接模板来生成此连接 URI 字符串,例如使用 HTTP 连接模板。主要区别在于 URI 前缀,例如 my-conn-type://,Apache Airflow 提供程序在连接中通常会忽略该前缀。本页介绍如何交替使用 Apache Airflow UI 中的连接模板来处理不同的连接类型。

警告

请勿覆盖 Amazon MWAA 中的 aws_default 连接。Amazon MWAA 使用此连接来执行各种关键任务,例如收集任务日志。覆盖此连接可能会导致数据丢失和环境可用性中断。

连接 URI 字符串示例

以下示例显示 MySQL 连接类型的连接 URI 字符串。

'mysql://288888a0-50a0-888-9a88-1a111aaa0000.a1.us-east-1.airflow.amazonaws.com%2Fhome?role_arn=arn%3Aaws%3Aiam%3A%3A001122332255%3Arole%2Fservice-role%2FAmazonMWAA-MyAirflowEnvironment-iAaaaA&region_name=us-east-1'

示例连接模板

以下示例显示 Apache Airflow UI 中的 HTTP 连接模板。

Apache Airflow v2

以下示例显示 Apache Airflow UI 中 Apache Airflow v2 的 HTTP 连接模板。

此图显示了 Apache Airflow UI 中的 HTTP 连接类型。
Apache Airflow v1

以下示例显示 Apache Airflow UI 中 Apache Airflow v1 的 HTTP 连接模板。

此图显示了 Apache Airflow UI 中的 HTTP 连接类型。

使用 HTTP 连接模板进行 Jdbc 连接的示例

以下示例说明如何在 Apache Airflow v2.0.2 中为 Jdbc 连接类型使用 HTTP 连接模板,以及如何在 Apache Airflow UI 中使用 Apache Airflow v1.10.12 的 Jdbc 连接模板中的相同值。

Apache Airflow v2

以下示例显示了 Apache Airflow 为本节中的示例生成的连接 URI 字符串。

http://myconnectionurl/some/path&login=mylogin&extra__jdbc__dry__path=usr/local/airflow/dags/classpath/redshif-jdbc42-2.0.0.1.jar&extra__jdbc__dry__clsname=redshift-jdbc42-2.0.0.1

以下示例说明如何在 Apache Airflow UI 中使用 HTTP 连接模板为 Apache Airflow v2 的 Jdbc 连接进行连接。

此图显示了 Apache Airflow UI 中 Jdbc 连接的 HTTP 连接类型。
Apache Airflow v1

以下示例显示了 Apache Airflow 为本节中的示例生成的连接 URI 字符串。

jdbc://myconnectionurl/some/path&login=mylogin&extra__jdbc__dry__path=usr/local/airflow/dags/classpath/redshif-jdbc42-2.0.0.1.jar&extra__jdbc__dry__clsname=redshift-jdbc42-2.0.0.1

以下示例显示了 Apache Airflow UI 中 Apache Airflow v1.10.12 的 Jdbc 连接模板。

此图显示了 Apache Airflow UI 中的 Jdbc 连接类型。