Сжатие

Разрешенные фазы: hot, warm.

Блокировка записи в исходном индексе и его сжатие в новый индекс с меньшим количеством первичных фрагментов. Имя получившегося индекса — shrink-<random-uuid>-<original-index-name>. Это действие соответствует API сжатия индекса.

После выполнения действия shrink, любые алиасы, указывающие на исходный индекс, будут указывать на новый сжатый индекс. Если ILM выполняет действие shrink над вспомогательным индексом для потока данных, то сжатый индекс заменит исходный индекс в потоке. Нельзя выполнить действие shrink над индексом записи.

Чтобы использовать действие shrink в фазе hot, действие rollover должно быть присутствовать. Если действие rollover не настроено, ILM отклонит политику.

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

resp = client.ilm.put_lifecycle(
    name="my_policy",
    policy={
        "phases": {
            "warm": {
                "actions": {
                    "shrink": {
                        "number_of_shards": 1
                    }
                }
            }
        }
    },
)
print(resp)

response = client.ilm.put_lifecycle(
  policy: 'my_policy',
  body: {
    policy: {
      phases: {
        warm: {
          actions: {
            shrink: {
              number_of_shards: 1
            }
          }
        }
      }
    }
  }
)
puts response

const response = await client.ilm.putLifecycle({
  name: "my_policy",
  policy: {
    phases: {
      warm: {
        actions: {
          shrink: {
            number_of_shards: 1,
          },
        },
      },
    },
  },
});
console.log(response);

PUT _ilm/policy/my_policy
{
  "policy": {
    "phases": {
      "warm": {
        "actions": {
          "shrink" : {
            "number_of_shards": 1
          }
        }
      }
    }
  }
}

resp = client.ilm.put_lifecycle(
    name="my_policy",
    policy={
        "phases": {
            "warm": {
                "actions": {
                    "shrink": {
                        "max_primary_shard_size": "50gb"
                    }
                }
            }
        }
    },
)
print(resp)

response = client.ilm.put_lifecycle(
  policy: 'my_policy',
  body: {
    policy: {
      phases: {
        warm: {
          actions: {
            shrink: {
              max_primary_shard_size: '50gb'
            }
          }
        }
      }
    }
  }
)
puts response

const response = await client.ilm.putLifecycle({
  name: "my_policy",
  policy: {
    phases: {
      warm: {
        actions: {
          shrink: {
            max_primary_shard_size: "50gb",
          },
        },
      },
    },
  },
});
console.log(response);

PUT _ilm/policy/my_policy
{
  "policy": {
    "phases": {
      "warm": {
        "actions": {
          "shrink" : {
            "max_primary_shard_size": "50gb"
          }
        }
      }
    }
  }
}