Spring 云数据流设计

Question

我有一个现有流程，我正在尝试将其转换为 SCDF 实施。当前进程是，

HTTP 接收器（接收 HTTP POST 数据）-> RabbitMQ -> MQ 接收器服务 -> Process/Transform -> DB Sink

如果可能的话，我怎样才能实现这样的流程？ （第 1 期）

到目前为止，我认为 SCDF 仅支持生产者 -> 过程 -> 消费者流。

我还尝试创建多个流（HTTP 源 -> RabbitMQ 接收器和 RabbitMQ 源 -> 进程 -> 数据库）但是 RabbitMQ 的部署（作为源和接收器）在 Cloud Foundry 上不起作用（第 2 期）。 Aperently，我可以使用 Rabbit source 或 sink 部署一个流，但不能同时使用它们（即使是不同的流）。

感谢您的帮助。

Answer 1

您所描述的是使用 named 目的地的基本流式传输管道，预计它可以在 Cloud Foundry 环境中工作。 您可以查看此 sample 了解更多信息。 如果问题仍然存在，请在尝试部署流时分享确切的 error/exception。