连接Hbase避坑指南

1.通过pip命令安装 happybase 和 thrift 两个库

命令: pip install happybase pip install thrift 注意:如果需要更新pip版本,请先更新。

2.创建一个.py文件。

导入happybase文件。 import happybase 连接Hbase避坑指南

 

 

happybase 是基于 thrift 库进行二次封装优化的,所以需要依赖 thrift 库的方法,安装即可无需导入。

3.创建数据库连接。

通过Connection方法创建数据库连接。 happybase.Connection()

4.修改连接参数

先上源码 连接Hbase避坑指南

 

 

1)由于本公司采用的是集群环境,所以我们只需要写入一个子节点ip就可以。(根据自身使用的实际场景填入ip) 2)hbase连接可以不需要手动设置端口号,默认即可。 3)踩坑处:关闭数据库的自动连接,更改为手动连接。(由于数据库默认配置中 autoconnect = True 自动连接,我们不需要连接就可以直接查询数据,但是只能查一次,后续无法继续查询,原因不详。) 连接代码:
happybase.Connection(host='xxx.xxx.xxx.xxx', autoconnect=False)

连接Hbase避坑指南

 

 

上一篇:应该将文本文件中的“Date”格式作为Json读取,然后使用Python插入到MongoDB中?


下一篇:NoSql Cassandra