使用Python访问Phoenix

news2024/10/6 12:18:47

需求分析

理解Phoenix的原理及应用场景，理解Thrift的原理及操作，掌握Python如何访问操作HBase。

系统实现

实验流程分析：

开启HBase集群

在Phoenix上创建表

启动Thrift服务

实现Python访问HBase

关闭启动的服务

开启HBase集群：

开启ZooKeeper集群

在master，slave1和slave2上分别打开Zookeeper集群

查看Zookeeper的运行状态

开启Hadoop集群

在master上开启Hadoop集群

启动HBase集群

在master上启动HBase集群

在Phoenix上创建表：

启动Phoenix服务

执行！table指令，出现如下的表

创建Phoenix表

创建一个Phoenix表，表名为population，具体指令如下：

create table if not exists population(
state char(2) not null,
city varchar not null,
population bigint constraint my_pk primary key(state,city)
);

向表中插入数据

向population表插入数据，具体指令如下：

查询表中插入数据

使用seletc命令查询population表中数据

数据如下

启动Thrift服务：

启动HBase Thrift服务

在master服务器启动Thrift服务，具体指令如下：

进入HBase Shell客户端

在任意一台服务器上进入HBase Shell客户端，具体指令如下：

查看HBase表

表中数据如下

实现Python访问HBase：

编写Python程序

在master服务器输入以下指令，打开文件

输入以下代码

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('master', 9090)
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = Hbase.Client(protocol)
transport.open()
result = client.getRow('POPULATION','CALos Angeles')
print(result)