1、安装Hbase库

pip install happybase

2、连接Hbase

2.1、查看Hbase配置

image.png image.png

2.2、使用happyhase连接hbase

import happybase
# 注意protocol和transport这两个参数，需要和hbase启动命令中的相同，否则会报错
connection = happybase.Connection('qa-cdh-001',port=9090, protocol='compact', transport='framed')
connection.tables()
[b'sz_abc', b'sz_cde_1',...]

image.png

3、操作Hbase

3.1、指定table，通过row-key查询

image.png

4、连接Hbase报错

 File "/Users/rikasai/.virtualenvs/kafka/lib/python3.6/site-packages/thriftpy2/protocol/compact.py", line 219, in _read_ubyte
    result, = unpack('!B', self.trans.read(1))
  File "thriftpy2/transport/buffered/cybuffered.pyx", line 44, in thriftpy2.transport.buffered.cybuffered.TCyBufferedTransport.read
  File "thriftpy2/transport/cybase.pyx", line 137, in thriftpy2.transport.cybase.CyTransportBase.get_string
  File "thriftpy2/transport/buffered/cybuffered.pyx", line 65, in thriftpy2.transport.buffered.cybuffered.TCyBufferedTransport.c_read
  File "thriftpy2/transport/buffered/cybuffered.pyx", line 69, in thriftpy2.transport.buffered.cybuffered.TCyBufferedTransport.read_trans
  File "thriftpy2/transport/cybase.pyx", line 61, in thriftpy2.transport.cybase.TCyBuffer.read_trans
  File "/Users/rikasai/.virtualenvs/kafka/lib/python3.6/site-packages/thriftpy2/transport/socket.py", line 132, in read
    message='TSocket read 0 bytes')
thriftpy2.transport.base.TTransportException: TTransportException(type=4, message='TSocket read 0 bytes')