參考鏈接https://happybase.readthedocs.io/en/latest/news.html#happybase-0-9

1.安裝依賴包

pip install happybase

pip install thrift

2.連接Hbase

import happybase

connection = happybase.Connection('cdh04')

#注意cdh04為Thrift server地址

print (connection.tables())

3.happybase的使用

3.1建立連接

import happybase

connection = happybase.Connection('cdh04')

當connection被創建的時候，默認自動與Hbase建立socket連接的

若不想自動與Hbase建立socket連接，可以將autoconnect參數設置為False

connection = happybase.Connection('cdh04', autoconnect=False)

然后手動與Hbase建立socket連接

connection.open()

3.2查看可用的table

print (connection.tables())

3.2創建table

創建table名字Jacson_Bai包含3個列族：INFO、NAME、SOURCE

connection.create_table(

'Jacson_Bai',

{

'INFO': dict(max_versions=3),

'NAME': dict(max_versions=1, block_cache_enabled=False),

'SOURCE': dict(),

}

)

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的python操作hbase,Python操作Hbase的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。