spring-cloud-stream - SCDF 流设计和定制处理器

Question

我当前的用例是接收 HTTP Post 消息，对其进行验证，转换为具有感兴趣字段的业务对象（仅）并推送到 nosql db。

我已经在 Cloud Foundry 上成功完成了 http 源和 mongodb sink 的 poc。

对于请求数据验证和转换，我没有找到任何可用的处理器，所以假设我必须编写一个（实际上是两个）。

验证处理器可以生成条件输出吗？意义，

• 将有效数据发送到队列以进行进一步处理（此处为转换）？
• 将无效数据发送到 mongodb 接收器中的日志/错误处理？

或者我应该以不同的方式设计我的流？感谢您的指导。

谢谢

标签： spring-cloud-streamspring-cloud-dataflow

Answer 1

是的; 您可以使用 aStreamBridge选择将输出发送到何处。

https://docs.spring.io/spring-cloud-stream/docs/3.1.2/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources