Link Search Menu Expand Document Documentation Menu
文档

rename_keys

rename_keys 处理器会重命名事件中的键。

配置

您可以使用以下选项配置 rename_keys 处理器。

选项 必需 描述
entries 是 要重命名的事件条目列表。
from_key 是 要重命名的条目的键。
to_key 是 条目的新键。
overwrite_if_to_key_exists 否 当设置为 true 时，如果事件中已存在 key，则会覆盖现有值。默认值为 false。

用法

首先，创建以下 pipeline.yaml 文件

pipeline:
  source:
    file:
      path: "/full/path/to/logs_json.log"
      record_type: "event"
      format: "json"
  processor:
    - rename_keys:
        entries:
        - from_key: "message"
          to_key: "newMessage"
          overwrite_if_to_key_exists: true
  sink:
    - stdout:

接下来，创建一个名为 logs_json.log 的日志文件，并将您的 pipeline.yaml 文件中的文件源 path 替换为该文件路径。有关更多信息，请参阅配置 OpenSearch Data Prepper。

例如，在运行 rename_keys 处理器之前，如果 logs_json.log 文件包含以下事件记录

{"message": "hello"}

当您运行 rename_keys 处理器时，它会将消息解析为以下“newMessage”输出

{"newMessage": "hello"}

如果 newMessage 已存在，其现有值将被 value 覆盖。

特殊注意事项

重命名操作按照键值对条目在 pipeline.yaml 文件中列出的顺序进行。这意味着在 rename_keys 处理器中，链式操作（键值对按顺序重命名）是隐式的。请参见以下示例 pipeline.yaml 文件

pipeline:
  source:
    file:
      path: "/full/path/to/logs_json.log"
      record_type: "event"
      format: "json"
  processor:
    - rename_keys:
        entries:
        - from_key: "message"
          to_key: "message2"
        - from_key: "message2"
          to_key: "message3"
  sink:
    - stdout:

将以下内容添加到 logs_json.log 文件中

{"message": "hello"}

在 rename_keys 处理器运行后，会出现以下输出

{"message3": "hello"}
剩余 350 字符

有问题？。

想贡献？或。