airflow.providers.google.cloud.hooks.looker

此模块包含 Google Cloud Looker hook。

模块内容

类

LookerHook

用于 Looker API 的 Hook。

LookerApiSettings

ApiSettings 类的 Looker SDK 自定义实现。

JobStatus

作业状态字符串。
class airflow.providers.google.cloud.hooks.looker.LookerHook(looker_conn_id, **kwargs)[源代码]

基类： airflow.hooks.base.BaseHook

用于 Looker API 的 Hook。

start_pdt_build(model, view, query_params=None)[源代码]

向 Looker 提交 PDT 物化作业。

参数

  • model (str) – 必需。要开始构建的 PDT 的模型。

  • view (str) – 必需。要开始构建的 PDT 的视图。

  • query_params (dict | None) – 可选。其他物化参数。

check_pdt_build(materialization_id)[源代码]

从 Looker 获取 PDT 物化作业状态。

参数

materialization_id (str) – 必需。要检查状态的物化 ID。

pdt_build_status(materialization_id)[源代码]

获取 PDT 物化作业状态。

参数

materialization_id (str) – 必需。要检查状态的物化 ID。

stop_pdt_build(materialization_id)[源代码]

启动 PDT 物化作业取消请求。

参数

materialization_id (str) – 必需。要停止的物化 ID。

wait_for_job(materialization_id, wait_time=10, timeout=None)[源代码]

轮询 PDT 物化作业以检查其是否完成。

参数

  • materialization_id (str) – 必需。要等待的物化 ID。

  • wait_time (int) – 可选。检查之间的时间间隔（秒）。

  • timeout (int | None) – 可选。等待作业准备就绪的时间（秒）。仅当 asynchronous 为 False 时使用。

get_looker_sdk()[源代码]

返回用于 Looker API 4.0 的 Looker SDK 客户端。

class airflow.providers.google.cloud.hooks.looker.LookerApiSettings(conn)[源代码]

基类： looker_sdk.rtl.api_settings.ApiSettings

Looker SDK 的 ApiSettings 类的自定义实现。

read_config()[源代码]

从 Airflow 的连接对象中获取连接设置。

覆盖获取连接设置的默认逻辑。

class airflow.providers.google.cloud.hooks.looker.JobStatus[源代码]

基类： enum.Enum

作业状态字符串。

QUEUED = 'added'[源代码]
PENDING = 'pending'[源代码]
RUNNING = 'running'[源代码]
CANCELLED = 'killed'[源代码]
DONE = 'complete'[源代码]
ERROR = 'error'[源代码]
未知 = 'unknown'[源代码]

此条目是否有帮助？