API слияния

Вызовы этого API блокируются до завершения слияния (если запрос не содержит wait_for_completion=false, по умолчанию true). Если соединение клиента разорвано до завершения, процесс принудительного слияния будет продолжен в фоновом режиме. Любые новые запросы на принудительное слияние тех же индексов также будут заблокированы до завершения текущего слияния.

Если запрос содержит wait_for_completion=false, Elasticsearch выполняет некоторые предварительные проверки, запускает запрос и возвращает task, который можно использовать для получения статуса задачи. Однако вы не можете отменить эту задачу, так как задача принудительного слияния не отменяется. Elasticsearch создаёт запись этой задачи как документ в _tasks/<task_id>. Когда вы закончите с задачей, вам следует удалить документ задачи, чтобы Elasticsearch мог вернуть занимаемое им место.

Вы можете принудительно слить несколько индексов с помощью одного запроса, указав:

Каждый целевой фрагмент принудительно сливается отдельно с помощью force_merge пула потоков. По умолчанию на каждом узле имеется только один force_merge поток, что означает, что фрагменты на этом узле принудительно сливаются по одному за раз. Если вы расширите force_merge пул потоков на узле, он будет принудительно сливать свои фрагменты параллельно.

Принудительное слияние временно увеличивает хранилище для фрагмента, который сливается, так как может потребоваться свободное место до трёх его размеров в случае, если max_num_segments параметр установлен на 1, чтобы переписать все сегменты в новый.

Принудительное слияние полезно для управления старыми вспомогательными индексами потока данных и другими индексами, основанными на времени, особенно после перенаправления. В этих случаях каждый индекс получает трафик индексирования только в течение определенного периода времени. Как только индекс больше не получает записей, его фрагменты можно принудительно объединить в один сегмент.

resp = client.indices.forcemerge(
    index=".ds-my-data-stream-2099.03.07-000001",
    max_num_segments="1",
)
print(resp)

response = client.indices.forcemerge(
  index: '.ds-my-data-stream-2099.03.07-000001',
  max_num_segments: 1
)
puts response

const response = await client.indices.forcemerge({
  index: ".ds-my-data-stream-2099.03.07-000001",
  max_num_segments: 1,
});
console.log(response);

POST /.ds-my-data-stream-2099.03.07-000001/_forcemerge?max_num_segments=1

Это может быть хорошей идеей, так как фрагменты с одним сегментом иногда могут использовать более простые и эффективные структуры данных для выполнения поисков.