airflow.providers.mysql.transfers.vertica_to_mysql¶

類¶

VerticaToMySqlOperator

將資料從 Vertica 移動到 MySQL。

模組內容¶

class airflow.providers.mysql.transfers.vertica_to_mysql.VerticaToMySqlOperator(sql, mysql_table, vertica_conn_id='vertica_default', mysql_conn_id='mysql_default', mysql_preoperator=None, mysql_postoperator=None, bulk_load=False, *args, **kwargs)[source]¶

Bases: airflow.models.BaseOperator

將資料從 Vertica 移動到 MySQL。

引數:

sql (str) – 要針對 Vertica 資料庫執行的 SQL 查詢。(模板化)
vertica_conn_id (str) – 源 Vertica 連線
mysql_table (str) – 目標 MySQL 表，使用點表示法指定特定資料庫。(模板化)
mysql_conn_id (str) – 引用 mysql 連線 ID。
mysql_preoperator (str | None) – 在匯入前針對 MySQL 執行的 sql 語句，通常用於截斷或刪除即將匯入的資料，使任務具有冪等性（執行兩次任務不會重複載入資料）。(模板化)
mysql_postoperator (str | None) – 在匯入後針對 MySQL 執行的 sql 語句，通常用於將資料從暫存區移動到生產環境併發出清理命令。(模板化)
bulk_load (bool) – 使用 bulk_load 選項的標誌。這使用 LOAD DATA LOCAL INFILE 命令直接從製表符分隔的文字檔案載入到 MySQL。MySQL 伺服器必須支援透過此命令載入本地檔案（預設情況下停用）。

template_fields: collections.abc.Sequence[str] = ('sql', 'mysql_table', 'mysql_preoperator', 'mysql_postoperator')[source]¶

template_ext: collections.abc.Sequence[str] = ('.sql',)[source]¶

template_fields_renderers[source]¶

ui_color = '#a0e08c'[source]¶

sql[source]¶

mysql_table[source]¶

mysql_conn_id = 'mysql_default'[source]¶

mysql_preoperator = None[source]¶

mysql_postoperator = None[source]¶

vertica_conn_id = 'vertica_default'[source]¶

bulk_load = False[source]¶

execute(context)[source]¶

建立運算子時派生。

上下文是與渲染 jinja 模板時使用的相同的字典。

有關更多上下文，請參閱 get_template_context。