airflow.providers.google.cloud.hooks.looker
此模块包含一个 Google Cloud Looker hook。
模块内容
-
class airflow.providers.google.cloud.hooks.looker.LookerHook(looker_conn_id, **kwargs)[source]
Bases: airflow.hooks.base.BaseHook
Looker API 的 Hook。
-
looker_conn_id[source]
-
source = 'airflow:3.0.0'[source]
-
start_pdt_build(model, view, query_params=None)[source]
向 Looker 提交 PDT 物化作业。
- 参数：
model (str) – 必填。要开始构建的 PDT 模型。
view (str) – 必填。要开始构建的 PDT 视图。
query_params (dict | None) – 可选。附加的物化参数。
-
check_pdt_build(materialization_id)[source]
从 Looker 获取 PDT 物化作业状态。
- 参数：
materialization_id (str) – 必填。要检查状态的物化 ID。
-
pdt_build_status(materialization_id)[source]
获取 PDT 物化作业状态。
- 参数：
materialization_id (str) – 必填。要检查状态的物化 ID。
-
stop_pdt_build(materialization_id)[source]
启动 PDT 物化作业取消请求。
- 参数：
materialization_id (str) – 必填。要停止的物化 ID。
-
wait_for_job(materialization_id, wait_time=10, timeout=None)[source]
轮询 PDT 物化作业以检查其是否完成。
- 参数：
materialization_id (str) – 必填。要等待的物化 ID。
wait_time (int) – 可选。两次检查之间的秒数。
timeout (int | None) – 可选。等待作业就绪的秒数。仅当 asynchronous 为 False 时使用。
-
get_looker_sdk()[source]
返回 Looker API 4.0 的 Looker SDK 客户端。
-
class airflow.providers.google.cloud.hooks.looker.LookerApiSettings(conn)[source]
Bases: looker_sdk.rtl.api_settings.ApiSettings
Looker SDK ApiSettings 类的自定义实现。
-
conn[source]
-
read_config()[source]
从 Airflow 的连接对象中获取连接设置。
覆盖获取连接设置的默认逻辑。
-
class airflow.providers.google.cloud.hooks.looker.JobStatus[source]
Bases: enum.Enum
作业状态字符串。
-
QUEUED = 'added'[source]
-
PENDING = 'pending'[source]
-
RUNNING = 'running'[source]
-
CANCELLED = 'killed'[source]
-
DONE = 'complete'[source]
-
ERROR = 'error'[source]
-
UNKNOWN = 'unknown'[source]