【发布时间】:2021-02-07 13:22:59
【问题描述】:
我正在将数千个 URL 发布到我在 RabbitMQ 中的队列中,以供分析。使用后,结果将存储在 ElasticSearch 中。
由于某些原因,当队列变得太长时,我会收到 ElasticSearch 错误。
如果我将ConsumeChannel.prefetch 增加到 1 以上,我也会遇到同样的问题。
我正在通过 docker-compose 运行不同的服务。
Elasticsearch ERROR: 2021-02-07T13:05:30Z
Error: Request error, retrying
POST http://localhost:9200/test_20210207/_doc => connect ECONNREFUSED 127.0.0.1:9200
at Log.error
【问题讨论】:
-
rabbitmq 队列变大是因为您与 elasticsearch 的连接问题。检查弹性搜索日志。
标签: node.js elasticsearch docker-compose rabbitmq