Logstash：如何将值从一个聚合筛选器任务ID传递到另一个

问题描述

我有一个需求，我需要将流数据从ID为different_%{customer}的一个集合过滤器流向另一个%{traceid}

logstash.conf代码段：

aggregate {
          task_id => "different_%{customer}"
          code => "
            event.set('it_works','phase execute remittance req body')
            event.set('transactionAmount',map['transactionAmount'])"
          map_action => "update"
          end_of_task => true
          timeout => 120
      }

      aggregate {
          task_id => "%{traceid}"
          code => "
            event.set('it_works','phase execute remittance another req body')
            map['id'] = event.get('id')
            map['transactionAmount'] = event.get('transactionAmount')"
          map_action => "update"
      }

甚至没有保存phase execute remittance req body。无法确定问题出在哪里。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）