1、连接数据库

import happybase
connection = happybase.Connection(host=host, port=port)

2、查询数据库中的所有表

table_name_list = connection.tables()

3、连接数据库中的表

enginetable = connection.table(table_name)

4、创建hbase表

families = {table_name: dict()
}
connection.create_table(table_name, families)

5、向hbase的某个表中插入数据

  • row_key 必须是唯一的,如果是相同数据库中的数据会被替换掉
  • 每个key需要带上表名 例如{“table_name:data”:“data”}
enginetable.put("row_key",{'table_name:Data': "[]"})

6、查询数据
row_start:开始行键(从左原则)

row_stop:结束行键(从左原则)

row_prefix:匹配的行键的 ROA 前缀

columns:入参的数据类型为list 需要显示什么字段,列表中就填写什么字段

filter:筛选器

例如:

data = enginetable.scan(row_prefix="1".encode("utf-8"), columns=["table_name:age"],filter = "SingleColumnValueFilter('table_name', 'age', =, 'binary:20') " )

timestamp:时间戳
include_timestamp:是否返回时间戳 入参:布尔类型

batch_size:设置检索结果的批大小

scan_batching:服务器端扫描批处理

limit:要返回的最大行数

sorted_columns:是否返回排序列

data = enginetable.scan(row_start=None, row_stop=None, row_prefix=None,columns=None, filter=None, timestamp=None,include_timestamp=False, batch_size=1000, scan_batching=None,limit=None, sorted_columns=False)

多条件查询
例如:

data= enginetable.scan(filter = "SingleColumnValueFilter('table_name', 'age', =, 'binary:123')" and "SingleColumnValueFilter('table_name', 'Time', =, 'binary:20221218001212')")

happybase对hbase数据库的基本操作相关推荐

  1. HBase数据库的基本操作增删改查

    # 进入hbase命令行,hbase需要在环境变量路径中 >hbase shell 表操作 # 显示hbase中的表 > list# 创建user表,包含info.data两个列族 > ...

  2. Python使用HappyBase连接Hbase与基本操作

    hbase基本概念可以参考:https://www.cnblogs.com/swordfall/p/8737328.html 文章目录 安装Hbase Python连接Hbase 1.创建.删除表结构 ...

  3. hbase数据库的一些基本操作(持续更新中)

    进入到hbase安装目录的bin文件下,运行./start-hbase.sh 既可以启动,启动不了是因为配置原因,具体自己搜索,输入hbase shell 即可进入hbase'数据库的命令环境. 1. ...

  4. Hbase(5)——python用happybase操作Hbase

    首先要在jvm上开启hbase服务 并且在jvm上的9090端口开启thrift服务:hbase thrift start-port:9090 在win上的python环境中装上happybase库: ...

  5. Hbase教程(二) Hbase数据库Shell命令

    Hbase教程(二) Hbase数据库Shell命令 1 Hbase- Shell命令 Hbase是分布式是一个分布式的.面向列的开源数据库,Hbase也提供了Shell命令对数据库增.删.改.查的权 ...

  6. JDBC编程:2(数据库的基本操作)

    数据库的基本操作 查询数据 在开始前先简单地介绍一下什么是静态SQL和动态SQL: 静态SQL,在编译阶段就可以确定数据库要做什么事情.在某种高级语言中,如果嵌入了SQL语句,而这个SQL语句的主体结 ...

  7. java连接Hbase数据库

    java连接Hbase数据库 如果是是连接机群上的Hbase服务,需要提前将相关的几个xml文件存放在本地的编程目录下,否则开发端无法获取机群信息及授权: hdfs-site.xml core-sit ...

  8. hbase 数据库简介安装与常用命令的使用

    一:hbase 简介与架构功能 二:hbase 安装与配置 三:hbase 常见shell 命令操作 一:hbase 简介与架构功能 1.1 为什么要使用hbase 数据库 传统的RDBMS关系型数据 ...

  9. 通过sql语句对MySql数据库的基本操作

    一.数据库的基本操作 1 CREATE DATABASE mybookstore; 2 DROP DATABASE mybookstore; 二.表的基本操作 1.创建表 insert into 表名 ...

最新文章

  1. 在Cacti上实现MSN报警机制
  2. python+appium+PyCharm==自动化测试APP环境
  3. 3线程的终止方式,线程属性,NPTL
  4. java post 登陆_java HttpPost 密码登录和提交表单的案例
  5. JS在页面限制checkbox最大复选数
  6. c语言整形符号位_C语言中32位有符号整数如何定义
  7. 正则表达式 10. 分组可选
  8. 征途mysql安装配置_征途服务端的配置和安装
  9. margin失效问题——嵌套块元素引起的外边距坍塌
  10. C语言动态申请内存空间
  11. 中文编程,最精致的python访客登记系统实例项目,微信机器人不再只当人工智障---08
  12. 【渝粤题库】广东开放大学 形成性考核 - 副本 (11)
  13. 《死亡搁浅》:在“联结”的世界里,是 “个人”在游戏中
  14. 配置管理——配置管理委员会
  15. 北京一日行之十二——植物园、蜜蜂馆、碧云寺、香山
  16. 【财经期刊FM-Radio|2020年11月03日】
  17. VELO3D宣布推出大幅面3D金属打印机Sapphire(R) XC,将生产率提高5倍,同时将成本降低75%
  18. 软件推荐——二维码生成工具(绿色版)
  19. Nginx+Apache一前一后双引擎驱动的你网站
  20. 葡萄酒评价问题_葡萄酒有设计问题

热门文章

  1. Jenkins 用户角色权限管理
  2. HTTP/2和HTTP/3
  3. [BZOJ2876] [NOI2012]骑行川藏
  4. 数据治理与数据安全研读开篇
  5. 时间序列的平稳性与差分法
  6. addEventListener( ) 方法 -- 事件监听
  7. java聊天室代码实训总结_java实训聊天系统报告总结
  8. 一晚迎来十三年里最大单日涨幅,告别2021,中概股终于触底?
  9. ENSP—NAT综合实验
  10. String转换成json