我正在尝试使用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无法处理的字节字符串。在
如何从没有键错误的行中返回列族?在
工作正常。在
相关问题 更多 >
编程相关推荐