Python中HBase的操作示例代码分析

黄舟

Lepaskan： 2017-05-07 11:02:51

asal

1760 orang telah melayarinya

安装HBase

HBase是一个构建在HDFS上的分布式列存储系统，主要用于海量结构化数据存储。这里，我们的目标只是为Python访问HBase提供一个基本的环境，故直接下载二进制包，采用单机安装。下载后解压，修改配置文件，然后可以直接启动HBase了。所用系统版本为ubuntu14.04。

下载

wget https://mirrors.tuna.tsinghua.edu.cn/apache/hbase/1.2.4/hbase-1.2.4-bin.tar.gz tar zxvf hbase-1.2.4-bin.tar.gz

Salin selepas log masuk

配置

修改hbase-env.sh，设置JAVA_HOME。

export JAVA_HOME=/usr/lib/jvm/java-8-oracle

Salin selepas log masuk

修改hbase-site.xml，设置存储数据的根目录。

<configuration>
    <property>
        <name>hbase.rootdir</name>
        <value>file:///home/mi/work/hbase/data</value>
    </property></configuration>

Salin selepas log masuk

启动

bin/start-hbase.sh  # 启动bin/hbase shell  # 进入hbase交互shell

Salin selepas log masuk

安装Thrift

安装好HBase之后，还需安装Thrift，因为其他语言调用HBase时，需要通过Thrift进行连接。

安装Thrift依赖

sudo apt-get install automake bison flex g++ git libboost1.55 libevent-dev libssl-dev libtool make pkg-config

Salin selepas log masuk

PS: libboost1.55-all-dev，在我的ubuntu14.04上安装有点问题，所以装的是libboost1.55。

编译安装

下载源码，解压后进行编译安装。Thrift下载地址

tar zxf thrift-0.10.0.tar.gzcd thrift-0.10.0/./configure 
--with-cpp --with-boost --with-python --without-csharp --with-java 
--without-erlang --without-perl --with-php --without-php_extension --without-ruby --without-haskell  
--without-gomake  # 编译耗时较长sudo make install

Salin selepas log masuk

启动HBase的Thrift服务

bin/hbase-daemon.sh start thrift

Salin selepas log masuk

检查系统进程

~/work/hbase/hbase-1.2.4/conf$ jps3009 ThriftServer4184 HMaster5932 Jps733 Main

Salin selepas log masuk

可以看到ThriftServer已成功启动，然后我们就可以使用多种语言，通过Thrift来访问HBase了。

Python操作HBase

下面以Python为例来演示如何访问HBase。

安装依赖包

sudo pip install thriftsudo pip install hbase-thrift

Salin selepas log masuk

Demo程序

from thrift import Thriftfrom thrift.transport 
import TSocketfrom thrift.transport import TTransportfrom thrift.protocol 
import TBinaryProtocolfrom hbase import Hbasefrom hbase.ttypes import *

transport = TSocket.TSocket(&#39;localhost&#39;, 9090)

transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)

client = Hbase.Client(protocol)
transport.open()

contents = ColumnDescriptor(name=&#39;cf:&#39;, maxVersions=1)# client.deleteTable(&#39;test&#39;)client.createTable(&#39;test&#39;, [contents])print client.getTableNames()# insert datatransport.open()

row = &#39;row-key1&#39;mutations = [Mutation(column="cf:a", value="1")]
client.mutateRow(&#39;test&#39;, row, mutations)
# get one rowtableName = &#39;test&#39;rowKey = &#39;row-key1&#39;result = client.getRow(tableName, rowKey)
print resultfor r in result:    
print &#39;the row is &#39;, r.row    
print &#39;the values is &#39;, r.columns.get(&#39;cf:a&#39;).value

Salin selepas log masuk

执行结果：

[&#39;test&#39;]
[TRowResult(columns={&#39;cf:a&#39;: TCell(timestamp=1488617173254, value=&#39;1&#39;)}, row=&#39;row-key1&#39;)]
the row is  row-key1
the values is  1

Salin selepas log masuk

Atas ialah kandungan terperinci Python中HBase的操作示例代码分析. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!