python 通过thrift操作hbase的完整代码

前端之家收集整理的这篇文章主要介绍了python 通过thrift操作hbase的完整代码前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
对python这个高级语言感兴趣的小伙伴,下面一起跟随编程之家 jb51.cc的小编两巴掌来看看吧!

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表:
 

# @param python通过thrift操作hbase实例
# @author 编程之家 jb51.cc|jb51.cc 

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()

# End www.jb51.cc

执行代码,成功后,进入hbase的shell,用命令list可以看到刚刚的test表已经创建成功。

插入数据:

# @param python通过thrift操作hbase实例
# @author 编程之家 jb51.cc|jb51.cc 

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)

# End www.jb51.cc

获取一行数据:
 

# @param python通过thrift操作hbase实例
# @author 编程之家 jb51.cc|jb51.cc 

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

# End www.jb51.cc

返回多行则需要使用scan:
 

# @param python通过thrift操作hbase实例
# @author 编程之家 jb51.cc|jb51.cc 

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

# End www.jb51.cc

scannerGet则是每次只取一行数据:

# @param python通过thrift操作hbase实例
# @author 编程之家 jb51.cc|jb51.cc 

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',None)
result = client.scannerGet(id)
while result:
    print result
    result = client.scannerGet(id)

# End www.jb51.cc
原文链接:https://www.f2er.com/python/526885.html

猜你在找的Python相关文章