配置单元 - python连接错误 [英] Hive - python connection error

问题描述

这是代码：
$ b

 ＃！/ usr / bin / env python 
 import pyhs2 
 try：
 with pyhs2.connect（host ='localhost'，$ b $ port = 10001，
 authMechanism =PLAIN，
 user ='root '，
 password ='test'，
 database ='test'）as conn：
 with conn.cursor（）as cur：
 #Show databases 
 print cur.getDatabases（）
 
 #Execute查询
 cur.execute（select * from raw_stats）
 
＃返回查询中的列信息
 print cur.getSchema（）
 
 #Fetch表结果
用于我在cur.fetch（）中：
 print i 
 
除了Thrift.TException，tx ：
 print'％s'％（tx.message）
  

错误！ b
$ b

追溯（最近一次调用最后）：文件/usr/local/py/test.py，行
8，在database ='default'）中conn：File
/usr/lib/python2.6/site-packages/pyhs2/init.py，第7行，在
connect
return连接（* args，** kwargs）文件/usr/lib/python2.6/site-packages/pyhs2/connections.py，第46行，在
init中
transport.open（）文件/usr/lib/python2.6/site-packages/pyhs2/cloudera/thrift_sasl.py，行
55，打开
self._trans.open（）File /usr/lib64/python2.6/site-packages/thrift/transport/TSocket.py，行
101，打开
message = message）thrift.transport.TTransport.TTransportException：Could not连接到localhost：10001

解决方案

它通过启动hiveServer2服务并更改端口10000解决。

Here is code :

#!/usr/bin/env python
import pyhs2
try:
with pyhs2.connect(host='localhost',
           port=10001,
           authMechanism="PLAIN",
           user='root',
           password='test',
           database='test') as conn:
    with conn.cursor() as cur:
        #Show databases
        print cur.getDatabases()

        #Execute query
        cur.execute("select * from raw_stats")

        #Return column info from query
        print cur.getSchema()

        #Fetch table results
        for i in cur.fetch():
            print i

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

Error!

Traceback (most recent call last): File "/usr/local/py/test.py", line 8, in database='default') as conn: File "/usr/lib/python2.6/site-packages/pyhs2/init.py", line 7, in connect return Connection(*args, **kwargs) File "/usr/lib/python2.6/site-packages/pyhs2/connections.py", line 46, in init transport.open() File "/usr/lib/python2.6/site-packages/pyhs2/cloudera/thrift_sasl.py", line 55, in open self._trans.open() File "/usr/lib64/python2.6/site-packages/thrift/transport/TSocket.py", line 101, in open message=message) thrift.transport.TTransport.TTransportException: Could not connect to localhost:10001

解决方案

It resolved by starting hiveServer2 service and changing the port 10000.

这篇关于配置单元 - python连接错误的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！