Different ways to use ingest pipeline

Ingest Pipeline

#add the pipeline
PUT _ingest/pipeline/set_incremental
{
  "processors": [
    {
      "set": {
        "field": "incremental_value",
        "value": 0
      }
    }
  ]
}

#---------------------
#using while ingesting

#indexing a document
PUT users/_doc/1/?pipeline=set_incremental
{
  "email": "[email protected]",
  "user": "janedoe",
  "name": "jane"
}

#check if the pipeline was excuted
GET users/_doc/1

#indexing using bulk 
POST users/_doc/_bulk
{"index":{"_id":"2", "pipeline": "set_incremental"}}
{"email": "[email protected]", "user": "mackdoe", "name": "mack"}


#check if the pipeline was excuted
GET users/_doc/2

#or

POST users/_doc/_bulk?pipeline=set_incremental
{"index":{"_id":"3"}}
{"email": "[email protected]", "user": "johndoe", "name": "john"}

#check if the pipeline was excuted
GET users/_doc/3

#----------------------
#adding a new processor

PUT _ingest/pipeline/add_incremental
{
 "processors": [
      {
        "script": {
          "source": """
            ctx.incremental_value += 1;
          """
        }
      }
    ]
}

#---------------------
#using while updating
POST users/_update_by_query?pipeline=add_incremental

#check the value was added in all documents
GET users/_search

#---------------------
#using while reindex
POST _reindex
{
  "source": {
    "index": "users"
  },
  "dest": {
    "index": "new_users",
    "pipeline": "add_incremental"
  }
}

#check the value was added in all documents in the new index
GET new_users/_search