亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

利用Python調用HBASE

發布時間:2020-07-19 12:48:05 來源:網絡 閱讀:1351 作者:DBAspace 欄目:大數據

利用Python調用HBASE的 需要安裝thrift hbase-thrift 

啟動hbase的thrift服務:bin/hbase-daemon.sh start thrift 默認端口是9090

mysql 到hbase的數據同步:

1、put 

2、Importtsv

3、編寫MapReduce Job導入

4、sqoop

簡單code:

#!/usr/bin/env python

#coding=utf-8

import sys

sys.path.append('/usr/lib/python2.6/site-packages/hbase')

from thrift import Thrift

from thrift.transport import TSocket

from thrift.transport import TTransport

from thrift.protocol import TBinaryProtocol

from hbase import Hbase

from hbase.ttypes import *

import csv

from hbase.ttypes import ColumnDescriptor, Mutation, BatchMutation, TRegionInfo

from hbase.ttypes import IOError, AlreadyExists

######

def client_conn():

transport=TSocket.TSocket("172.16.10.87",9090)

transport=TTransport.TBufferedTransport(transport)

protocol=TBinaryProtocol.TBinaryProtocol(transport)

client=Hbase.Client(protocol)

transport.open()

return client

def __del__():

transport.close()


if __name__=="__main__":

client=client_conn()

#獲取表名字

print client.getTableNames()

##創建表

#client.createTable('name2',[ColumnDescriptor(name="user_id:",maxVersions=1),ColumnDescriptor(name="user_name"),])

#寫入數據

client.mutateRow('name2','a1',[Mutation(column='user_id:1',value="1")])

client.mutateRow('ca_record','1',[Mutation(column='user_id:0',value='5')])

##獲取數據


aa=client.getRow('name2','a1')

for r in aa:

   print 'row',r.row 

   print '\br'

   print 'value',r.columns.get("user_id:1").value

##刪除表

#client.disableTable("t1")

#client.deleteTable("t1")

print client.getTableNames()

###獲取表的行鍵值

#print client.scannerGet(client.scannerOpen('t2',"cmd",["a"]))

print client.scannerGet(client.scannerOpen('t2',"",["a"])) #當row key為空取第一個



print "------"

print client.getColumnDescriptors('t3')

#在自己開發環境  只要安裝好thrift 及hbase-thrift的包,在import的時候不會出問題

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

皮山县| 德阳市| 洪湖市| 禄劝| 巴马| 民丰县| 黄平县| 新巴尔虎左旗| 林西县| 河池市| 克什克腾旗| 灵台县| 运城市| 酉阳| 满城县| 高青县| 汶川县| 焉耆| 黎川县| 怀化市| 仲巴县| 潞城市| 阳原县| 永年县| 西城区| 旬邑县| 永福县| 武陟县| 张家港市| 林甸县| 顺平县| 比如县| 扬中市| 二手房| 彝良县| 大连市| 琼海市| 高雄县| 宜春市| 甘泉县| 正宁县|