filter不起作用

qybjjes1  于 2021-06-08  发布在  Hbase
关注(0)|答案(1)|浏览(389)

我在hbase中有一个表,其中汉字存储在某一列中,比如'flt:crew_dept'. 现在我需要过滤掉所有flt:crew_dept'等于某个值。在hbase shell中执行此操作时,工作正常,如下所示

  1. scan 'PAX_EXP_FACT', {COLUMNS => ['FLT:CREW_DEPT'], FILTER => "SingleColumnValueFilter ('FLT', 'CREW_DEPT', =, 'binary:\xe4\xb8\x80\xe9\x83\xa8', true, true)", LIMIT => 5}
  2. ROW COLUMN+CELL
  3. CA101-20160808-PEK-001192753702 column=FLT:CREW_DEPT, timestamp=1500346136328, value=\xE4\xB8\x80\xE9\x83\xA8
  4. CA101-20161103-PEK-001181988752 column=FLT:CREW_DEPT, timestamp=1500346230204, value=\xE4\xB8\x80\xE9\x83\xA8
  5. CA101-20161105-PEK-000728690130 column=FLT:CREW_DEPT, timestamp=1500346244963, value=\xE4\xB8\x80\xE9\x83\xA8
  6. CA101-20161201-PEK-006731936575 column=FLT:CREW_DEPT, timestamp=1500346233640, value=\xE4\xB8\x80\xE9\x83\xA8
  7. CA101-20161212-PEK-001512808262 column=FLT:CREW_DEPT, timestamp=1500346223572, value=\xE4\xB8\x80\xE9\x83\xA8
  8. 5 row(s) in 0.0060 seconds

但是,在python中使用happybase执行类似操作时,不会返回任何结果:

  1. import happybase
  2. import datetime
  3. import pytz
  4. connection = happybase.Connection('192.168.199.200', port=9090)
  5. table = connection.table('PAX_EXP_FACT')
  6. filter_str = ""
  7. filter_str += "SingleColumnValueFilter('FLT', 'CREW_DEPT', =, 'binary:\xe4\xba\x8c\xe9\x83\xa8')"
  8. results = table.scan(
  9. filter=filter_str
  10. # ,limit=100
  11. )
  12. count = 0
  13. for key, data in results:
  14. count += 1
  15. print(data[b'FLT:CREW_DEPT'].decode('utf-8'))
  16. print('No. of flight matches:', count)
  17. connection.close()

返回0行。。。
有人能帮忙吗?非常感谢!!!

4jb9z9bj

4jb9z9bj1#

答案很简单。。。我应该用的

  1. "SingleColumnValueFilter('FLT', 'CREW_DEPT', =, 'binary:中文')"

而不是先将其转换为utf-8编码的字节字符串。。。即使在hbase shell中,我也可以做同样的事情(尽管它以问号的形式显示)

  1. scan 'PAX_EXP_FACT', {COLUMNS => ['FLT:CREW_DEPT'], FILTER => "SingleColumnValueFilter ('FLT', 'CREW_DEPT', =, 'binary:??', true, true)", LIMIT => 5}
  2. ROW COLUMN+CELL
  3. CA101-20160808-PEK-001192753702 column=FLT:CREW_DEPT, timestamp=1500353334419, value=\xE4\xB8\x80\xE9\x83\xA8
  4. CA101-20161103-PEK-001181988752 column=FLT:CREW_DEPT, timestamp=1500353426641, value=\xE4\xB8\x80\xE9\x83\xA8
  5. CA101-20161105-PEK-000728690130 column=FLT:CREW_DEPT, timestamp=1500353447707, value=\xE4\xB8\x80\xE9\x83\xA8
  6. CA101-20161201-PEK-006731936575 column=FLT:CREW_DEPT, timestamp=1500353432222, value=\xE4\xB8\x80\xE9\x83\xA8
  7. CA101-20161212-PEK-001512808262 column=FLT:CREW_DEPT, timestamp=1500353417107, value=\xE4\xB8\x80\xE9\x83\xA8
  8. 5 row(s) in 0.0100 seconds

使用子字符串将不起作用,这是我在提出这个愚蠢的问题之前一直在尝试的。。。

相关问题