Hbase Python接口

thrift --gen py Hbase.thrift 

from thrift.transport.TSocket import TSocket
from thrift.transport.TTransport import TBufferedTransport
from thrift.protocol import TBinaryProtocol
import sys

sys.path.append(‘gen-py‘)
from hbase import Hbase

host = ‘192.168.6.1‘
port = 8080
transport = TBufferedTransport(TSocket(host, port))
transport.open()
protocol = TBinaryProtocol.TBinaryProtocol(transport)

client = Hbase.Client(protocol)

#取数据
results = client.getRow(‘Item‘, ‘rowkey‘, {})
if len(results) > 0:
    result = results[0]
    for k,v in result.columns.iteritems():
        print k, v.value

# 关闭
transport.close()