事件处理函数

本文档介绍事件处理函数的语法与格式、相关的场景示例等。

e_output 函数

输出到指定别名的目标主题中。其中，日志主题别名即创建加工任务时指定的目标名称。

函数语法/格式

e_output(topic="日志主题别名")

参数说明如下：

函数示例

• 场景：根据日志中字段 is_output 的值判断是否要输出该日志到别名为 target-1 的日志主题中。

• 加工规则：

  c_if(v("is_output"), e_output("target-1"))
  

• 日志样例：

  [
      {
          "is_output":1,
          "content":"hello world"
      },
      {
          "is_output":0,
          "content":"test content"
      }
  ]
  

• 加工结果：

  [
      {
          "is_output":1,
          "content":"hello world"
      }
  ]
  

  说明

  第一条日志输出到别名为 target-1 的日志主题中，第二条日志不输出。

e_split 函数

使用分隔符对特定字段进行拆分，拆分结果分裂为多条日志。

函数语法/格式

e_split(field, sep=",", quote='"', lstrip=Ture, jmes=None, output=None)

分裂规则：

• 规则 1：如果配置了 jmes 参数，则将日志字段的值转化为 JSON 列表，再使用 jmes 提取值作为下一步的值。此时 sep 和 quote 参数的指定无效。如果没有配置 jmes 参数，按规则 2 进行分裂。
• 规则 2：如果上一步的值是一个列表或 JSON 列表格式的字符串，则按照此列表分裂并结束处理，此时 sep 和 quote 参数的指定无效。如果不是 JSON 列表或 JSON 列表字符串，按规则 3 进行分裂。
• 规则 3：使用 sep、quote 和 lstrip 将上一步的值进行 CSV 解析，根据解析后的多个值进行分裂并结束处理。

参数说明如下：

函数示例

• 场景：根据字段 city 的值分裂为多条日志。

• 加工规则：

  e_split("city")
  

• 日志样例：

  {
      "content":"hello world",
      "city":"shanghai,hangzhou,chengdu"
  }
  

• 加工结果：

  [
      {
          "content":"hello world",
          "city":"shanghai"
      },
      {
          "content":"hello world",
          "city":"hangzhou"
      },
      {
          "content":"hello world",
          "city":"chengdu"
      }
  ]
  

e_drop 函数

丢弃符合条件的日志。

函数语法/格式

e_drop(condition=条件)

参数说明如下：

函数示例

• 场景：根据日志字段 city 的值判断是否丢弃该日志。

• 加工规则：

  c_if(op_eq(v("city"), "shanghai"), e_drop())
  

• 日志样例：

  [
      {
          "content":"hello world",
          "city":"shanghai"
      },
      {
          "content":"hello world",
          "city":"hangzhou"
      }
  ]
  

• 加工结果：

  {
      "content":"hello world",
      "city":"hangzhou"
  }
  

e_keep 函数

保留符合条件的日志，不符合条件则丢弃。

函数语法/格式

e_keep(condition=条件)

参数说明如下：

函数示例

• 场景：根据日志字段 city 的值判断是否保留该日志。

• 加工规则：

  c_if(op_eq(v("city"), "shanghai"), e_keep())
  

• 日志样例：

  [
      {
          "content":"hello world",
          "city":"shanghai"
      },
      {
          "content":"hello world",
          "city":"hangzhou"
      }
  ]
  

• 加工结果：

  {
      "content":"hello world",
      "city":"shanghai"
  }