利用python将hive查询结果保存到mysql代码,Python代码库,德仔网

代码语言

代码分类

【Python】利用python将hive查询结果保存到mysql

作者: / 发布于2017/3/23/ 909

Python脚本连接Hive获取返回值代码

#!/usr/bin/env python

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

try:
    transport = TSocket.TSocket('localhost', 10000)
    transport = TTransport.TBufferedTransport(transport)
    protocol = TBinaryProtocol.TBinaryProtocol(transport)

    client = ThriftHive.Client(protocol)
    transport.open()

    client.execute('ADD jar /home/soft/<a href="http://lib.csdn.net/base/hadoop" class='replace_word' title="Hadoop知识库" target='_blank' style='color:#df3434; font-weight:bold;'>Hadoop</a>/hive-0.7.0/lib/hive-contrib-0.7.0.jar')
    query = '''
        select count(1) from apilog                                '''

    client.execute(query)
    row = client.fetchOne()
    print row

    transport.close()
except Thrift.TException, tx:
    print '%s' % (tx.message)

试试其它关键字

同语言下

可能有用的

贡献的其它代码Label