SQLExecuteQueryOperator 连接 Vertica¶

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

注意

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

使用操作符¶

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

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

以下示例演示了使用 SQLExecuteQueryOperator 连接 Vertica 的用法：

tests/system/vertica/example_vertica.py[source]

    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 等）具有最高优先级。