blog_es_pipeline_1_exception_handling_d

POST _ingest/pipeline/_simulate
{
  "pipeline": {
    "processors": [
      {
        "dissect": {
          "field": "message",
          "pattern": "%{name}:%{age}"
        }
      },
      {
        "pipeline": {
          "name": "func_convert_age",
          "on_failure": [
            {
              "set": {
                "field": "error",
                "value": "{{ _ingest.on_failure_processor_type }} - {{ _ingest.on_failure_message }}"
              }
            },
            {
              "remove": {
                "field": [ "name", "age" ]
              }
            }
          ]
        }
      }
    ]
  },
  "docs": [
    {
      "_source": {
        "message": "helen wong:45"
      }
    },
    {
      "_source": {
        "message": "josh blake:a46"
      }
    }
  ]
}