我实际上是在尝试开发一个简单的 Node.js 客户端,它可以用来在 Cosmos 表上查询我的 Hive 表。
我首先尝试使用 Node.js 将此实现用于 Hive: https://github.com/wdavidw/node-thrift-hive .我的代码如下:
var router = express.Router();
var request = require('request');
var _ = require('lodash');
var hive = require('thrift-hive');
// Client connection
var client = hive.createClient({
version: '0.7.1-cdh3u3',
server: '130.206.80.46',
port: 10000,
timeout: 1000
});
// Execute call
router.route('/')
.get(function(req, res, next) {
client.execute('use default', function(err) {
// Query call
client.query('select * from interserre')
.on('row', function(database) {
console.log(database);
})
.on('error', function(err) {
console.log(err.message);
client.end();
})
.on('end', function() {
client.end();
});
});
})
module.exports = router;
我收到这个错误:
events.js:85
throw er; // Unhandled 'error' event
^
Error: connect ECONNREFUSED
at exports._errnoException (util.js:746:11)
at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1010:19)
之后我尝试使用 Python 示例(由文档提供,只是为了运行一个简单的测试。
我什至无法连接到服务器。
Could not connect to 130.206.80.46:10000
我认为问题在于我们没有提供任何允许我们连接到 Cosmos 门户的信息。使用 Thrift 无法放置您的凭据。服务器无法识别您是真正的 Cosmos 用户并拒绝您的连接。
Python 只是一个测试。我实际上正在做一个 Hackaton,并计划使用 Node.js 来查询我拥有的数据。您认为问题出在哪里?模块? Cosmos 门户?
最佳答案
我们目前正在向 Cygnus 添加一套 Hive 客户端示例,用于使用 Java、Python 和 Node.js 编写的 HiveServer1 和 HiveServe2。这是 Cygnus 0.9.0 中出现的东西,同时您可以在 develop
branch 中检查工作的当前状态(Java 和 Python 的客户端)。 .
关于 Node.js,有一些库允许以非身份验证的方式连接到 HiveServer1(node-thrift-hive
,node-hive
)(从技术上讲,它们仅适用于 Hive 服务器的 NOSASL 配置)。关于 HiveServer2,发生与 jsh2
等库相同的情况.
关于python - 无法连接到 Cosmos 以使用 Python 或 Node.js 客户端查询 Hive,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30329064/