#導(dǎo)入thrift和habse包
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from hbase import Hbase
from hbase.ttypes import *

#此處可以修改地址和端口
host = '192.168.1.1'
#默認(rèn)端口為9090
port = 9090
#要查詢(xún)的表名
table = 'table_name'
#定義一個(gè)過(guò)濾器，此為關(guān)鍵步驟
filter = "RowFilter(=,'regexstring:.3333.')" #此行原創(chuàng)：）
# Make socket
transport = TSocket.TSocket(host, port)
# Buffering is critical. Raw sockets are very slow
# 還可以用TFramedTransport,也是高效傳輸方式
transport = TTransport.TBufferedTransport(transport)
# Wrap in a protocol
#傳輸協(xié)議和傳輸過(guò)程是分離的，可以支持多協(xié)議
protocol = TBinaryProtocol.TBinaryProtocol(transport)
#客戶端代表一個(gè)用戶
client = Hbase.Client(protocol)
#打開(kāi)連接
try:
transport.open()
scan.filterString=filter
scanner = client.scannerOpenWithScan(table, scan)
except Exception:
finally:
client.scannerClose(scan)
transport.close()
連接代碼網(wǎng)上一搜一大堆，非原創(chuàng)，來(lái)源已不可考，非本人研究成果；
關(guān)鍵就是這個(gè)："RowFilter(=,'regexstring:.3333.')"
這個(gè)過(guò)濾器要寫(xiě)對(duì)，hbase有十幾種內(nèi)置的過(guò)濾器方法，有幾種比較運(yùn)算符和比較器，上面這個(gè)是正則方式，即'regexstring:.3333.'；
過(guò)濾器整個(gè)雙引號(hào)里面的內(nèi)容會(huì)通過(guò)thrift傳給hbase服務(wù)端處理，下劃線這部分正則要支持java的正則要求不然會(huì)報(bào)錯(cuò)