airflow.providers.yandex.operators.yq

模組內容

類別

YQExecuteQueryOperator

使用 Yandex Query 服務執行 SQL 程式碼。
class airflow.providers.yandex.operators.yq.YQExecuteQueryOperator(*, name=None, folder_id=None, yandex_conn_id=None, public_ssh_key=None, service_account_id=None, sql, **kwargs)[原始碼]

基底類別：airflow.models.BaseOperator

使用 Yandex Query 服務執行 SQL 程式碼。

參數

  • sql (str) – 要執行的 SQL 程式碼，以單一字串形式呈現

  • name (str | None) – YandexQuery 中查詢的名稱

  • folder_id (str | None) – 雲端資料夾 ID，用於建立查詢

  • yandex_conn_id (str | None) – Airflow 連線 ID，用於取得參數

template_fields: collections.abc.Sequence[str] = ('sql',)[原始碼]
template_fields_renderers[原始碼]
template_ext: collections.abc.Sequence[str] = ('.sql',)[原始碼]
ui_color = '#ededed'[原始碼]
hook()[原始碼]

取得有效的 hook。

execute(context)[原始碼]

在建立運算子時衍生。

Context 是與呈現 Jinja 模板時相同的字典。

請參閱 get_template_context 以取得更多 Context 資訊。

on_kill()[原始碼]

覆寫此方法以在任務實例被終止時清理子程序。

在運算子中任何使用 threading、subprocess 或 multiprocessing 模組的情況都需要清理，否則會留下孤立程序。

這個條目是否有幫助？