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

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.

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