Link Search Menu Expand Document Documentation Menu

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"}
剩余 350 字符

有问题?

想贡献吗?