连接类型概述
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®ion_name=us-east-1'
示例连接模板
以下示例显示 Apache Airflow UI 中的 HTTP 连接模板。
- Apache Airflow v2
-
以下示例显示 Apache Airflow UI 中 Apache Airflow v2 的 HTTP 连接模板。
- Apache Airflow v1
-
以下示例显示 Apache Airflow UI 中 Apache Airflow v1 的 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 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 连接模板。