Как изменить таблицу в Hbase, используя Thrift в Python

Question

Я могу подключиться к Hbase, используя сервер Thrift на Python. Я следую этому руководству: connection-hbase-with-python-application-using-thrift-server для подключения к Hbase. Мне нужно изменить таблицу сейчас . Может кто-нибудь помочь с этим? Пожалуйста, обратите внимание, я использую версию Python2.6.

Спасибо

Answer 1

Вот как вы можете сделать HBase Put в Python, используя happybase API. Убедитесь, что сервер Thrift работает на вашем сервере:

import happybase

conn = happybase.Connection(HBASE_SERVER) # uses default port 9095, but provide second arg if non-default port
myTable = conn.table(TABLE_NAME)
myTable.put(b'rowKey', {b'CF:CN': b'TextValue'})

Метод table.put принимает rowKey в виде байтов и словарь, который отображает семейство столбцов и имя столбца в значения. Есть и другие варианты аргументов, с которыми можно поиграться, например, отметка времени, настройки WAL и т. Д. Но этот минимальный пример должен работать.