1.3Python访问Hbase
时间: 2023-11-29 13:06:32 浏览: 140
可以使用 happybase 库来访问 Hbase。这个库提供了一个 Python 接口,可以简单地连接到 Hbase 并执行各种操作。以下是一个简单的示例:
```python
import happybase
# 连接到 Hbase
connection = happybase.Connection(host='localhost', port=9090)
# 创建表
table_name = 'my_table'
column_family = 'cf'
connection.create_table(table_name, {column_family: {}})
# 插入数据
table = connection.table(table_name)
row_key = 'row1'
data = {'cf:col1': 'value1', 'cf:col2': 'value2'}
table.put(row_key, data)
# 获取数据
row = table.row(row_key)
print(row['cf:col1'], row['cf:col2'])
# 删除表
connection.delete_table(table_name, disable=True)
```
在这个例子中,我们首先使用 `happybase.Connection` 函数连接到本地运行的 Hbase 实例。然后,我们创建了一个名为 `my_table` 的表,并插入了一行数据。最后,我们检索了该行数据并打印了其中两个列的值。最后,我们删除了该表。
请注意,这只是一个简单的示例,实际的 Hbase 应用程序可能需要更复杂的查询和数据操作。
阅读全文