diff options
| author | wangkuan <[email protected]> | 2024-09-10 17:14:50 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2024-09-10 17:14:50 +0800 |
| commit | daf6ee08400b1102bb7e97af2c5663fc5cee24b4 (patch) | |
| tree | 0db262096e7f5f5681489ee406adb9a240dca071 /config | |
| parent | e4047ae73ed837fcc931fd2dee45c7fca9741df4 (diff) | |
[feature][bootstrap][common]node新增tags属性用于分流，需要与downstream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
Diffstat (limited to 'config')
| -rw-r--r-- | config/grootstream_job_example.yaml | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/config/grootstream_job_example.yaml b/config/grootstream_job_example.yaml index 37ef114..8f27609 100644 --- a/config/grootstream_job_example.yaml +++ b/config/grootstream_job_example.yaml @@ -15,9 +15,9 @@ splits: decoded_as_split: type: split rules: - - name: projection_processor + - tag: http_tag expression: event.decoded_as == 'HTTP' - - name: aggregate_processor + - tag: dns_tag expression: event.decoded_as == 'DNS' processing_pipelines: projection_processor: @@ -80,7 +80,8 @@ application: - name: inline_source downstream: [decoded_as_split] - name: decoded_as_split - downstream: [ projection_processor ,aggregate_processor] + tags: [http_tag, dns_tag] + downstream: [ projection_processor, aggregate_processor] - name: projection_processor downstream: [ print_sink ] - name: aggregate_processor |