使用python写入hbase 2.0

pip install happybase

import happybase

connection = happybase.Connection(host='hbase_host', port='hbase_port')

table_name = 'my_table'
column_family = 'cf'
connection.create_table(table_name, {column_family: dict()})

table = connection.table(table_name)
row_key = 'row_key'
data = {'cf:column1': 'value1', 'cf:column2': 'value2'}
table.put(row_key, data)

import happybase

def write_to_hbase():
    connection = happybase.Connection(host='hbase_host', port='hbase_port')
    table_name = 'my_table'
    column_family = 'cf'

    connection.create_table(table_name, {column_family: dict()})
    table = connection.table(table_name)
    row_key = 'row_key'
    data = {'cf:column1': 'value1', 'cf:column2': 'value2'}
    table.put(row_key, data)

    connection.close()

if __name__ == '__main__':
    write_to_hbase()