0

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

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

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

4

1 回答 1

2

问题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被命名为目的地）

于 2016-09-01T22:25:12.073 回答