Heim >Backend-Entwicklung >Python-Tutorial >So verbinden und starten Sie Hive in Python

So verbinden und starten Sie Hive in Python

伊谢尔伦
伊谢尔伦Original
2017-04-29 10:22:132400Durchsuche

1. Bevor Sie Python zum Herstellen einer Verbindung mit Hive verwenden, müssen Sie die Dateien in lib/py unter dem Hive-Installationspaket in die Site-Pakete in sys.path von Python kopieren, andernfalls wird beim Einführen des entsprechenden Codes ein Fehler gemeldet Das zu verwendende Paket wird zum Aufrufen des Hive-Clients verwendet.

2 Hive's Thrift starten

Stellen Sie sicher, dass die folgenden Dienste aktiviert sind:

hive --service hiveserver

Der Standardport ist 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])

Das obige ist der detaillierte Inhalt vonSo verbinden und starten Sie Hive in Python. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn