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]