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。

此条目是否有帮助？