Процессор перенаправления

Процессор reroute позволяет перенаправить документ в другой целевой индекс или потоковый набор данных. Он имеет два основных режима:

При установке опции destination, целевой объект явно задан, и опции dataset и namespace не могут быть установлены.

Если опция destination не установлена, этот процессор работает в режиме потокового набора данных. Обратите внимание, что в этом режиме процессор reroute может использоваться только с потоковыми наборами данных, следующими схеме именования потоковых наборов данных схемы именования потоковых наборов данных. Попытка использовать этот процессор с потоковым набором данных с несоответствующим именем приведет к возникновению исключения.

Имя потокового набора данных состоит из трёх частей: <type>-<dataset>-<namespace>. Более подробную информацию см. в документации по схеме именования потоковых наборов данных.

Этот процессор может использовать как статические значения, так и ссылки на поля из документа для определения компонентов dataset и namespace нового целевого объекта. Более подробную информацию см. в таблице 39 «Опции перенаправления».

После выполнения процессора reroute все остальные процессоры текущего конвейера пропускаются, включая конечный конвейер. Если текущий конвейер выполняется в контексте конвейера, вызываемый конвейер также будет пропущен. Это означает, что в конвейере может быть выполнен не более одного процессора reroute, что позволяет определить взаимоисключающие условия перенаправления, аналогично условию if, else-if, else-if, ….

Процессор перенаправления гарантирует, что поля data_stream.<type|dataset|namespace> устанавливаются в соответствии с новым целевым объектом. Если документ содержит значение event.dataset, оно будет обновлено, чтобы отразить то же значение, что и data_stream.dataset.

Обратите внимание, что клиент должен иметь разрешения на доступ к окончательному целевому объекту. В противном случае документ будет отклонен с исключением безопасности, которое выглядит так:

{"type":"security_exception","reason":"action [indices:admin/auto_create] is unauthorized for API key id [8-dt9H8BqGblnY2uSI--] of user [elastic/fleet-server] on indices [logs-foo-default], this action is granted by the index privileges [auto_configure,create_index,manage,all]"}

Опция if может быть использована для определения условия, при котором документ должен быть перенаправлен на новый целевой объект.

{
  "reroute": {
    "tag": "nginx",
    "if" : "ctx?.log?.file?.path?.contains('nginx')",
    "dataset": "nginx"
  }
}

Опции dataset и namespace могут содержать либо одно значение, либо список значений, используемых в качестве резервных вариантов. Если ссылка на поле приводит к значению null, поле отсутствует в документе, используется следующее значение или ссылка на поле. Если ссылка на поле приводит к значению, которое не является String, процессор завершается с ошибкой.

В следующем примере процессор сначала попытается разрешить значение для поля service.name, чтобы определить значение для dataset. Если это поле разрешается в null, отсутствует или не является строкой, используется следующий элемент в списке. В этом случае это статическое значение ""generic". Опция namespace настроена только на одно статическое значение.

{
  "reroute": {
    "dataset": [
        "{{service.name}}",
        "generic"
    ],
    "namespace": "default"
  }
}