airflow.providers.google.cloud.sensors.looker¶

本模組包含 Google Cloud Looker sensor。

類¶

LookerCheckPdtBuildSensor

檢查先前提交的 PDT 實體化作業的狀態。

模組內容¶

class airflow.providers.google.cloud.sensors.looker.LookerCheckPdtBuildSensor(materialization_id, looker_conn_id, cancel_on_kill=True, **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

檢查先前提交的 PDT 實體化作業的狀態。

引數:

materialization_id (str) – 必需。要輪詢的實體化作業 ID。（可模板化）
looker_conn_id (str) – 必需。用於連線到 Looker 的連線 ID。
cancel_on_kill (bool) – 可選。一個標誌，指示在呼叫 on_kill 時是否取消 hook 的作業。

template_fields = ['materialization_id'][source]¶

materialization_id[source]¶

looker_conn_id[source]¶

cancel_on_kill = True[source]¶

hook: airflow.providers.google.cloud.hooks.looker.LookerHook | None = None[source]¶

poke(context)[source]¶

派生此類時重寫。

on_kill()[source]¶

當任務例項被終止時，重寫此方法以清理子程序。

在 operator 中使用 threading、subprocess 或 multiprocessing 模組的任何地方都需要進行清理，否則會留下殭屍程序。