我正在尝试使用python通过knox与hbase进行交互,在python中,管理员给出了一个用于hive、hbase和spark的knoxapi端点列表,比如: https://knox-devl.www.mysite.com:9042/gateway/MYSITEHDO/hbaseversion/cluster
现在,因为我使用的是python的happybase库,所以我的连接代码是
import happybase
connection=happybase.Connection('https://knox-devl.www.mysite.com/gateway/MYSITEHDO/hbaseversion/cluster',port=9042)
connection.open()
print(connection.tables())
它显示的错误是: thriftpy.transport.TTransportException: TTransportException(message="Could not connect to ('https://knox-devl.www.mysite.com/gateway/MYSITEHDO/hbaseversion/cluster', 9042)", type=1)
我还尝试了phoenixdb lib
import phoenixdb
database_url = 'https://knox-devl.www.mysite.com:9042/gateway/MYSITEHDO/hbaseversion/cluster'
conn = phoenixdb.connect(database_url, autocommit=True)
cursor = conn.cursor()
cursor.execute("SHOW tables")
但我得到了另一个错误: phoenixdb.errors.InterfaceError: ('RPC request failed', None, None, BadStatusLine("''",)) Exception phoenixdb.errors.InterfaceError: InterfaceError('RPC request failed', None, None, BadStatusLine("''",)) in <bound method Connection.__del__ of <phoenixdb.connection.Connection object at 0x10bc97d90>> ignored
只有这样我才能通过curl获得一些数据:
curl -i -k -u guest:guest-password 'https://knox-devl.www.mysite.com:9042/gateway/MYSITEHDO/hbaseversion/cluster'
但是那里没有sql命令。
有没有人知道如何做到这一点,或者我在这里遗漏了什么,比如请求一个不同的url或者在集群上启用一些东西?
1条答案
按热度按时间nbysray51#
正如您所指出的,通过knox与hbase交谈的唯一方法是通过hbase的restapi。happybase正在尝试通过rpc直接连接到hbase,knox将阻止rpc。
在启用了knox的集群之外,不能使用happybase。
在这里可以找到将hbase restapi与python结合使用的好教程。如果链接失效,本文中最有用的命令包括:
查看表的架构:
插入一行:
删除表: