天天看点

Happybase的基本使用

happybase是python通过thrift访问hbase的库,方便快捷。

<code>import happybase</code>

<code></code>

<code>connection = happybase.connection('hostname')</code>

<code>table = connection.table('table-name')</code>

<code>table.put('row-key', {'family:qual1': 'value1', 'family:qual2': 'value2'})</code>

<code>row = table.row('row-key')</code>

<code>print row['family:qual1'] # prints 'value1'</code>

<code>for key, data in table.rows(['row-key-1', 'row-key-2']):</code>

<code>print key, data # prints row key and data for each row</code>

<code>for key, data in table.scan(row_prefix='row'):</code>

<code>print key, data # prints 'value1' and 'value2'</code>

<code>row = table.delete('row-key')</code>

<code># lazy connection</code>

<code>connection = happybase.connection('somehost', autoconnect=false)</code>

<code># and before first use:</code>

<code>connection.open()</code>

<code># show all tables</code>

<code>print connection.tables()</code>

<code># using table namespace</code>

<code>connection = happybase.connection('somehost', table_prefix='myproject')</code>

<code>connection.create_table(</code>

<code>'mytable',</code>

<code>{'cf1': dict(max_versions=10),</code>

<code>'cf2': dict(max_versions=1, block_cache_enabled=false),</code>

<code>'cf3': dict(), # use defaults</code>

<code>}</code>

<code>)</code>

<code>table = connection.table('mytable')</code>