Pinot的Python DB-API和SqlAlchemy方言。

pinotdb的Python项目详细描述


pinot的python db-api和sqlalchemy方言

此模块允许通过其SQL API访问pinot。

用法

使用db api:

frompinotdbimportconnectconn=connect(host='localhost',port=8099,path='/query',scheme='http')curs=conn.cursor()curs.execute("""    SELECT place,           CAST(REGEXP_EXTRACT(place, '(.*),', 1) AS FLOAT) AS lat,           CAST(REGEXP_EXTRACT(place, ',(.*)', 1) AS FLOAT) AS lon      FROM places     LIMIT 10""")forrowincurs:print(row)

使用sqlalchemy:

fromsqlalchemyimport*fromsqlalchemy.engineimportcreate_enginefromsqlalchemy.schemaimport*engine=create_engine('pinot://localhost:8099/query?server=http://localhost:9000/')# uses HTTP by default :(# engine = create_engine('pinot+http://localhost:8099/query?server=http://localhost:9000/')# engine = create_engine('pinot+https://localhost:8099/query?server=http://localhost:9000/')places=Table('places',MetaData(bind=engine),autoload=True)print(select([func.count('*')],from_obj=places).scalar())

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java试图使用GUI解决问题,但如果语句让我困惑   将JavaSOAP请求转换为Javascript?   java请求的资源在使用Struts 2时不可用   Java FutureTask不工作?   java JPA计算布尔值   Java8到OpenJDK11Com。太阳组织。阿帕奇。xml。内部。*无法访问的类型   java我想从给定的字符串中打印数字1和数字0我怎么能?   在If statemet中调用方法的java   多线程线程能够看到java中主线程设置的更新的静态变量   java JPA/Hibernate@OrderBy random