1.3.2.3. 数据转换 Kamelets

通过以下数据转换 Kamelets,您可以在源和接收器组件之间传递的数据执行简单的操作:

  • 提取字段 - 使用 extract-field-action Kamelet 从数据正文中拉取字段,并将数据的整个正文替换为提取字段。
  • Hoist Field - 使用 hoist-field-action Kamelet 将数据正文嵌套到单个字段。
  • 插入标头 - 使用 insert-header-action Kamelet 使用静态数据或记录元数据添加标头字段。
  • 插入字段 - 使用 insert-field-action Kamelet 通过使用静态数据或记录元数据添加字段值。
  • 掩码字段 - 使用 mask-field-action Kamelet 将字段值替换为字段类型的有效 null 值(如 0 或空字符串),或使用给定的替换(替换必须是非空字符串或数字值)。

    例如,如果您要从相关数据库捕获数据到 Kafka,且数据包含受保护(PCI / PII)信息,如果 Kafka 集群还没有认证,则必须屏蔽保护信息。

  • replace Field - 使用 replace-field-action Kamelet 过滤或重命名字段。您可以指定要重命名的字段、使用 disable(exclude)或 启用(include)。
  • To Key - (针对 Kafka)使用 value-to-key-action Kamelet 将 record 键替换为从有效负载中字段子集中形成的新键。您可以将事件键设置为基于事件信息的值,然后再将数据写入 Kafka。例如,在从数据库表读取记录时,您可以根据客户 ID 对 Kafka 中的记录进行分区。