Python如何連接和啟動Hive

伊谢尔伦
發布: 2017-04-29 10:22:13
原創
2386 人瀏覽過

1.在使用Python連接hive之前,需要將hive安裝套件下的lib/py中的檔案拷貝到python的sys.path中的site-packages下,否則引入對應的套件會報錯,這個是使用hive提供的Python介面來呼叫hive客戶端。

2 啟動hive 的thrift

確保以下服務開啟:

hive --service hiveserver

預設連接埠是10000

from hive_service import ThriftHive
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
def ReadHiveTest(sql):
try:
tSocket = TSocket.TSocket('172.18.1.88',10000)
tTransport = TTransport.TBufferedTransport(tSocket)
protocol = TBinaryProtocol.TBinaryProtocol(tTransport)
client = ThriftHive.Client(protocol)
tTransport.open()
client.execute(sql)
return client.fetchAll()
except Thrift.TException, tx:
print '%s' % (tx.message)
finally:
tTransport.close()
if __name__ == '__main__':
showDatabasesSql = 'show databases'
showTablesSql = 'show tables'
selectSql = 'SELECT * FROM 07_jn_mysql_2'
result = ReadHiveTest(selectSql)
print(result[1])
登入後複製

以上是Python如何連接和啟動Hive的詳細內容。更多資訊請關注PHP中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板