本文實例講述了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程序設計有所幫助。
新聞熱點
疑難解答
