这篇文章主要介绍了python连接phoenix的方法,简单说明了phoenix的概念、功能并结合具体实例形式分析了python连接phoenix的相关操作技巧,需要的朋友可以参考下
本文实例讲述了python连接phoenix的方法。分享给大家供大家参考，具体如下：
phoenix是由saleforce.com开源的一个项目，后又捐给了apache。它相当于一个java中间件，帮助开发者，像使用jdbc访问关系型数据库一些，访问nosql数据库hbase。可以把phoenix只看成一种代替hbase的语法的一个工具。虽然可以用java可以用jdbc来连接phoenix，然后操作hbase，但是在生产环境中，不可以用在oltp中。
1.方案
这里我们通过jpype和jaydebeapi 来连接
2.过程
这里我列出实例代码：
import jpype import jaydebeapi import os phoenix_client_jar="/data/users/huser/phoenix/phoenix-4.3.0-client.jar" args=='-djava.class.path=%s'% phoenix_client_jar jvm_path=jpype.getdefaultjvmpath() jpype.startjvm(jvm_path,args) conn=jaydebeapi.connect('org.apache.phoenix.jdbc.phoenixdriver',['jdbc:phoenix:bj-g2hdp1,bj-g2hdp2,bj-g2hdp3:2181','',''],phoenix_clinent_jar) curs=conn.cursor() sql="select * from test" count=curs.execute(sql) results=curs.fetchall() for r in results: print r
以上就是python实现连接phoenix的实例的详细内容。