SCDF 流设计和定制处理器
SCDF Stream Design & Custom Processor
我当前的用例是接收 HTTP Post 消息，对其进行验证，转换为具有感兴趣字段的业务对象（仅）并推送到 nosql 数据库。
我已经成功完成了 http source 上的 poc 和 mongodb cloud foundry 上的 sink。
对于请求数据验证和转换，我没有找到任何可用的处理器，所以假设我必须编写一个（实际上是两个）。
验证处理器可以生成条件输出吗？意思是，
- 将有效数据发送到队列以进行进一步处理（此处为转换）？
- 将无效数据发送到 log/error 在 mongodb 接收器中处理？
或者我应该以不同的方式设计我的流吗？感谢您的指导。
谢谢
我当前的用例是接收 HTTP Post 消息，对其进行验证，转换为具有感兴趣字段的业务对象（仅）并推送到 nosql 数据库。
我已经成功完成了 http source 上的 poc 和 mongodb cloud foundry 上的 sink。
对于请求数据验证和转换，我没有找到任何可用的处理器，所以假设我必须编写一个（实际上是两个）。
验证处理器可以生成条件输出吗？意思是，
- 将有效数据发送到队列以进行进一步处理（此处为转换）？
- 将无效数据发送到 log/error 在 mongodb 接收器中处理？
或者我应该以不同的方式设计我的流吗？感谢您的指导。
谢谢