python 带有行过滤器的happybase连接池演示

Posted 2021-05-09

# -*- coding: utf-8 -*-
import happybase

pool = happybase.ConnectionPool(size=10, host='xxx')

if __name__ == '__main__':
    with pool.connection() as conn:
        table = conn.table('table')
        # row filter demo
        row_filter = "RowFilter(=, 'regexstring:1234')"
        for key, value in table.scan(filter=row_filter):
            print key, value