python连接phoenix的jaydebeapi方式

使用pip install JayDeBeApi,具体示例如下:

import jaydebeapi
conn = jaydebeapi.connect('org.apache.phoenix.jdbc.PhoenixDriver', \
'jdbc:phoenix:my_zk_server:2181:test', ['', ''], \
'/workspace/service/phoenix-client/phoenix-client.jar')
curs = conn.cursor()
curs.execute('select * from your_table limit 1')
curs.fetchall()

注:test为hbase的某一个名称空间。

猜你喜欢

转载自www.cnblogs.com/lizheng19822003/p/11133055.html