select_entries
`select_entries` 处理器从 OpenSearch Data Prepper 事件中选择条目。只有选定的条目保留在已处理的事件中,而所有其他条目都将被删除。但是,此处理器不会从 Data Prepper 管道中删除任何事件。
配置
您可以使用以下选项配置 `select_entries` 处理器。
选项 | 必需 | 描述 |
---|---|---|
include_keys(包含的键) | 是 | 要从事件中选择的键列表。 |
select_when | 否 | 一个 条件表达式,例如 `/some-key == "test"'`,用于评估处理器是否将在事件上运行。如果条件不满足,事件将未经修改地继续通过管道,并保留所有原始字段。 |
用法
以下示例展示了如何在 `pipeline.yaml` 文件中配置 `select_entries` 处理器
pipeline:
source:
...
....
processor:
- select_entries:
include_keys: [ "key1", "key2" ]
select_when: '/some_key == "test"'
sink:
例如,当您的源包含以下事件记录时
{"message": "hello", "key1" : "value1", "key2" : "value2", "some_key" : "test"}
`select_entries` 处理器在处理后的输出中仅包含 `key1` 和 `key2`
{"key1": "value1", "key2": "value2"}