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

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐