Python通过pythony连接Hive执行Hql的脚本

代码如下

#!/usr/bin/env python
import sys
sys.path.append(‘/home/spark/opt/hive-1.2.1/lib/py‘)
from hive_service import ThriftHive
from hive_service.ttypes import HiveServerException
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
def hiveExe(sql):
   try:
       transport = TSocket.TSocket(‘127.0.0.1‘,10000) 
       transport = TTransport.TBufferedTransport(transport)
       protocol = TBinaryProtocol.TBinaryProtocol(transport)
       client = ThriftHive.Client(protocol)
       transport.open()
       client.execute(sql)
       print "The return value is : " 
       print client.fetchAll()
       print "............"
       transport.close()
   except Thrift.TException,tx:
       print ‘%s‘ % (tx.message)
if __name__ == ‘__main__‘:
   select_sql="select url_current from yemao1_log limit 100";
   hiveExe(select_sql)

https://www.jb51.cc/python/526858.html

Python通过pythony连接Hive执行Hql的脚本

原文：https://www.cnblogs.com/hellow-gu/p/15049908.html