1.在使用Python连接hive之前，需要将hive安装包下的lib/py中的文件拷贝到python的sys.path中的site-packages下，否则引入对应的包会报错，这个是使用hive提供的Python接口来调用hive客户端。
2 启动hive 的thrift
确保以下服务开启：
hive –service hiveserver
默认端口是10000
from hive_service import ThriftHivefrom thrift import Thriftfrom thrift.transport import TSocketfrom thrift.transport import TTransportfrom thrift.protocol import TBinaryProtocoldef ReadHiveTest(sql):try:tSocket = TSocket.TSocket('172.18.1.88',10000)tTransport = TTransport.TBufferedTransport(tSocket)protocol = TBinaryProtocol.TBinaryProtocol(tTransport)client = ThriftHive.Client(protocol)tTransport.open()client.execute(sql)return client.fetchAll()except Thrift.TException, tx:print '%s' % (tx.message)finally:tTransport.close()if __name__ == '__main__':showDatabasesSql = 'show databases<strong style="color:transparent">本文来源gao@daima#com搞(%代@#码@网&</strong>'showTablesSql = 'show tables'selectSql = 'SELECT * FROM 07_jn_mysql_2'result = ReadHiveTest(selectSql)print(result[1])
以上就是Python如何连接和启动Hive的详细内容，更多请关注搞代码gaodaima其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：Python如何连接和启动Hive
转载请注明原文链接：Python如何连接和启动Hive
