Elasticsearch nodejs проверяет, заполнена ли очередь

Question

У меня следующая ошибка сasticsearch

[remote_transport_exception] [es-0][x.x.x.x:9300][indices:data/write/bulk[s]]

Или

[remote_transport_exception] [es-0][x.x.x.x:9300][indices:data/write/bulk[s][p]]

Похоже, что очередь эластичного поиска заполнена

Я используюnodejs lib https://www.npmjs.com/package/elasticsearch, и эта ошибка произошла после вызова client.index.

Я использую индекс как обещание потребителю rabbitmq, сообщение не приходит больше 8 одновременно.

client.index().then(...)

Кажется, что then вызывается, когда обновление или создание все еще находятся в очереди, я попытался добавить {wait_for_active_shards: 'all'}, но у меня та же проблема.

Answer 1

Это была проблема, потому что серверasticsearch был слишком занят.

Я добавил систему повтора в случае 429 кода ошибки, теперь она работает нормально