SQLExecuteQueryOperator 连接 Vertica¶

使用 SQLExecuteQueryOperator 在 Vertica 数据库中执行 Vertica 命令。

注意

如果您之前使用过其他旧版算子处理 Vertica 交互，现在可以使用 SQLExecuteQueryOperator 执行存储过程和原生 SQL。

使用算子¶

使用 conn_id 参数连接到您的 Vertica 实例，其连接元数据结构如下：

Vertica Airflow 连接元数据¶
参数	输入
主机: 字符串	Vertica 数据库主机名或容器名（如果在 Docker 网络中运行）
模式: 字符串	默认执行 SQL 操作的模式
登录名: 字符串	Vertica 数据库用户（如果使用社区 Docker 镜像，通常是 `dbadmin`）
密码: 字符串	Vertica 数据库用户密码
端口: 整型	Vertica 数据库端口（默认：5433）
额外参数: JSON	额外的连接配置（例如 TLS 设置）：`{"tlsmode": "disable"}`

使用 SQLExecuteQueryOperator 连接 Vertica 的示例如下：

tests/system/vertica/example_vertica.py

    create_table_vertica_task = SQLExecuteQueryOperator(
        task_id="create_table_vertica",
        sql=[
            "DROP TABLE IF EXISTS employees;",
            """
            CREATE TABLE employees (
                id IDENTITY,
                name VARCHAR(50),
                salary NUMERIC(10,2),
                hire_date TIMESTAMP DEFAULT NOW()
            )
            """,
        ],
    )

参考¶

如需更多信息，请参阅：

Vertica 文档

注意

通过 SQLExecuteQueryOperator() 给定的参数优先于通过 Airflow 连接元数据设置的参数（例如 schema、login、password 等）。