Elasticsearch ingest pipeline pushing data to another index

pipeline.json

GET _cat/indices


# Create a pipeline that pushes the data to "index2"
PUT _ingest/pipeline/test
{
  "description" : "Push data to index2",
  "processors": [
      {
        "script": {
          "source": """
          
          ctx._index = 'index2';
          ctx._type = '_doc';
          ctx.field_foo_times_bar = (ctx.foo * ctx.bar) 
          """
        }
      }
    ]
}


# Post to "index1" as normal and use the pipeline
PUT index1/_doc/1?pipeline=test
{
  "foo": 10,
  "bar": 10
}

# Default record in index1
GET index1/_doc/1

# Modified record in index2
GET index2/_doc/1


# Test a pipeline
POST _ingest/pipeline/_simulate
{
  "pipeline": {
    "description" : "Demo",
    "processors": [
      {
        "script": {
          "source": """
          ctx.field_foo_times_bar = (ctx.foo * ctx.bar) 
          """
        }
      }
    ]
  },
  "docs": [
    {
      "_source": {
        "foo": 10,
        "bar": 10
      }
    }
  ]
}