decompress
decompress
处理器解压缩事件中任何 Base64 编码的压缩字段。
配置
选项 | 必需 | 类型 | 描述 |
---|---|---|---|
keys | 是 | 列表 | 事件中将要解压缩的字段。 |
type | 是 | 枚举 | 用于事件中 keys 的解压缩类型。仅支持 gzip 。 |
decompress_when | 否 | 字符串 | 一个 Data Prepper 条件表达式,用于确定 decompress 处理器何时在特定事件上运行。 |
tags_on_failure | 否 | 列表 | 当处理器无法解压缩事件中的 keys 时,用于标记事件的字符串列表。默认为 _decompression_failure 。 |
用法
以下示例展示了 pipelines.yaml
中使用的 decompress
处理器
processor:
- decompress:
decompress_when: '/some_key == null'
keys: [ "base_64_gzip_key" ]
type: gzip
指标
下表描述了常见的 抽象处理器 指标。
指标名称 | 类型 | 描述 |
---|---|---|
recordsIn | 计数器 | 进入管道组件的记录。 |
recordsOut | 计数器 | 从管道组件输出的记录。 |
timeElapsed | 计时器 | 管道组件执行期间经过的时间。 |
计数器
decompress
处理器包含以下指标:
processingErrors
:decompress
处理器中发生的处理错误数量。