Действие индексации 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": {} 
  }
}