def loadToHive(bakFilePath, tbName):

     try:

         transport = TSocket.TSocket(HIVE_SERVER, HIVE_PORT)

         transport = TTransport.TBufferedTransport(transport)

         protocol = TBinaryProtocol.TBinaryProtocol(transport)

         client = ThriftHive.Client(protocol)

         transport.open()

         client.execute("LOAD DATA LOCAL INPATH '" + bakFilePath + "' INTO TABLE " + tbName)

         print "LOAD DATA LOCAL INPATH '" + bakFilePath + "' INTO TABLE " + tbName

         transport.close()

     except Thrift.TException, tx:

         print '%s' % (tx.message)

 def test():

     try:

         bak = file( 'tmp.bak', 'w') #需要打开文件处理下

         ........ #处理文件

         loadToHive('tmp.bak', 'test') #load到test表

     except IOError as err:

         print('File Error: '+ str(err))

     finally:

         bak.close()