parse_ion
parse_ion
处理器解析 Amazon Ion 数据。
配置
您可以使用以下选项配置 parse_ion
处理器。
选项 | 必需 | 类型 | 描述 |
---|---|---|---|
源 | 否 | 字符串 | event 中被解析的字段。默认值为 message 。 |
目标 | 否 | 字符串 | 解析后的 JSON 的目标字段。默认为 event 的根。不能是 "" 、/ 或任何只包含空白字符的 string ,因为这些不是有效的 event 字段。 |
指针 | 否 | 字符串 | 指向要解析的字段的 JSON 指针。默认情况下没有 pointer ,这意味着整个 source 都将被解析。pointer 也可以访问 JSON 数组索引。如果 JSON 指针无效,则整个 source 数据将被解析到传出的 event 中。如果指向的键在 event 中已存在且 destination 是根,则指针使用键的整个路径。 |
解析条件 | 否 | 字符串 | 指定处理器应在何种条件下执行解析。默认情况下没有条件。接受遵循表达式语法的 OpenSearch Data Prepper 表达式字符串。 |
overwrite_if_destination_exists | 否 | 布尔型 | 如果设置为 true ,则覆盖目标。设置为 false 可防止更改已存在的目标值。默认值为 true 。 |
删除源 | 否 | 布尔型 | 如果设置为 true ,则源字段将被删除。默认值为 false 。 |
tags_on_failure | 否 | 字符串 | 一个字符串列表,指定在处理器失败或解析期间发生未知异常时在事件中设置的标签。 |
用法
以下示例展示了如何在管道中使用 parse_ion
处理器。
示例:最小配置
以下示例显示了 parse_ion
处理器的最低配置。
parse-json-pipeline:
source:
stdin:
processor:
- parse_json:
source: "my_ion"
sink:
- stdout:
当输入事件包含以下数据时
{"my_ion": "{ion_value1: \"hello\", ion_value2: \"world\"}"}
处理器将事件解析为以下输出:
{"ion_value1": "hello", "ion_value2" : "world"}