Поле _routing

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

resp = client.search(
    index="my-index-000001",
    routing="user1,user2",
    query={
        "match": {
            "title": "document"
        }
    },
)
print(resp)

response = client.search(
  index: 'my-index-000001',
  routing: 'user1,user2',
  body: {
    query: {
      match: {
        title: 'document'
      }
    }
  }
)
puts response

const response = await client.search({
  index: "my-index-000001",
  routing: "user1,user2",
  query: {
    match: {
      title: "document",
    },
  },
});
console.log(response);

GET my-index-000001/_search?routing=user1,user2 
{
  "query": {
    "match": {
      "title": "document"
    }
  }
}

При использовании пользовательской маршрутизации важно предоставлять значение маршрутизации при индексировании, получении, удалении или обновлении документа.

Пропуск значения маршрутизации может привести к индексированию документа более чем в одном фрагменте. В качестве меры предосторожности поле _routing может быть настроено для того, чтобы значение пользовательской routing маршрутизации было обязательным для всех операций CRUD:

resp = client.indices.create(
    index="my-index-000002",
    mappings={
        "_routing": {
            "required": True
        }
    },
)
print(resp)

resp1 = client.index(
    index="my-index-000002",
    id="1",
    document={
        "text": "No routing value provided"
    },
)
print(resp1)

response = client.indices.create(
  index: 'my-index-000002',
  body: {
    mappings: {
      _routing: {
        required: true
      }
    }
  }
)
puts response

response = client.index(
  index: 'my-index-000002',
  id: 1,
  body: {
    text: 'No routing value provided'
  }
)
puts response

const response = await client.indices.create({
  index: "my-index-000002",
  mappings: {
    _routing: {
      required: true,
    },
  },
});
console.log(response);

const response1 = await client.index({
  index: "my-index-000002",
  id: 1,
  document: {
    text: "No routing value provided",
  },
});
console.log(response1);

PUT my-index-000002
{
  "mappings": {
    "_routing": {
      "required": true 
    }
  }
}

PUT my-index-000002/_doc/1 
{
  "text": "No routing value provided"
}

При индексировании документов, указывая пользовательскую _routing, уникальность _id не гарантируется во всех фрагментах индекса. Фактически, документы с одинаковым _id могут оказаться в разных фрагментах, если они были проиндексированы с различными значениями _routing.

Пользователь отвечает за обеспечение уникальности идентификаторов в индексе.

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

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

При наличии этого параметра формулы расчета фрагментов становятся:

routing_value = hash(_routing) + hash(_id) % routing_partition_size
shard_num = (routing_value % num_routing_shards) / routing_factor

То есть, поле _routing используется для расчета набора фрагментов в пределах индекса, а затем поле _id используется для выбора фрагмента в пределах этого набора.

Для активации этой функции значение index.routing_partition_size должно быть больше 1 и меньше index.number_of_shards.

После активации разбиения индекса будут следующие ограничения: