Maison >développement back-end >Tutoriel Python >Comment se connecter et démarrer Hive en Python

Comment se connecter et démarrer Hive en Python

伊谢尔伦
伊谢尔伦original
2017-04-29 10:22:132400parcourir

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!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn