airflow.providers.apache.kylin.hooks.kylin

类

KylinHook

与 Kylin 交互以运行 CubeSource 命令并获取作业状态。

模块内容

class airflow.providers.apache.kylin.hooks.kylin.KylinHook(kylin_conn_id=default_conn_name, project=None, dsn=None)[源代码]

基础类: airflow.hooks.base.BaseHook

与 Kylin 交互以运行 CubeSource 命令并获取作业状态。

参数:

  • kylin_conn_id (str) – 在 Airflow 管理界面配置的连接 ID。

  • project (str | None) – 项目名称

  • dsn (str | None) – dsn

conn_name_attr = 'kylin_conn_id'[源代码]
default_conn_name = 'kylin_default'[源代码]
conn_type = 'kylin'[源代码]
hook_name = 'Apache Kylin'[源代码]
kylin_conn_id = 'kylin_default'[源代码]
project = None[源代码]
dsn = None[源代码]
get_conn()[源代码]

返回 hook 的连接。

cube_run(datasource_name, op, **op_args)[源代码]

运行 CubeSource.support_invoke_command 中的 CubeSource 命令。

参数:

  • datasource_name

  • op – 命令

  • op_args – 命令参数

返回:

响应

get_job_status(job_id)[源代码]

获取作业状态。

参数:

job_id – kylin 作业 ID

返回:

作业状态

此条目有帮助吗？