Maison >développement back-end >Tutoriel Python >Comment se connecter et démarrer Hive en Python
1. Avant d'utiliser Python pour vous connecter à Hive, vous devez copier les fichiers dans lib/py sous le package d'installation de Hive vers les packages de site dans sys.path de Python, sinon une erreur sera signalée lors de l'introduction du fichier correspondant. package.Il s'agit d'utiliser l'interface Python fournie par hive pour appeler le client hive.
2 Démarrez Hive's Thrift
Assurez-vous que les services suivants sont activés :
hive --service hiveserver
Le port par défaut est 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])
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!