处理器数
处理器级代表您要执行的数据处理类型。 您可以根据需要在一个流程中使用多个处理器。
要帮助创建或测试流程 ，可以使用开发处理器。
独立流量
在独立流程中，可以使用以下处理器：
- Base64 字段解码器 - 将 编码数据解码为二进制数据。 Base64
- Base64 字段编码器 - 使用 对二进制数据进行编码。 Base64
- Couchbase 查找 - 在 Server 中执行查找，用数据丰富记录。 Couchbase
- 数据生成器 - 使用指定的数据格式将记录序列化为字段。
- 数据解析器 - 解析嵌入字段的 NetFlow 或系统日志数据。
- 延迟 - 将批次延迟传递到流程的其他部分。
- 加密和解密字段 - 加密或解密字段。
- 表达式评估器 - 对数据进行计算。 还可以添加或修改记录头属性。
- 字段扁平化器 - 扁平化嵌套字段。
- 字段散列器 - 使用算法对敏感数据进行编码。
- 字段映射器 - 将表达式映射到一组字段，以更改字段路径、字段名或字段值。
- 字段屏蔽器 - 屏蔽敏感字符串数据。
- 字段合并 - 合并复杂列表或地图中的字段。
- 字段排序 - 排列映射或列表映射根字段类型中的字段，并将字段输出到列表映射或列表根字段类型中。
- 字段透视器 - 透视列表、地图或列表-地图字段中的数据，并为字段中的每个项目创建记录。
- 字段移除器 - 从记录中移除字段。
- 字段重命名器 - 重命名记录中的字段。
- 字段替换器 - 替换字段值。
- 字段分割器 - 将字段中的字符串值分割成不同的字段。
- 字段类型转换器 - 转换字段的数据类型。
- 字段压缩 - 从两个字段合并列表数据。
- Geo IP- 返回指定 IP 地址的地理位置和 IP 情报信息。
- Groovy 评估器 - 根据自定义 Groovy 代码处理记录。
- HTTP 客户端 - HTTP 客户端处理器将请求发送到 HTTP 资源 URL 并将结果写入字段。
- HTTP 路由器 - 根据记录头属性中的 HTTP 方法和 URL 路径，将数据路由至不同的流。
- JavaScript 评估器 - 根据自定义 代码处理记录。 JavaScript
- JDBC 查找 - 通过 连接在数据库表中执行查找。 JDBC
- JDBC Tee - 通过 连接将数据写入数据库表，并用生成的数据库列中的数据丰富记录。 JDBC
- JSON 生成器 - 将字段中的数据序列化为 JSON 编码字符串。
- JSON 解析器 - 解析嵌入字符串字段的 JSON 对象。
- Jython 评估器 - 根据自定义 Jython 代码处理记录。
- 日志解析器 - 根据指定的日志格式解析字段中的日志数据。
- MLeap 评估器 - 使用存储在 MLeap bundle 中的机器学习模型，对数据进行评估、评分或分类。
- MongoDB Atlas 查找 - 在 Atlas 或 Enterprise Server 中执行查找，用数据丰富记录。 MongoDB MongoDB
- PMML 评估器 - 使用存储在 PMML 文档中的机器学习模型来生成预测或数据分类。
- PostgreSQL 元数据 - 跟踪源数据的结构变化，然后创建和修改 表，作为 PostgreSQL PostgreSQL 的漂移同步解决方案的一部分。
- 记录重复器 - 删除重复记录。
- Redis 查找 - 在 中执行键值查找，用数据丰富记录。 Redis
- Salesforce 批量 API 查找 2.0 - 使用 批量 API 在 中执行查找。 Salesforce 2.0 Salesforce
- Salesforce 查找 - 使用 SOAP 或批量 API 在 中执行查找。 Salesforce
- 模式生成器 - 为每条记录生成模式，并将模式写入记录头属性。
- SQL 解析器 - 解析字符串字段中的 SQL 查询。
- 静态查找 - 在本地内存中执行键值查找。
- 数据流选择器 - 根据条件将数据路由到不同的数据流。
- TensorFlow 评估器 - 使用 机器学习模型对数据进行预测或分类。 TensorFlow
- 网络客户端 - 向 HTTP 端点发送请求，并将结果写入字段。
- 全文件转换器 - 将 Avro 文件转换为 Parquet 文件。
- 窗口聚合器 - 在时间窗口内执行聚合，在监控模式下显示结果，并在启用时将结果写入事件。 该处理器不会更新正在评估的记录。
- XML 扁平化器 - 扁平化字符串字段中的 XML 数据。
- XML 解析器 - 解析字符串字段中的 XML 数据。
开发处理器
为帮助创建或测试流程 ，您可以使用以下开发处理器：
开发身份
Dev 随机误差
开发记录创建器
更多信息，请参阅开发阶段。