airflow.providers.yandex.hooks.yq

模块内容

类

YQHook

Yandex Query 的钩子。
class airflow.providers.yandex.hooks.yq.YQHook(*args, **kwargs)[源代码]

基类：airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook

Yandex Query 的钩子。

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 中组成指向查询的 Web 链接。

参数

query_id (str) – 查询的 ID。

此条目是否有帮助？