airflow.providers.google.cloud.operators.looker

此模組包含 Google Cloud Looker operators。

LookerStartPdtBuildOperator

提交 PDT 實體化作業到 Looker。

模組內容

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)[source]

基類: airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator

提交 PDT 實體化作業到 Looker。

引數:
  • 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 時使用。

model[source]
view[source]
query_params = None[source]
looker_conn_id[source]
asynchronous = False[source]
cancel_on_kill = True[source]
wait_time = 10[source]
wait_timeout = None[source]
hook: airflow.providers.google.cloud.hooks.looker.LookerHook | None = None[source]
materialization_id: str | None = None[source]
execute(context)[source]

建立 operator 時派生。

Context 與渲染 jinja 模板時使用的字典相同。

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

on_kill()[source]

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

在 operator 中使用 threading、subprocess 或 multiprocessing 模組時,需要進行清理,否則會留下殭屍程序。

此條目有幫助嗎?