Справочник по обработчикам ingest

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

Каждый последующий процессор зависит от выходных данных предыдущего процессора, поэтому порядок процессоров важен. Измененные документы индексируются в Elasticsearch после применения всех процессоров.

Elasticsearch включает более 40 настраиваемых процессоров. Подстраницы в этом разделе содержат справочную документацию для каждого процессора. Чтобы получить список доступных процессоров, используйте API информации о узлах.

resp = client.nodes.info(
    node_id="ingest",
    filter_path="nodes.*.ingest.processors",
)
print(resp)

response = client.nodes.info(
  node_id: 'ingest',
  filter_path: 'nodes.*.ingest.processors'
)
puts response

const response = await client.nodes.info({
  node_id: "ingest",
  filter_path: "nodes.*.ingest.processors",
});
console.log(response);

GET _nodes/ingest?filter_path=nodes.*.ingest.processors

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

Вы можете установить дополнительные обработчики в качестве плагинов.

Вы должны установить все плагин-обработчики на всех узлах кластера. В противном случае Elasticsearch не сможет создать конвейеры, содержащие обработчик.

Чтобы отметить плагин как обязательный, установите plugin.mandatory в elasticsearch.yml. Узел не сможет запуститься, если обязательный плагин не установлен.

plugin.mandatory: my-ingest-plugin