本文实例讲述了Python连接phoenix的方法。分享给大家供大家参考,具体如下:
phoenix是由saleforce.com开源的一个项目,后又捐给了Apache。它相当于一个Java中间件,帮助开发者,像使用jdbc访问关系型数据库一些,访问NoSql数据库HBase。可以把Phoenix只看成一种代替HBase的语法的一个工具。虽然可以用java可以用jdbc来连接phoenix,然后操作HBase,但是在生产环境中,不可以用在OLTP中。
Phoenix官网:http://phoenix.apache.org/
1.方案
这里我们通过Jpype和JayDeBeApi 来连接
2.过程
这里我列出实例代码:
import jpypeimport jaydebeapiimport osphoenix_client_jar="/data/users/huser/phoenix/phoenix-4.3.0-client.jar"args=='-Djava.class.path=%s'% phoenix_client_jarjvm_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程序设计有所帮助。
新闻热点
疑难解答