Apache Kylin Python 客户端工具库是基于Python可访问Kylin的客户端. 此工具库包含两个可使用组件.

  • Apache Kylin 命令行工具
  • Apache Kylin SQLAchemy方言

想要了解更多关于此工具库信息请点击Github仓库.

安装

请确保您python解释器版本在2.7+, 或者3.4+以上. 最方便安装Apache Kylin Python客户端工具库的方法是使用pip命令
pip install --upgrade kylinpy

Kylinpy 命令行工具

安装完kylinpy后, 立即可以在终端下访问kylinpy

  1.     $ kylinpy
  2.     Usage: kylinpy [OPTIONS] COMMAND [ARGS]...
  4.     Options:
  5.       -h, --host TEXT       Kylin host name  [required]
  6.       -P, --port INTEGER    Kylin port, default: 7070
  7.       -u, --username TEXT   Kylin username  [required]
  8.       -p, --password TEXT   Kylin password  [required]
  9.       --project TEXT        Kylin project  [required]
  10.       --prefix TEXT         Kylin RESTful prefix of url, default: /kylin/api
  11.       --debug / --no-debug  show debug infomation
  12.       --api1 / --api2       API version; default is "api1"; "api1" 适用于 Apache Kylin
  13.       --help                Show this message and exit.
  15.     Commands:
  16.       auth           get user auth info
  17.       cube_columns   list cube columns
  18.       cube_desc      show cube description
  19.       cube_names     list cube names
  20.       model_desc     show model description
  21.       projects       list all projects
  22.       query          sql query
  23.       table_columns  list table columns
  24.       table_names    list all table names

Kylinpy命令行工具示例

  1. 访问Apache Kylin
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug auth

  2. 访问选定cube所有的维度信息
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug cube_columns --name kylin_sales_cube

  3. 访问选定的cube描述
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug cube_desc --name kylin_sales_cube

  4. 访问所有cube名称
    kylinpy -h hostname -u ADMIN -p KYLIN --project learn_kylin --api1 --debug cube_names

  5. 访问选定cube的SQL定义
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug cube_sql --name kylin_sales_cube

  6. 列出Kylin中所有项目
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug projects

  7. 访问选定表所有的维度信息
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug table_columns --name KYLIN_SALES

  8. 访问所有表名
    kylinpy -h hostname -u ADMIN -p KYLIN --project learn_kylin --api1 table_names

  9. 访问所选模型信息
    kylinpy -h hostname -P 7070 -u ADMIN -p KYLIN --project learn_kylin --api1 --debug model_desc --name kylin_sales_model

Apache Kylin SQLAlchemy方言

任何一个使用SQLAlchemy的应用程序都可以通过此方言访问到Kylin, 您之前如果已经安装了kylinpy那么现在就已经集成好了SQLAlchemy Dialect. 请使用如下DSN模板访问Kylin

  1. kylin://<username>:<password>@<hostname>:<port>/<project>?version=<v1|v2>&prefix=</kylin/api>

SQLAlchemy 实例

测试Apache Kylin连接

  1.     $ python
  2.     >>> import sqlalchemy as sa
  3.     >>> kylin_engine = sa.create_engine('kylin://username:password@hostname:7070/learn_kylin?version=v1')
  4.     >>> results = kylin_engine.execute('SELECT count(*) FROM KYLIN_SALES')
  5.     >>> [e for e in results]
  6.     [(4953,)]
  7.     >>> kylin_engine.table_names()
  8.     [u'KYLIN_ACCOUNT',
  9.      u'KYLIN_CAL_DT',
  10.      u'KYLIN_CATEGORY_GROUPINGS',
  11.      u'KYLIN_COUNTRY',
  12.      u'KYLIN_SALES',
  13.      u'KYLIN_STREAMING_TABLE']

使用 Python 和 Apache Kylin 做数据科学分析

请参考此博客：Use Python for Data Science with Apache Kylin.