Logstash: How to pass value from one Aggregate Filter Task ID to another

Elastic Stack Logstash
1

I have a requirement in which I need flow data from one aggreage filter of id different_%{customer} to another %{traceid}

logstash.conf code snippet:

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"
      }

Even phase execute remittance req body is not saved. Unable to identify where it is going wrong.

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.