airflow.providers.yandex.hooks.yq

類

YQHook

用於 Yandex Query 的 hook。

模組內容

class airflow.providers.yandex.hooks.yq.YQHook(*args, **kwargs)[source]

基類: airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook

用於 Yandex Query 的 hook。

client: yandex_query_client.YQHttpClient[source]
close()[source]

釋放所有資源。

create_query(query_text, name=None)[source]

建立並執行查詢。

引數:

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

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

wait_results(query_id, execution_timeout=timedelta(minutes=30))[source]

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

引數:

  • query_id (str) – 查詢 ID。

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

stop_query(query_id)[source]

停止查詢。

引數:

query_id (str) – 查詢 ID。

get_query(query_id)[source]

獲取查詢資訊。

引數:

query_id (str) – 查詢 ID。

get_query_status(query_id)[source]

獲取查詢狀態。

引數:

query_id (str) – 查詢 ID。

在 Yandex Query UI 中生成查詢的網頁連結。

引數:

query_id (str) – 查詢 ID。

此條目是否有幫助？