Python如何连接和启动Hive

2 启动hive 的thrift

确保以下服务开启：

hive --service hiveserver

默认端口是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(&＃39;172.18.1.88&＃39;,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 &＃39;%s&＃39; % (tx.message)
finally:
tTransport.close()
if __name__ == &＃39;__main__&＃39;:
showDatabasesSql = &＃39;show databases&＃39;
showTablesSql = &＃39;show tables&＃39;
selectSql = &＃39;SELECT * FROM 07_jn_mysql_2&＃39;
result = ReadHiveTest(selectSql)
print(result[1])

以上就是Python如何连接和启动Hive的详细内容，更多请关注 第一PHP社区 其它相关文章！