airflow.providers.google.cloud.operators.looker

此模組包含 Google Cloud Looker 運算子。

模組內容

類別

LookerStartPdtBuildOperator

向 Looker 提交 PDT 實體化工作。
class airflow.providers.google.cloud.operators.looker.LookerStartPdtBuildOperator(looker_conn_id, model, view, query_params=None, asynchronous=False, cancel_on_kill=True, wait_time=10, wait_timeout=None, **kwargs)[原始碼]

基底： airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

向 Looker 提交 PDT 實體化工作。

參數

  • looker_conn_id (str) – 必填。用於連線至 Looker 的連線 ID。

  • model (str) – 必填。要開始建置的 PDT 模型。

  • view (str) – 必填。要開始建置的 PDT 視圖。

  • query_params (dict | None) – 選填。其他實體化參數。

  • asynchronous (bool) – 選填。旗標，指示是否等待工作完成或立即返回。這對於提交長時間運行的工作並使用 LookerCheckPdtBuildSensor 非同步等待它們很有用

  • cancel_on_kill (bool) – 選填。旗標，指示在呼叫 on_kill 時是否取消 Hook 的工作。

  • wait_time (int) – 選填。檢查工作是否準備就緒的間隔秒數。僅在 asynchronous 為 False 時使用。

  • wait_timeout (int | None) – 選填。等待工作準備就緒的秒數。僅在 asynchronous 為 False 時使用。

execute(context)[原始碼]

在建立運算子時衍生。

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

請參閱 get_template_context 以取得更多上下文。

on_kill()[原始碼]

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

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

此條目是否有幫助？