这是代码:
#!/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)
错误
Traceback(最后一次调用(:文件"/usr/local/py/test.py",第行8,在数据库中="默认"(作为conn:File"/usr/lib/python2.6/site packages/pyhs2/init.py",第7行,位于连接return Connection(*args,**kwargs(文件"/usr/lib/python2.6/site packages/pyhs2/connections.py",第46行,位于inittransport.open((文件"/usr/lib/python2.6/site packages/pyhs2/cloudera/fraft_sasl.py",第行55,打开自我_trans.open((文件"/usr/lib64/python2.6/site packages/srift/transport/TSocket.py",第行101,打开message=message(节俭.transport.transport.TTransportException:无法连接到localhost:10001
它通过启动hiveServer2服务并更改端口10000来解决。