hbase python条件查询

在Python中使用Happybase库进行HBase的条件查询，可以按照以下步骤进行：

1. 导入Happybase库

import happybase

2. 连接HBase

connection = happybase.Connection(host='your_hbase_host', port=9090)

3. 选择HBase表

table = connection.table('your_hbase_table')

4. 定义查询条件

filter_str = "SingleColumnValueFilter('column_family', 'column_name', comparison_operator, 'value')"

其中，'column_family'和'column_name'分别是列族和列名称，comparison_operator是比较运算符，可以是EQUAL、GREATER、GREATER_OR_EQUAL、LESS、LESS_OR_EQUAL、NOT_EQUAL、NO_OP中的一个，'value'是待比较的值。

5. 执行查询

rows = table.scan(filter=filter_str)

6. 遍历查询结果

for key, data in rows:
    print(key, data)

完整代码示例如下：

import happybase

# 连接HBase
connection = happybase.Connection(host='your_hbase_host', port=9090)

# 选择HBase表
table = connection.table('your_hbase_table')

# 定义查询条件
filter_str = "SingleColumnValueFilter('column_family', 'column_name', comparison_operator, 'value')"

# 执行查询
rows = table.scan(filter=filter_str)

# 遍历查询结果
for key, data in rows:
    print(key, data)

注意：以上示例中的'your_hbase_host'、'your_hbase_table'、'column_family'、'column_name'、'comparison_operator'、'value'都需要根据实际情况进行替换。