连接类型概述 - 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 v3
此图描述了 Apache Airflow UI 中的 HTTP 连接类型。
Apache Airflow v2
此图描述了 Apache Airflow UI 中的 HTTP 连接类型。

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

根据以下示例在 Apache Airflow UI 中为 Jdbc 连接类型应用 HTTP 连接模板。

Apache Airflow v3

以下示例显示了 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 中为 Apache Airflow v3 的 Jdbc 连接应用 HTTP 连接模板。

此图显示了 Apache Airflow UI 中 Jdbc 连接的 HTTP 连接类型。
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 中为 Apache Airflow v2 的 Jdbc 连接应用 HTTP 连接模板。

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