python通过thrift方式连接hive问题

漫步夕阳 发布于 2013/02/28 17:25
阅读 3K+
收藏 0

根据某高手前辈的链接安装好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") 

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

请高手解救,谢谢!

加载中
0
漫步夕阳
补充一下,使用的是hive 0.8.1版本,thrift是0.9.0版本。
0
漫步夕阳
原来是hive server没启动。执行hive --service hiveserver就可以了
返回顶部
顶部