python操作hbase增删改

Posted 2022-05-24 宝哥大数据

1、启动hbas thrift服务

sudo .//hbase-daemon.sh start thrift

2、引入python 的hbase包 happybase

import happybase

3、获取连接

# ，端口默认是9090 hbase thrift 启动的默认端口也是9090
connection = happybase.Connection('ip',port=9090)

4、 获取表

table = connection.table("member_tag")

5、 删除一行数据

table.delete(row="mid_001", columns=None)

6、 删除一列数据

table.delete(row="mid_001", columns='info:age')

7、批量删除

batch = table.batch()
batch.delete(row='mid_001', columns=['tag:age'])
batch.delete(row='mid_002', columns=['tag:age'])
batch.send()

python操作hbase 参考 https://happybase.readthedocs.io/en/latest/user.html#establishing-a-connection