thrift 是facebook开发并开源的一个二进制通讯中间件，通过thrift，我们可以充分利用各个语言的优势，编写高效的代码。
关于thrift的论文：http://pan.baidu.com/share/link?shareid=234128&uk=3238841275
安装thrift：http://thrift.apache.org/docs/install/ubuntu/
安装完成后到hbase的目录下，找到hbase.thrift，该文件在
hbase-0.94.4/src/main/resources/org/apache/hadoop/hbase/thrift下可以找到
thrift --gen python hbase.thrift 会生成gen-py文件夹，将其修改成hbase
安装python的thrift库
sudo pip install thrift
启动hbase的thrift服务：bin/hbase-daemon.sh start thrift 默认端口是9090
创建hbase表:
from thrift import thrift from thrift.transport import tsocket from thrift.transport import ttransport from thrift.protocol import tbinaryprotocol from hbase import hbase from hbase.ttypes import * transport = tsocket.tsocket('localhost', 9090); transport = ttransport.tbufferedtransport(transport) protocol = tbinaryprotocol.tbinaryprotocol(transport); client = hbase.client(protocol) transport.open() contents = columndescriptor(name='cf:', maxversions=1) client.createtable('test', [contents]) print client.gettablenames()
执行代码，成功后，进入hbase的shell，用命令list可以看到刚刚的test表已经创建成功。
插入数据：
from thrift import thrift from thrift.transport import tsocket from thrift.transport import ttransport from thrift.protocol import tbinaryprotocol from hbase import hbase from hbase.ttypes import * transport = tsocket.tsocket('localhost', 9090) transport = ttransport.tbufferedtransport(transport) protocol = tbinaryprotocol.tbinaryprotocol(transport) client = hbase.client(protocol) transport.open() row = 'row-key1' mutations = [mutation(column=cf:a, value=1)] client.mutaterow('test', row, mutations, none)
获取一行数据：
from thrift import thrift from thrift.transport import tsocket from thrift.transport import ttransport from thrift.protocol import tbinaryprotocol from hbase import hbase from hbase.ttypes import * transport = tsocket.tsocket('localhost', 9090) transport = ttransport.tbufferedtransport(transport) protocol = tbinaryprotocol.tbinaryprotocol(transport) client = hbase.client(protocol) transport.open() tablename = 'test' rowkey = 'row-key1' result = client.getrow(tablename, rowkey, none) print result for r in result: print 'the row is ' , r.row print 'the values is ' , r.columns.get('cf:a').value
返回多行则需要使用scan：
from thrift import thrift from thrift.transport import tsocket from thrift.transport import ttransport from thrift.protocol import tbinaryprotocol from hbase import hbase from hbase.ttypes import * transport = tsocket.tsocket('localhost', 9090) transport = ttransport.tbufferedtransport(transport) protocol = tbinaryprotocol.tbinaryprotocol(transport) client = hbase.client(protocol) transport.open() scan = tscan() tablename = 'test' id = client.scanneropenwithscan(tablename, scan, none) result2 = client.scannergetlist(id, 10) print result2
scannerget则是每次只取一行数据：
from thrift import thrift from thrift.transport import tsocket from thrift.transport import ttransport from thrift.protocol import tbinaryprotocol from hbase import hbase from hbase.ttypes import * transport = tsocket.tsocket('localhost', 9090) transport = ttransport.tbufferedtransport(transport) protocol = tbinaryprotocol.tbinaryprotocol(transport) client = hbase.client(protocol) transport.open() scan = tscan() tablename = 'test' id = client.scanneropenwithscan(tablename, scan, none) result = client.scannerget(id) while result: print result result = client.scannerget(id)