python写入hive,hive Python

　　用大蟒写艾滋病毒客户端-改善-伊泰耶技术网站

　　用大蟒写艾滋客户端

　　博客分类：Hadoop python SQL server Hadoop BBS

　　第一步：将配置单元-0.7.0\lib\py中所有巴拉圭文件拷贝到你自己的计算机编程语言工程中。

　　第二步：把下面的代码拷贝一份新建一个巴拉圭文件，修改IP，端口，输入要执行的SQL。

　　计算机编程语言代码# encoding=utf-8 from hive _ service hive _ service。ttypesimportiveserverexception fromthriffimportthrift fromthrift。transportimporttransportfromthrift。protocolimportbinaryprotocoldefhiveexe(SQL):try:transport=TSocket .TSocket(119.188.7.xx ，10000)transport=TTransport .TBufferedTransport(传输)协议=TBinaryProtocol .TBinaryProtocol(transport)client=thrift hive .客户端(协议)运输。打开()客户端。“执行(SQL)打印”返回值为：“打印客户端。“获取一张()打印件”..节俭除外TException，tx:打印 % s %(tx。消息)最后：运输。close()if _ _ name _ _= _ _ main _ _ :hiveExe( select count(*)from pokes )# encoding=utf-8

　　从hive_service导入节约蜂房

　　从hive_service.ttypes导入HiveServerException

　　从节俭进口节俭

　　从节俭。运输进口手提包

　　从节俭。运输进口运输

　　来自节俭协议导入协议

　　def hiveExe(sql):

　　尝试：

　　transport=TSocket .TSocket(119.188.7.xx ，10000)

　　transport=TTransport .TBufferedTransport(传输)

　　协议=TBinaryProtocol .运输协议

　　client=ThriftHive .客户端（协议)

　　transport.open()

　　客户端。执行(sql)

　　打印返回值是：

　　print client.fetchOne()

　　打印…………

　　除了节俭. tx异常，tx:

　　打印" % s"%(tx。消息)

　　最后：

　　transport.close()

　　if __name__==__main__ :

　　hiveExe( select count(*)from pokes )第三步：

　　hive - service hiveserver(启动配置单元服务器)

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。