DeleteByQueryElasticsearch 2.0.0

Bundle
org.apache.nifi | nifi-elasticsearch-restapi-nar
Description
Delete from an Elasticsearch index using a query. The query can be loaded from a flowfile body or from the Query parameter.
Tags
delete, elastic, elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, query
Input Requirement
ALLOWED
Supports Sensitive Dynamic Properties
false
  • Additional Details for DeleteByQueryElasticsearch 2.0.0

    DeleteByQueryElasticsearch

    This processor executes a delete operation against one or more indices using the _delete_by_query handler. The query should be a valid Elasticsearch JSON DSL query (Lucene syntax is not supported). An example query:

    {
  "query": {
    "match": {
      "username.keyword": "john.smith"
    }
  }
}

    To delete all the contents of an index, this could be used:

    {
  "query": {
    "match_all": {}
  }
}
Properties
Dynamic Properties
Relationships
Name Description
success If the "by query" operation succeeds, and a flowfile was read, it will be sent to this relationship.
failure If the "by query" operation fails, and a flowfile was read, it will be sent to this relationship.
retry All flowfiles that fail due to server/cluster availability go to this relationship.
Writes Attributes
Name Description
elasticsearch.delete.took The amount of time that it took to complete the delete operation in ms.
elasticsearch.delete.error The error message provided by Elasticsearch if there is an error running the delete.