pyinstaller打包python源程序访问hive

首页 > 代码库 > pyinstaller打包python源程序访问hive

pyinstaller打包python源程序访问hive

2024-07-05 19:38:29 227人阅读

1.需求

　　使用hvie server一段时间后，业务部门需要自己不定时的查询业务数据，之前这一块都是他们提需求我们来做，后来发现这样重复一样的工作放在我们这边做是在没有效率，遂提出给他们工具或者web UI自助查询，当然hive有自己的hwi可以通过网页UI进行自助查询，但是这对不懂sql的业务人员有点不太友好，目前有没时间去修改hwi的UI，所以还是给他们提供查询工具吧。我这边主要使用python thrift访问集群的hive，所以自然要将python源码打包成.exe，业务人员在windows环境下双击该应用程序，输入参数回车后即可查询hive数据。

2.python thrift访问hive示例代码如下(connectHive.py)：

#-*-encoding: utf-8-*-
‘‘‘
Created on 2014年2月19日

@author: jxw
‘‘‘

import sys
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(‘192.168.243.128‘, 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()
        for r in client.fetchAll():
            #for w in r.strip().split(‘\t‘):
                #print w
            print r
        print "............"
        transport.close()
    except Thrift.TException, tx:
        print ‘%s‘ % (tx.message)

if __name__ == ‘__main__‘:
    num = int(raw_input("input top N:"))
    #print num
    sql_ctx = "select * from game_log.tab_char_create limit %d" %num
    #print sql_ctx
    hiveExe(sql_ctx)
    s = raw_input("Enter any key to exit.")
    print s