Настройка жизненного цикла потока данных

Если в Elasticsearch включены функции безопасности, вам необходимо иметь привилегию manage_data_stream_lifecycle индекса или выше для использования данного API. Дополнительную информацию см. в разделе Права доступа к безопасности.

PUT _data_stream/<data-stream>/_lifecycle

Настраивает жизненный цикл потока данных для целевых потоков данных. Если предоставлено несколько потоков данных, но хотя бы один из них не существует, обновление жизненного цикла завершится неудачей для всех из них, и API вернёт ответ 404.

В следующем примере настраивается жизненный цикл my-data-stream:

resp = client.indices.put_data_lifecycle(
    name="my-data-stream",
    data_retention="7d",
)
print(resp)

response = client.indices.put_data_lifecycle(
  name: 'my-data-stream',
  body: {
    data_retention: '7d'
  }
)
puts response

const response = await client.indices.putDataLifecycle({
  name: "my-data-stream",
  data_retention: "7d",
});
console.log(response);

PUT _data_stream/my-data-stream/_lifecycle
{
  "data_retention": "7d"
}

При успешном обновлении жизненного цикла во всех потоках данных вы получите следующий результат:

{
  "acknowledged": true
}

В следующем примере настраиваются два раунда сжатия данных, первый из которых начинается через один день после перехода подлежащего индекса (или позже, если индекс всё ещё находится в пределах своих временных границ записи времени) с интервалом 10m, а второй — через 7 дней после перехода с интервалом 1d:

resp = client.indices.put_data_lifecycle(
    name="my-weather-sensor-data-stream",
    downsampling=[
        {
            "after": "1d",
            "fixed_interval": "10m"
        },
        {
            "after": "7d",
            "fixed_interval": "1d"
        }
    ],
)
print(resp)

response = client.indices.put_data_lifecycle(
  name: 'my-weather-sensor-data-stream',
  body: {
    downsampling: [
      {
        after: '1d',
        fixed_interval: '10m'
      },
      {
        after: '7d',
        fixed_interval: '1d'
      }
    ]
  }
)
puts response

const response = await client.indices.putDataLifecycle({
  name: "my-weather-sensor-data-stream",
  downsampling: [
    {
      after: "1d",
      fixed_interval: "10m",
    },
    {
      after: "7d",
      fixed_interval: "1d",
    },
  ],
});
console.log(response);

PUT _data_stream/my-weather-sensor-data-stream/_lifecycle
{
    "downsampling": [
      {
        "after": "1d",
        "fixed_interval": "10m"
      },
      {
        "after": "7d",
        "fixed_interval": "1d"
      }
    ]
}