HappyBase操作HBase

启动HBase thrift server :

hbase-daemon.sh start thrift

安装happy base

pip install happybase

如何使用HappyBase
建立连接

import happybase
connection = happybase.Connection('somehost')

当连接建立时, 会自动创建一个与 HBase Thrift server的socket链接. 可以通过参数禁止自动链接, 然后再需要连接是调用 Connection.open():

connection = happybase.Connection('somehost', autoconnect=False)
# before first use:
connection.open()

Connection 这个类提供了一个与HBase交互的入口, 比如获取HBase中所有的表: Connection.tables():

print(connection.tables())

操作表
Table类提供了大量API, 这些API用于检索和操作HBase中的数据。在上面的示例中，我们已经使用Connection.tables（）方法查询HBase中的表。如果还没有任何表，可使用Connection.create_table（）创建一个新表：

connection.create_table('users',{'cf1': dict()})

创建表之后可以传入表名获取到Table类的实例:

table = connection.table('mytable')

查询操作

# api
table.scan() #全表查询
table.row('row_key') # 查询一行
table.rows([row_keys]) # 查询多行
#封装函数
def scanQuery():# 创建和hbase的连接connection = happybase.Connection('192.168.19.137')#通过connection找到user表 获得table对象table = connection.table('user')filter = "ColumnPrefixFilter('username')"#row_start 指定起始rowkey 缩小查询范围#filter 添加过滤器for key,value in table.scan(row_start='rowkey_10',filter=filter):print(key,value)# 关闭连接connection.close()
def getQuery():connection = happybase.Connection('192.168.19.137')# 通过connection找到user表 获得table对象table = connection.table('user')result = table.row('rowkey_22',columns=['base_info:username'])#result = table.row('rowkey_22',columns=['base_info:username'])result = table.rows(['rowkey_22','rowkey_16'],columns=['base_info:username'])print(result)# 关闭连接connection.close()

插入数据

#api
table.put(row_key, {'cf:cq':'value'})
def insertData():connection = happybase.Connection('192.168.19.137')# 通过connection找到user表 获得table对象table = connection.table('users')table.put('rk_01',{'cf1:address':'beijing'})# 关闭连接for key,value in table.scan():print(key,value)connection.close()

删除数据

#api
table.delete(row_key, cf_list)def deleteData():connection = happybase.Connection('192.168.19.137')# 通过connection找到user表 获得table对象table = connection.table('users')table.delete('rk_01',['cf1:username'])# 关闭连接for key,value in table.scan():print(key,value)connection.close()

删除表

#api
conn.delete_table(table_name, True)
#函数封装
def delete_table(table_name):pretty_print('delete table %s now.' % table_name)conn.delete_table(table_name, True)

HBase-shell及happyhbase相关推荐

hbase shell 查看列名_Hbase的简单命令使用
通过hbase shell进入到cli窗口 1.创建表 create 't01','cf01' t01为表名 cf01为列族名在hbase当中命令是需要区分大小的在hbase当中字符串是需要加上引 ...
hbase shell命令_HBASE的shell操作
前言我们知道hbase其实是架构在hdfs上的一个分布式数据库,既然是数据库那么这篇文章就主要围绕着我们最熟悉的增删改查来做.当然了,其实hbase的shell操作在真实的企业中几乎不用,这个很简单 ...
hbase shell编码显示中文
最近测试hbase shell,碰到个中文显示编码问题,最后通过Python解决了问题,具体操作如下: hbase(main):015:0* scan 'fr_test_hbase:test_log1 ...
HBase shell 命令执行
来源:http://www.oldboyedu.com/zuixin_wenzhang/index/id/132.html HBase Shell 提供了大多数的 HBase 命令,通过 HBase ...
hbase shell命令扩展（转自http://www.netfoucs.com/cuirong1986/article/details/7986900）
也许你还不清楚我在说什么,看一下下面的截图你就明白了: 好吧,如果您感兴趣,可以继续看下去了. hbase是以字节数组的形式存储数据的,当你直接用API或通过hbase 自带的shell端去查询数据时 ...
01 HBase基本概念和hbase shell常用命令用法
本文转载自:http://archive.cnblogs.com/a/2178064/ 1. 简介 HBase是一个分布式的.面向列的开源数据库,源于google的一篇论文<bigtable:一 ...
HBase基本概念和hbase shell常用命令用法
1. 简介 HBase是一个分布式的.面向列的开源数据库,源于google的一篇论文<bigtable:一个结构化数据的分布式存储系统>.HBase是Google Bigtable的开源实 ...
HBase总结（十三）HBase Shell 常用命令及例子
下面我们看看HBase Shell的一些基本操作命令,我列出了几个常用的HBase Shell命令,如下: 名称命令表达式创建表 create '表名称', '列名称1','列名称2','列名称N ...
在SecureCRT中，hbase shell不能回退的问题
解决方法: 在hbase shell中如输入出错,按住Ctrl+删除键(backspace) 即可删除!
Hbase shell详情
HBase 为用户提供了一个非常方便的使用方式, 我们称之为"HBase Shell". HBase Shell 提供了大多数的 HBase 命令, 通过 HBase Shell ...

HBase-shell及happyhbase

HappyBase操作HBase

HBase-shell及happyhbase相关推荐

最新文章

热门文章