`airflow.models.connection`¶

模块内容¶

类¶

Connection

用于存储有关不同数据库实例连接信息的占位符。

函数¶

`parse_netloc_to_hostname`(args, *kwargs)	请勿使用，此方法已弃用。
`sanitize_conn_id`(conn_id[, max_length])	清理连接 ID，并仅允许其中包含特定字符。

属性¶

`log`
`RE_SANITIZE_CONN_ID`
`CONN_ID_MAX_LEN`

airflow.models.connection.log[源代码]¶

airflow.models.connection.RE_SANITIZE_CONN_ID[源代码]¶

airflow.models.connection.CONN_ID_MAX_LEN: int = 250[源代码]¶

airflow.models.connection.parse_netloc_to_hostname(*args, **kwargs)[源代码]¶: 请勿使用，此方法已弃用。

airflow.models.connection.sanitize_conn_id(conn_id, max_length=CONN_ID_MAX_LEN)[源代码]¶

清理连接 ID，并仅允许其中包含特定字符。

也就是说，它允许字母数字字符以及符号 #,!,-,_,.,:,/, 和 () 从 1 个到最多 250 个连续匹配。如果需要，可以通过设置 max_length 来调整最大长度。

您可以在这里尝试使用正则表达式：https://regex101.com/r/69033B/1

选择的字符是为了防止注入 javascript 或可执行位，以避免前端出现任何尴尬的行为。

参数

conn_id (str | None) – 要清理的连接 ID。
max_length – 连接 ID 的最大长度，默认为 250。

返回

清理后的字符串，否则返回 None。

返回类型

str | None

class airflow.models.connection.Connection(conn_id=None, conn_type=None, description=None, host=None, login=None, password=None, schema=None, port=None, extra=None, uri=None)[源代码]¶

基类：airflow.models.base.Base, airflow.utils.log.logging_mixin.LoggingMixin

用于存储有关不同数据库实例连接信息的占位符。

这里的想法是，脚本使用对数据库实例 (conn_id) 的引用，而不是在使用运算符或钩子时硬编码主机名、登录名和密码。

另请参阅

有关如何使用此类的更多信息，请参阅：管理连接

参数

conn_id (str | None) – 连接 ID。
conn_type (str | None) – 连接类型。
description (str | None) – 连接描述。
host (str | None) – 主机。
login (str | None) – 登录名。
password (str | None) – 密码。
schema (str | None) – 架构。
port (int | None) – 端口号。
extra (str | dict | None) – 额外元数据。非标准数据（如私钥/SSH 密钥）可以保存在此处。JSON 编码的对象。
uri (str | None) – 描述连接参数的 URI 地址。