Python访问HBase全攻略（完备版，看这个）

以下是一些利用 HappyBase（一个 Python 客户端库，用于与 HBase 交互）的示例代码，展示了怎样连接到 HBase、创建表、插入数据、查询数据和删除数据的根本操作：

---

1. 安装 HappyBase

（1）确保HDFS、Hbase、Zookeeper服务正常运行：

1. 1.启动hdfs
2.   start-dfs.sh
4. 2.启动Hbase
5.   start-hbase.sh
7. 3.开启ThriftServer
8.   hbase-daemon.sh start thrift
9.   
10. 4.启动hbase shell
11.    hbase shell

复制代码

2. 查看进程

确保具有 ThriftServer：

1. [root@localhost~]# jps
2. 1556 HRegionServer
3. 485 SecondaryNameNode
4. 230 NameNode
5. 1400 HMaster
6. 1993 ThriftServer
7. 1114 HQuorumPeer
8. 2111 Jps
9. 3514 DataNode

复制代码

---

3. 连接到 HBase

（1）Windows下安装happybase库：

1. pip install happybase -i https://pypi.tuna.tsinghua.edu.cn/simple

复制代码

查看happybase是否安装成功（进入python进行导包）：

（2）利用pycharm新建一个python项目（很简单，线下也会讲）
4. 连接到 HBase

1. import happybase
3. # 连接到 HBase Thrift 服务
4. connection = happybase.Connection(host='localhost', port=9090)
5. print("已连接到 HBase")
8. # 通过conn对象，调用tables方法，获取hbase中的表格
9. print(connection .tables())

复制代码

---

5 创建表

1. # 在默认命名空间下创建名为 'test_table' 的表，并定义列族 'cf1'、'cf2'、'cf3'
2. connection.create_table(
3.     'table_name',
4.     {
5.             'cf1': dict(max_versions=5),   # 列族1，列族名为 'cf1'
6.                 'cf2': dict(max_versions=3),   # 列族2，列族名为 'cf2'
7.                 'cf3': dict()                  # 列族3，列族名为 'cf3',默认属性
8.         }  
9. )
10. print("表已创建成功！")
12. #在命名空间bigdata下，创建新表student，包含列族info，属性为默认;包含列族score，属性设置最大版本号为5
13. conn.create_table("bigdata:student",{"info":dict(),"score":dict(max_versions=5)})

复制代码

1. # 以下代码编写得更优美，更好
2. # 创建名为 'test_table' 的表，并定义列族 'cf'（如果表已存在，可跳过此步骤）
3. table_name = 'test_table'
4. if table_name.encode() not in connection.tables():
5.         connection.create_table(
6.                 table_name,
7.             {
8.                     'cf1': dict()
9.             }  
10. )
11. print(f"表 {table_name} 已创建成功！")

复制代码

---

6.查看表格的列族信息

1. # 1.获取某个表格对象
2. table = conn.table("ns:table_name")
4. # 2.查询表格的列族信息
5. print(table.families())

复制代码

---

7. 插入数据

1. # 获取表对象
2. table = connection.table('ns:table_name')
3. # 表不存在也不会报错，本步骤不会真的链接到HBase，只是在代码内创建一个table对象
5. # 插入数据
6. # table.put()接收行键和要存储的数据。数据应该是一个字典，包含多个单元格值，将列名映射到一个值：
7. table.put(b'row1', {b'cf:col1': b'value1', b'cf:col2': b'value2'})
8. table.put(b'row2', {b'cf:col1': b'value3', b'cf:col2': b'value4'})
11. for examples:
13. stu_table = conn.table('bigdata:student')
14. stu_tab.put(b"1001",{b"info:name":b"zhangsan",b"info:age":b"20"})
15. stu_tab.put(b"1002",{b"info:name":b"lisi",b"info:age":b"22"})
16. stu_tab.put(b"1003",{b"info:name":b"wangwu",b"info:age":b"21"})
17. stu_tab.put(b"1004",{b"info:name":b"zhaoliu",b"info:age":b"25"})
19. print("数据已成功插入！")

复制代码

---

5. 查询数据

查询单行数据

1. row = table.row(b'row1')
2. print(f"Retrieved row:", {row})
4. #通过行键、列族：列限定符查询某个单元格值
5. row_name = student_tab.row("row_key1",["cf1:c1"])
6. print(row_name)

复制代码

查询多行数据

1. #通过行键查询多行数据(返回值是字典列表)
2. row_1_2 = table.rows(["1001","1002"])
3. print(row_1_2)

复制代码

查询全部数据

1. for key, data in table.scan():
2.     print(f"Row key: {key}, Data: {data}")

复制代码

---

6. 删除数据

删除单个单位格

1. table.delete(b'row1', columns=[b'cf:col1'])
2. print("Column 'cf:col1' in 'row1' deleted")

复制代码

删除整行数据

1. table.delete(b'row2')
2. print("Row 'row2' deleted")
4. # 要删除一列或多列而不是整行，还需指定 columns 参数：
5. table = conn.table('bogdata:student')
6. #删除某一个单元格数据(所有版本的数据都会删除)
7. table.delete("1001",columns=["score:nosql"])

复制代码

---

7. 删除表

1. # 先禁用表
2. connection.disable_table('test_table')
4. # 然后删除表
5. connection.delete_table('test_table')
6. print("表已被删除！")

复制代码

---

8. 关闭连接

1. connection.close()
2. print("连接已关闭！")

复制代码

---

示例流程的完备代码

以下代码整合了上述步调：

1. import happybase
3. def main():
4.     connection = happybase.Connection(host='localhost', port=9090)
5.     print("Connected to HBase")
6.    
7.     # 创建表
8.     try:
9.         connection.create_table('test_table', {'cf': dict()})
10.         print("Table 'test_table' created")
11.     except Exception as e:
12.         print("Table might already exist:", e)
13.    
14.     table = connection.table('test_table')
16.     # 插入数据
17.     table.put(b'row1', {b'cf:col1': b'value1', b'cf:col2': b'value2'})
18.     table.put(b'row2', {b'cf:col1': b'value3', b'cf:col2': b'value4'})
19.     print("Data inserted")
20.    
21.     # 查询数据
22.     print("Row1 data:", table.row(b'row1'))
23.     for key, data in table.scan():
24.         print(f"Row key: {key}, Data: {data}")
26.     # 删除数据
27.     table.delete(b'row1', columns=[b'cf:col1'])
28.     print("Column 'cf:col1' in 'row1' deleted")
30.     # 删除表
31.     connection.disable_table('test_table')
32.     connection.delete_table('test_table')
33.     print("Table 'test_table' deleted")
35.     # 关闭连接
36.     connection.close()
37.     print("Connection closed")
39. if __name__ == '__main__':
40.     main()

复制代码

---

留意事项

• 确保 HBase 的 Thrift 服务已启动，通常可以通过以下命令启动：
  1. hbase thrift start

  复制代码
• 更换 localhost 和 9090 为实际的 HBase Thrift 服务主机名和端口。
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。