python通过thrift方式连接hive问题

Question

根据某高手前辈的链接安装好thrift和相亲包，执行如下测试脚本出现无法连接的情况。

1. #!/usr/bin/env python  
2. import sys  
3. from hive_service import ThriftHive  
4. from hive_service.ttypes import HiveServerException  
5. from thrift import Thrift  
6. from thrift.transport import TSocket  
7. from thrift.transport import TTransport  
8. from thrift.protocol import TBinaryProtocol  
9.   
10. def hiveExe(sql):  
11.   
12.     try:  
13.         transport = TSocket.TSocket('127.0.0.1', 10000)   
14.         transport = TTransport.TBufferedTransport(transport)  
15.         protocol = TBinaryProtocol.TBinaryProtocol(transport)  
16.         client = ThriftHive.Client(protocol)  
17.         transport.open()  
18.   
19.   
20.         client.execute(sql)  
21.   
22.         print "The return value is : "   
23.         print client.fetchAll()  
24.         print "............"  
25.         transport.close()  
26.     except Thrift.TException, tx:  
27.         print '%s' % (tx.message)  
28.   
29. if __name__ == '__main__':  
30.     hiveExe("select * from t_afan_test") 
31. 
    

错误提示：Could not connect to 127.0.0.1:10000

请高手解救，谢谢！

Answer 1

原来是hive server没启动。执行hive --service hiveserver就可以了

Answer 2

补充一下，使用的是hive 0.8.1版本，thrift是0.9.0版本。