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 等）。