IMPORTANT: No additional bug fixes or documentation updates will be released for this version. For the latest information, see the current release documentation.

« Watcher webhook action Watcher logging Action »

› › ›

Watcher index action

edit

Watcher index action

edit

Use the index action to index data into Elasticsearch. See Index action attributes for the supported attributes.

Configuring index actions

edit

The following snippet shows a simple index action definition:

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

	The id of the action
	An optional condition to restrict action execution
	An optional transform to transform the payload and prepare the data that should be indexed
	The index, alias, or data stream to which the data will be written
	An optional `_id` for the document

Index action attributes

edit

Name	Required	Default	Description
`index`	yes^*	-	The index, alias, or data stream to index into. ^*If you dynamically set an `_index` value, this parameter isn’t required. See Multi-document support.
`doc_id`	no	-	The optional `_id` of the document.
`op_type`	no	`index`	The op_type for the index operation. Must be one of either `index` or `create`. Must be `create` if `index` is a data stream.
`execution_time_field`	no	-	The field that will store/index the watch execution time.
`timeout`	no	60s	The timeout for waiting for the index api call to return. If no response is returned within this time, the index action times out and fails. This setting overrides the default timeouts.
`refresh`	no	-	Optional setting of the refresh policy for the write request

Multi-document support

edit

Like with all other actions, you can use a transform to replace the current execution context payload with another and by that change the document that will end up indexed.

The index action plays well with transforms with its support for the special _doc payload field.

When resolving the document to be indexed, the index action first looks up for a _doc field in the payload. When not found, the payload is indexed as a single document.

When a _doc field exists, if the field holds an object, it is extracted and indexed as a single document. If the field holds an array of objects, each object is treated as a document and the index action indexes all of them in a bulk.

An _index, or _id value can be added per document to dynamically set the index and ID of the indexed document.

The following snippet shows a multi-document index action definition:

"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": {} 
  }
}

	The document’s index
	An optional `_id` for the document
	A new `severity` field derived from the original document
	The payload `_doc` field which is an array of documents
	Since the `_index` was informed per document this should be empty

« Watcher webhook action Watcher logging Action »