1.通过pip命令安装 happybase 和 thrift 两个库
命令: pip install happybase pip install thrift 注意:如果需要更新pip版本,请先更新。2.创建一个.py文件。
导入happybase文件。 import happybase
happybase 是基于 thrift 库进行二次封装优化的,所以需要依赖 thrift 库的方法,安装即可无需导入。
3.创建数据库连接。
通过Connection方法创建数据库连接。 happybase.Connection()4.修改连接参数
先上源码
1)由于本公司采用的是集群环境,所以我们只需要写入一个子节点ip就可以。(根据自身使用的实际场景填入ip) 2)hbase连接可以不需要手动设置端口号,默认即可。 3)踩坑处:关闭数据库的自动连接,更改为手动连接。(由于数据库默认配置中 autoconnect = True 自动连接,我们不需要连接就可以直接查询数据,但是只能查一次,后续无法继续查询,原因不详。) 连接代码:
happybase.Connection(host='xxx.xxx.xxx.xxx', autoconnect=False)