Heim > Artikel > Backend-Entwicklung > So verbinden und starten Sie Hive in Python
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!