Google Cloud Looker 運算子¶

Looker 是一款商業智慧軟體和大資料分析平臺，可幫助您輕鬆探索、分析和共享即時業務分析。

Looker 擁有公共 API 和不同語言的關聯 SDK 客戶端，支援透過程式設計方式訪問 Looker 資料平臺。

前提任務¶

要使用這些運算子，您必須執行以下操作：

透過 pip 安裝 API 庫。

pip install 'apache-airflow[google]'

有關安裝的詳細資訊。

在 Airflow 中設定 Looker 連線。您可以檢視管理連線和 Google Cloud Platform Looker 連線

啟動 PDT 實體化作業¶

要向 Looker 提交 PDT 實體化作業，您需要提供模型名稱和檢視名稱。

作業配置可以使用以下方式以同步（阻塞）模式提交：LookerStartPdtBuildOperator。

tests/system/google/cloud/looker/example_looker.py

build_pdt_task = LookerStartPdtBuildOperator(
    task_id="build_pdt_task",
    looker_conn_id=LOOKER_CONNECTION_ID,
    model=LOOKER_MODEL,
    view=LOOKER_VIEW,
)

或者，作業配置可以使用以下方式以非同步模式提交：LookerStartPdtBuildOperator 和 LookerCheckPdtBuildSensor。

tests/system/google/cloud/looker/example_looker.py

start_pdt_task_async = LookerStartPdtBuildOperator(
    task_id="start_pdt_task_async",
    looker_conn_id=LOOKER_CONNECTION_ID,
    model=LOOKER_MODEL,
    view=LOOKER_VIEW,
    asynchronous=True,
)

check_pdt_task_async_sensor = LookerCheckPdtBuildSensor(
    task_id="check_pdt_task_async_sensor",
    looker_conn_id=LOOKER_CONNECTION_ID,
    materialization_id=start_pdt_task_async.output,
    poke_interval=10,
)

作業中需要提供的引數比示例所示的更多。有關完整的引數列表，請參閱 airflow.providers.google.cloud.operators.looker.LookerStartPdtBuildOperator 中的 Looker 運算子引數。