通过 JSON 标头进行 Spring Cloud Dataflow 路由

Question

我一直在尝试使用 Spring Cloud Dataflow 创建一个流，但运气不佳（主要是由于缺乏文档）。

问题 1：访问 dockerized Spring Cloud Dataflow 的 Web GUI 我有一个在基本 Ubuntu 容器上运行 Kafka 的 dockerized Spring Cloud 服务器。出于某种原因，我无法在 Windows 中访问 Web GUI（位于 :9393/dashboard）。但是，我有一个运行 Nginx 反向代理的单独 Docker Ubuntu 容器，当我转到 /index.html 等时会显示它。我认为这不是端口问题，我有 Spring使用 -p 9393:9393 设置云容器，否则该端口未使用。

问题 2：通过 JSON Header 路由 我的最终目标是从 Nginx 加载一个文件并根据其 JSON 标头进行路由（有两个不同的 JSON 标头），然后将查询提取到 Cassandra。 除了按 JSON 标头排序之外，我可以完成所有这些操作。您会推荐我使用哪个应用程序？

Answer 1

问题1：访问dockerized Spring Cloud Dataflow的Web GUI

我们可能需要更多细节。假设这是本地服务器，也许您可​​以共享 docker 脚本/图像，所以我们可以尝试一下。

问题 2：通过 JSON Header 路由

router-sink 应用程序对于这种类型的用例会派上用场。此应用程序根据特定条件将有效负载路由到指定的目的地，因此您有机会将带有相应ingest-query 的有效负载路由到 Cassandra。

流 1：

stream create test --definition "file | router --expression=header.contains('a')?':foo':':bar’"

流 2：

stream create baz --definition ":foo > cassandra --ingest-query=\"query1\""

流 3：

stream create wiz --definition ":bar > cassandra --ingest-query=\"query2\""

（其中：foo 和 bar 被命名为目的地）