我正在使用来自 Javascript (NodeJS) 客户端的 Elastic Search 的 Bulk API 为一堆文档编制索引。每次通话我都会发送一千个文档。该实例处理它,直到它达到 100 次调用(大约 100K 文档)。然后它返回一个 服务不可用 (503) 错误。
在打一个新电话之前,我会等待上一个电话完成并额外等待一秒钟。
搜索这个问题,我发现了一篇关于 Rails 修复的帖子:https://medium.com/@thetron/dealing-with-503-errors-when-testing-elasticsearch-integration-in-rails-ec7a5f828274 .作者使用以下代码使错误消失:
before do
repository.create_index!
repository.client.cluster.health wait_for_status: ‘yellow’
end
基于此,我写了以下内容:
const body = [
// 1K actions/docs
];
elastic.cluster.health({
waitForStatus: 'yellow',
timeout: '60s', // I also tried using the default timeout
requestTimeout: 60000
}, function (error, response) {
if (!!error) {
console.error(error);
return;
}
elastic.bulk({
body: body
}, function (error, response) {
if (!!error) {
console.error(error);
return;
}
console.log('Success!');
});
});
不确定它是否有任何区别,但该实例正在 AWS 上运行。由于文档数量众多,也许扩大实例是一种解决方案。但我想在这样做之前弄清楚如何处理这个错误。即使我必须让我的代码变慢一些。
最佳答案
您最好的选择是按照您所说的那样扩展您的集群,但您的加载过程也应该能够处理故障。
话虽如此,以下是 Elasticsearch 集群状态:
所以在你上面的例子中,你不想等待
yellow
, 你要等green
.
关于node.js - 如何在发送命令之前确保 Elastic Search 是健康的?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39167870/