API Rollover

При переролировании псевдонима индекса вы можете указать имя для нового индекса. Если вы не укажете имя, и текущий индекс заканчивается на - и число, например my-index-000001 или my-index-3, новое имя индекса увеличивает это число. Например, если вы переролируете псевдоним с текущим индексом my-index-000001, переролирование создаёт новый индекс с именем my-index-000002. Это число всегда имеет 6 символов и нулевую заправку, независимо от имени предыдущего индекса.

Переролирование создаёт новый индекс и подчиняется настройке wait_for_active_shards.

Следующий запрос безусловно переключает поток данных.

resp = client.indices.rollover(
    alias="my-data-stream",
)
print(resp)

response = client.indices.rollover(
  alias: 'my-data-stream'
)
puts response

const response = await client.indices.rollover({
  alias: "my-data-stream",
});
console.log(response);

POST my-data-stream/_rollover

Следующий запрос переключает поток данных лениво, что означает, что поток данных будет переключен при следующем событии индексации. Это гарантирует, что изменения в отображении и настройках будут применены к поступающим данным, но избежит создания дополнительных индексов для потоков данных с медленной обработкой.

resp = client.indices.rollover(
    alias="my-data-stream",
    lazy=True,
)
print(resp)

const response = await client.indices.rollover({
  alias: "my-data-stream",
  lazy: "true",
});
console.log(response);

POST my-data-stream/_rollover?lazy

Следующий запрос переключает поток данных только в том случае, если текущий индекс записи соответствует одному или нескольким из следующих условий:

resp = client.indices.rollover(
    alias="my-data-stream",
    conditions={
        "max_age": "7d",
        "max_docs": 1000,
        "max_primary_shard_size": "50gb",
        "max_primary_shard_docs": "2000"
    },
)
print(resp)

response = client.indices.rollover(
  alias: 'my-data-stream',
  body: {
    conditions: {
      max_age: '7d',
      max_docs: 1000,
      max_primary_shard_size: '50gb',
      max_primary_shard_docs: '2000'
    }
  }
)
puts response

const response = await client.indices.rollover({
  alias: "my-data-stream",
  conditions: {
    max_age: "7d",
    max_docs: 1000,
    max_primary_shard_size: "50gb",
    max_primary_shard_docs: "2000",
  },
});
console.log(response);

POST my-data-stream/_rollover
{
  "conditions": {
    "max_age": "7d",
    "max_docs": 1000,
    "max_primary_shard_size": "50gb",
    "max_primary_shard_docs": "2000"
  }
}

API возвращает:

{
  "acknowledged": true,
  "shards_acknowledged": true,
  "old_index": ".ds-my-data-stream-2099.05.06-000001",
  "new_index": ".ds-my-data-stream-2099.05.07-000002",
  "rolled_over": true,
  "dry_run": false,
  "lazy": false,
  "conditions": {
    "[max_age: 7d]": false,
    "[max_docs: 1000]": true,
    "[max_primary_shard_size: 50gb]": false,
    "[max_primary_shard_docs: 2000]": false
  }
}

Следующий запрос создает <my-index-{now/d}-000001> и устанавливает его в качестве индекса записи для my-alias.

resp = client.indices.create(
    index="<my-index-{now/d}-000001>",
    aliases={
        "my-alias": {
            "is_write_index": True
        }
    },
)
print(resp)

response = client.indices.create(
  index: '<my-index-{now/d}-000001>',
  body: {
    aliases: {
      "my-alias": {
        is_write_index: true
      }
    }
  }
)
puts response

const response = await client.indices.create({
  index: "<my-index-{now/d}-000001>",
  aliases: {
    "my-alias": {
      is_write_index: true,
    },
  },
});
console.log(response);

# PUT <my-index-{now/d}-000001>
PUT %3Cmy-index-%7Bnow%2Fd%7D-000001%3E
{
  "aliases": {
    "my-alias": {
      "is_write_index": true
    }
  }
}

Следующий запрос переключает алиас только в том случае, если текущий индекс записи соответствует одному или нескольким из следующих условий:

resp = client.indices.rollover(
    alias="my-alias",
    conditions={
        "max_age": "7d",
        "max_docs": 1000,
        "max_primary_shard_size": "50gb",
        "max_primary_shard_docs": "2000"
    },
)
print(resp)

response = client.indices.rollover(
  alias: 'my-alias',
  body: {
    conditions: {
      max_age: '7d',
      max_docs: 1000,
      max_primary_shard_size: '50gb',
      max_primary_shard_docs: '2000'
    }
  }
)
puts response

const response = await client.indices.rollover({
  alias: "my-alias",
  conditions: {
    max_age: "7d",
    max_docs: 1000,
    max_primary_shard_size: "50gb",
    max_primary_shard_docs: "2000",
  },
});
console.log(response);

POST my-alias/_rollover
{
  "conditions": {
    "max_age": "7d",
    "max_docs": 1000,
    "max_primary_shard_size": "50gb",
    "max_primary_shard_docs": "2000"
  }
}

API возвращает:

{
  "acknowledged": true,
  "shards_acknowledged": true,
  "old_index": "my-index-2099.05.06-000001",
  "new_index": "my-index-2099.05.07-000002",
  "rolled_over": true,
  "dry_run": false,
  "lazy": false,
  "conditions": {
    "[max_age: 7d]": false,
    "[max_docs: 1000]": true,
    "[max_primary_shard_size: 50gb]": false,
    "[max_primary_shard_docs: 2000]": false
  }
}

Если имена индексов алиаса используют дату и вы переключаете индексы с регулярным интервалом, вы можете использовать дату для сужения поиска. Например, следующий запрос нацелен на индексы, созданные в последние три дня.

resp = client.search(
    index="<my-index-{now/d}-*>,<my-index-{now/d-1d}-*>,<my-index-{now/d-2d}-*>",
)
print(resp)

response = client.search(
  index: '<my-index-{now/d}-*>,<my-index-{now/d-1d}-*>,<my-index-{now/d-2d}-*>'
)
puts response

const response = await client.search({
  index: "<my-index-{now/d}-*>,<my-index-{now/d-1d}-*>,<my-index-{now/d-2d}-*>",
});
console.log(response);

# GET /<my-index-{now/d}-*>,<my-index-{now/d-1d}-*>,<my-index-{now/d-2d}-*>/_search
GET /%3Cmy-index-%7Bnow%2Fd%7D-*%3E%2C%3Cmy-index-%7Bnow%2Fd-1d%7D-*%3E%2C%3Cmy-index-%7Bnow%2Fd-2d%7D-*%3E/_search

Следующий запрос создаёт <my-index-{now/d}-000001> и его алиас, my-write-alias.

resp = client.indices.create(
    index="<my-index-{now/d}-000001>",
    aliases={
        "my-write-alias": {}
    },
)
print(resp)

response = client.indices.create(
  index: '<my-index-{now/d}-000001>',
  body: {
    aliases: {
      "my-write-alias": {}
    }
  }
)
puts response

const response = await client.indices.create({
  index: "<my-index-{now/d}-000001>",
  aliases: {
    "my-write-alias": {},
  },
});
console.log(response);

# PUT <my-index-{now/d}-000001>
PUT %3Cmy-index-%7Bnow%2Fd%7D-000001%3E
{
  "aliases": {
    "my-write-alias": { }
  }
}

Следующий запрос переключает алиас только в том случае, если текущий индекс соответствует одному или нескольким из следующих условий:

resp = client.indices.rollover(
    alias="my-write-alias",
    conditions={
        "max_age": "7d",
        "max_docs": 1000,
        "max_primary_shard_size": "50gb",
        "max_primary_shard_docs": "2000"
    },
)
print(resp)

response = client.indices.rollover(
  alias: 'my-write-alias',
  body: {
    conditions: {
      max_age: '7d',
      max_docs: 1000,
      max_primary_shard_size: '50gb',
      max_primary_shard_docs: '2000'
    }
  }
)
puts response

const response = await client.indices.rollover({
  alias: "my-write-alias",
  conditions: {
    max_age: "7d",
    max_docs: 1000,
    max_primary_shard_size: "50gb",
    max_primary_shard_docs: "2000",
  },
});
console.log(response);

POST my-write-alias/_rollover
{
  "conditions": {
    "max_age": "7d",
    "max_docs": 1000,
    "max_primary_shard_size": "50gb",
    "max_primary_shard_docs": "2000"
  }
}

API возвращает:

{
  "acknowledged": true,
  "shards_acknowledged": true,
  "old_index": "my-index-2099.05.06-000001",
  "new_index": "my-index-2099.05.07-000002",
  "rolled_over": true,
  "dry_run": false,
  "lazy": false,
  "conditions": {
    "[max_age: 7d]": false,
    "[max_docs: 1000]": true,
    "[max_primary_shard_size: 50gb]": false,
    "[max_primary_shard_docs: 2000]": false
  }
}

Обычно вы используете шаблон индекса, чтобы автоматически настроить индексы, созданные при переключении. Если вы переключаете алиас индекса, вы используете API переключения для добавления дополнительных настроек индекса или перезаписи настроек в шаблоне. Потоки данных не поддерживают параметр settings.

resp = client.indices.rollover(
    alias="my-alias",
    settings={
        "index.number_of_shards": 2
    },
)
print(resp)

response = client.indices.rollover(
  alias: 'my-alias',
  body: {
    settings: {
      'index.number_of_shards' => 2
    }
  }
)
puts response

const response = await client.indices.rollover({
  alias: "my-alias",
  settings: {
    "index.number_of_shards": 2,
  },
});
console.log(response);

POST my-alias/_rollover
{
  "settings": {
    "index.number_of_shards": 2
  }
}