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!