Действие индексирования Watcher

Следующий фрагмент демонстрирует простое определение действия index:

"actions" : {
  "index_payload" : { 
    "condition": { ... }, 
    "transform": { ... }, 
    "index" : {
      "index" : "my-index-000001", 
      "doc_id": "my-id" 
    }
  }
}

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

Действие индексирования хорошо работает с преобразованиями благодаря поддержке специального поля полезной нагрузки _doc.

При определении документа для индексирования действие индексирования сначала ищет поле _doc в полезной нагрузке. При отсутствии поля полезная нагрузка индексируется как один документ.

Когда поле _doc существует, если поле содержит объект, оно извлекается и индексируется как один документ. Если поле содержит массив объектов, каждый объект обрабатывается как документ, и действие индексирования индексирует все из них в массив.

Значение _index или _id может быть добавлено к каждому документу для динамического задания индекса и идентификатора индексируемого документа.

Следующий фрагмент демонстрирует определение действия index для нескольких документов:

"actions": {
  "index_payload": {
    "transform": {
      "script": """
      def documents = ctx.payload.hits.hits.stream()
        .map(hit -> [
          "_index": "my-index-000001", 
          "_id": hit._id, 
          "severity": "Sev: " + hit._source.severity 
        ])
        .collect(Collectors.toList());
      return [ "_doc" : documents]; 
      """
    },
    "index": {} 
  }
}