API уменьшения индекса

POST /<index>/_shrink/<target-index>

PUT /<index>/_shrink/<target-index>

Для упрощения распределения фрагментов рекомендуется также удалить реплики фрагментов индекса. Позднее вы можете повторно добавить реплики фрагментов как часть операции сжатия.

Вы можете использовать следующий запрос API обновления настроек индекса, чтобы удалить реплики фрагментов индекса и переместить оставшиеся фрагменты индекса на тот же узел.

resp = client.indices.put_settings(
    index="my_source_index",
    settings={
        "settings": {
            "index.number_of_replicas": 0,
            "index.routing.allocation.require._name": "shrink_node_name"
        }
    },
)
print(resp)

response = client.indices.put_settings(
  index: 'my_source_index',
  body: {
    settings: {
      'index.number_of_replicas' => 0,
      'index.routing.allocation.require._name' => 'shrink_node_name'
    }
  }
)
puts response

const response = await client.indices.putSettings({
  index: "my_source_index",
  settings: {
    settings: {
      "index.number_of_replicas": 0,
      "index.routing.allocation.require._name": "shrink_node_name",
    },
  },
});
console.log(response);

PUT /my_source_index/_settings
{
  "settings": {
    "index.number_of_replicas": 0,                                
    "index.routing.allocation.require._name": "shrink_node_name"  
  }
}

Перемещение исходного индекса может занять некоторое время. Прогресс можно отслеживать с помощью API, или можно использовать API для ожидания, пока все фрагменты не будут перемещены с помощью параметра wait_for_no_relocating_shards.

Затем вы можете сделать индекс только для чтения с помощью следующего запроса с использованием API добавления блока индекса:

resp = client.indices.add_block(
    index="my_source_index",
    block="write",
)
print(resp)

response = client.indices.add_block(
  index: 'my_source_index',
  block: 'write'
)
puts response

const response = await client.indices.addBlock({
  index: "my_source_index",
  block: "write",
});
console.log(response);

PUT /my_source_index/_block/write

API сжатия индексов позволяет сжать существующий индекс в новый индекс с меньшим количеством первичных фрагментов. Запрашиваемое количество первичных фрагментов в целевом индексе должно быть делителем количества фрагментов в исходном индексе. Например, индекс с 8 первичными фрагментами может быть сжат в 4, 2 или 1 первичных фрагментов, или индекс с 15 первичными фрагментами может быть сжат в 5, 3 или 1. Если количество фрагментов в индексе является простым числом, его можно сжать только в один первичный фрагмент. Перед сжатием (первичная или реплицирующая) копия каждого фрагмента индекса должна быть присутствовать на одном узле.

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

resp = client.indices.shrink(
    index="my_source_index",
    target="my_target_index",
    settings={
        "index.routing.allocation.require._name": None,
        "index.blocks.write": None
    },
)
print(resp)

response = client.indices.shrink(
  index: 'my_source_index',
  target: 'my_target_index',
  body: {
    settings: {
      'index.routing.allocation.require._name' => nil,
      'index.blocks.write' => nil
    }
  }
)
puts response

const response = await client.indices.shrink({
  index: "my_source_index",
  target: "my_target_index",
  settings: {
    "index.routing.allocation.require._name": null,
    "index.blocks.write": null,
  },
});
console.log(response);

POST /my_source_index/_shrink/my_target_index
{
  "settings": {
    "index.routing.allocation.require._name": null, 
    "index.blocks.write": null 
  }
}

resp = client.indices.shrink(
    index="my_source_index",
    target="my_target_index",
    settings={
        "index.number_of_replicas": 1,
        "index.number_of_shards": 1,
        "index.codec": "best_compression"
    },
    aliases={
        "my_search_indices": {}
    },
)
print(resp)

response = client.indices.shrink(
  index: 'my_source_index',
  target: 'my_target_index',
  body: {
    settings: {
      'index.number_of_replicas' => 1,
      'index.number_of_shards' => 1,
      'index.codec' => 'best_compression'
    },
    aliases: {
      my_search_indices: {}
    }
  }
)
puts response

const response = await client.indices.shrink({
  index: "my_source_index",
  target: "my_target_index",
  settings: {
    "index.number_of_replicas": 1,
    "index.number_of_shards": 1,
    "index.codec": "best_compression",
  },
  aliases: {
    my_search_indices: {},
  },
});
console.log(response);

POST /my_source_index/_shrink/my_target_index
{
  "settings": {
    "index.number_of_replicas": 1,
    "index.number_of_shards": 1, 
    "index.codec": "best_compression" 
  },
  "aliases": {
    "my_search_indices": {}
  }
}