使用happybase时出现KeyError,因为列族以字节字符串的形式返回

2024-05-14 21:03:31 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在尝试使用happybase访问我的Hbase表。在

我正在使用happybase github repo中的python3分支。在

这是我的测试代码:

import happybase
from settings import HBASE_THRIFT_SERVER

connection = happybase.Connection(HBASE_THRIFT_SERVER)
print(connection.tables())
table = connection.table('people')


def get_audience(audience_qual,start,end):
    row = table.row(audience_qual)
    print(row)
    return row['data:record']


def get_all_audience():
    for key, data in table.scan():
        print(key, data)


def put_people_row(row_key, people):
    table.put(row_key, {'data:record': people})

if __name__ == '__main__':
    get_all_audience()
    print(get_audience('daily201605180000004', 0, 0))

当我执行此操作时,我在行上得到键错误,因为列族是作为字节字符串返回的。在

^{pr2}$

Happybase文档没有显示任何使列族工作的转换。但是,它确实提到HBase将数据存储为happybase无法处理的字节字符串。在

如何从没有键错误的行中返回列族?在


Tags: keyimportdatagetserverdeftableconnection

热门问题