logstash到ES的数据更新问题

    问题类似这个https://stackoverflow.com/ques ... q%3D1
    我现有两个数据表。表A有三个字段(aid, aname, fid)，其中aid为主键，fid为外键，fid关联表B的主键；表B有三个字段(fid, fname, fage)。我要在ES中实现A、B表数据的综合查询，因此我建立了如下两个索引

PUT index_a

{

   "mappings": {

      "doc" : {

         "properties": {

            "aid" : { "type" : "keyword" },

            "aname" : { "type" : "keyword" },

            "fid" : { "type" : "keyword" },

            "fname" : { "type" : "keyword" },

            "fage" : { "type" : "integer"}

         }

      }

   }

}



PUT index_b

{

   "mappings": {

      "doc" : {

         "properties": {

            "fid" : { "type" : "keyword" },

            "fname" : { "type" : "keyword" },

            "fage" : { "type" : "integer"}

         }

      }

   }

}

    index_a中包含了A、B表的数据，index_b中包含了B表的数据，我现在想要通过logstash实现mysql的A、B表的数据同步更新到这两个索引，其中index_b的更新较为简单。但是当B表数据发生变化时不仅要更新index_b，还要更新index_a，比如fid为1的数据中fname发生改变，那么要更新index_a中所有的fid为1的文档的fname，请问这个功能怎么在logstash中实现，即一次性更新多条文档，并且只更新fname