airflow.providers.yandex.hooks.yq

模組內容

類別

YQHook

用於 Yandex Query 的 Hook。
class airflow.providers.yandex.hooks.yq.YQHook(*args, **kwargs)[原始碼]

基底類別： airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook

用於 Yandex Query 的 Hook。

close()[原始碼]

釋放所有資源。

create_query(query_text, name=None)[原始碼]

建立並執行查詢。

參數

  • query_text (str | None) – SQL 文本。

  • name (str | None) – 查詢的名稱

wait_results(query_id, execution_timeout=timedelta(minutes=30))[原始碼]

等待查詢完成並取得結果。

參數

  • query_id (str) – 查詢的 ID。

  • execution_timeout (datetime.timedelta) – 等待查詢完成的時間長度。

stop_query(query_id)[原始碼]

停止查詢。

參數

query_id (str) – 查詢的 ID。

get_query(query_id)[原始碼]

取得查詢資訊。

參數

query_id (str) – 查詢的 ID。

get_query_status(query_id)[原始碼]

取得查詢的狀態。

參數

query_id (str) – 查詢的 ID。

在 Yandex Query UI 中組合查詢的網路連結。

參數

query_id (str) – 查詢的 ID。

此條目是否有幫助？