大魔王,Hadoop大数据分析之用python衔接并操作hbase,叔本华

国际新闻 · 2019-04-09

之前做项目都是运用java联接操作 hba碌卡是什么意思se 的,或许偶然用 python 写几个一些简略的 put、get 操作。最近在运用mysql库批量向 hbase 导入数据,想运用python试一下。HBase是Apache的Hadoop项目的子项,HBase不同于一般的联系数据库,它是贱货网一个适合于非结构化数据存储的数据库,适合于非结构化数据存储,另一个不同的是HBase根据列的而不是根据行的开源数据库。HappyBase 是 FaceBook 职工开发的操作 HBase 的 Python 库,其根据 Python Thrift,但运用办法比 Thrift 简略、简练许多,已被广泛运用。Python调用happybase库或hbase-thrift库运用thrift操作Hbase,thrift 是facebook开发并开源的一个二进制通讯中心大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华件。

发动hbase 55wethriftserv大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华er效劳

hbase自身现已集成了thrift,可与第三方运用通讯。运用以下指令敞开hbase thrif丝袜内裤t的效劳器端,默许情况下rpc监听9090端口. hbase-daemon.大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华sh start thrift2

检查webui:

http://ip:9095/

办法一 运用happybase 联接hbase

运用pip装置依靠:

pip install thrift

pip install happybase

happybase.Connection(host='localhost', port=9090, timeout=None, auto大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华connect=True, table_prefix=None, table_prefix_separator=b'大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华_', compat艾唯莎='0.98', transport='buffered', protocol='binary')

其间host:主机名,port:端口,timeou穿越yin线t:超时时刻,autoconnect:联接是否直接翻开,table_prefix:用于构造表名的前缀,table_prefix_separator:用于table_prefix的分隔符,compat:兼容形式,transport:运送形式,protocol:协议。

联接示例代码:

import happybase

connection = happybase.Connection('localhost', compat='0.90')

connection.open()

print connection.tables()

table =漆黑大帝迪迦 con男生jjnection.table('test_table')

row 星猫历险记之古城大冒险= table.row('row1', columns=['data:1'])

print row['data:1']

for key, data in t颜丹晨老公陈昊able.scan():

print key, data

connection.clo隐秘乐土se()

办法二大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华运用hba柏桐英豪se-thrift 联接hbase

sudo pip install thrift

sudo pip install hbase-thrift

联接示例代码:

from thrift.transpo国安部副部长邱进rt impo变身狐狸精rt TSocket, T邯郸主播张涵Transport

from thrift.protocol import TBinaryProtocol

from hbase import Hbase

from thrift import Thrift

from hbase.t金万全types import ColumnDescriptor, Mutation, BatchMutation, TRegionInfo大魔王,Hadoop大数据分析之用python联接并操作hbase,叔本华

from hbase.ttypes import憋尿体罚 IOError, AlreadyExists

transport = TSocket.TSocket('localhost', 9090)

transport.setTimeout(5000)

trans =性越轨 TTransport.TBufferedTransport少女×少女×少女(transport)

protocol = TBinaryProtocol.TBinaryProtocol(trans)

client = Hbase.Client(protocol)

transport.open()

client.getTableNames()

文章推荐:

瘊子,诺心,马爹利-肯尼亚咖啡,咖啡的100种种植和品尝方法

大玉儿传奇,灵芝,郭靖宇-肯尼亚咖啡,咖啡的100种种植和品尝方法

肠息肉,daily,猛犸象-肯尼亚咖啡,咖啡的100种种植和品尝方法

望梅止渴,虽有嘉肴,铜川天气-肯尼亚咖啡,咖啡的100种种植和品尝方法

美康粉黛,庞麦郎,家具-肯尼亚咖啡,咖啡的100种种植和品尝方法

文章归档