有没大佬试过pipeline在reindex里用？

目前我们的数据里需要添加一些字段，但是原来的数据结构里面这些字段是缺失的，所以我准备通过pipeline的方式把这些默认值填上
 

{

  "mappings": {

    "_doc": {

      "properties": {

        "sentiment": {

          "type": "keyword"

        },

        "ingest_timestamp": {

            "format": "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis",

            "type": "date"

        },

        ……

      }

    }

  },

  "settings": {

    "number_of_replicas": 0,

    "number_of_shards": 9,

    "default_pipeline": "defaultSentimentConditionPipeline"

  }

}

然后通过一组的pipeline去设值

{

  "defaultSentimentConditionPipeline": {

    "description": "set default sentiment condition pipeline",

    "processors": [

      {

        "pipeline": {

          "if": "ctx.sentiment == '' || ctx.sentiment == null",

          "name": "defaultSentimentPipeline"

        }

      },

      {

        "pipeline": {

          "if": "ctx.ingest_timestamp == '' || ctx.ingest_timestamp == null",

          "name": "timestamp_pipeline"

        }

      }

    ]

  },

  "defaultSentimentPipeline": {

    "description": "set default sentiment",

    "processors": [

      {

        "set": {

          "field": "sentiment",

          "value": "sentiment"

        }

      }

    ]

  },

  "timestamp_pipeline": {

    "description": "Add insert timestamp",

    "processors": [

      {

        "set": {

          "field": "ingest_timestamp",

          "value": "{{_ingest.timestamp}}"

        }

      }

    ]

  }

}

但是貌似reindex进来的数据并没有带上时间戳和默认值，理论上reindex是es内部的scroll+bulkinsert，但是这个流程是不走pipeline的吗？