是否可以使用Spring Cloud DataFlow Java Rest客户端获取所有流的列表？

Question

我正在使用 Spring Cloud Dataflow Java Rest 客户端 (https:/ /docs.spring.io/spring-cloud-dataflow/docs/current/api/）并希望使用它来检索所有当前部署的流。

获取 StreamOperations 对象并从中获取流列表非常简单：

val template = DataFlowTemplate(<someUri>)
val streamOperations = template.streamOperations()
val streamDefinitionResources = streamOperations.list()

上面的 streamDefinitionResources 实际上是一个 PagedModel ，它使用 2000 的页面大小保存结果的第一页。

但是，我没有看到任何方法来迭代所有页面以使用 java Rest 客户端获取所有流（即，没有通过 StreamOperations 或 StreamDefinitionResource 类提供的分页支持）。

是否可以仅使用 java Rest 客户端获取所有流？我错过了什么吗？

Answer 1

摘要

PagedModel 有一个 getNextLink() 方法，可用于手动遍历结果的“下一页”。

详细信息

底层 Dataflow REST API 支持通过页码和大小请求参数进行分页，并返回 HAL 响应，其中包含指向下一页和上一页的_链接。

例如，给定 10 个流定义，此 HTTP 请求：

GET localhost:9393/streams/definitions?page=0&size=2

返回以下响应：

{
  _embedded: {
    streamDefinitionResourceList: [
      {
        name: "ticktock1",
        dslText: "time | log",
        originalDslText: "time | log",
        status: "undeployed",
        description: "",
        statusDescription: "The app or group is known to the system, but is not currently deployed",
        _links: {
          self: {
            href: "http://localhost:9393/streams/definitions/ticktock1"
          }
        }
      },
      {
        name: "ticktock2",
        dslText: "time | log",
        originalDslText: "time | log",
        status: "undeployed",
        description: "",
        statusDescription: "The app or group is known to the system, but is not currently deployed",
        _links: {
          self: {
            href: "http://localhost:9393/streams/definitions/ticktock2"
          }
        }
      }
    ]
  },
  _links: {
    first: {
      href: "http://localhost:9393/streams/definitions?page=0&size=2"
    },
    self: {
      href: "http://localhost:9393/streams/definitions?page=0&size=2"
    },
    next: {
      href: "http://localhost:9393/streams/definitions?page=1&size=2"
    },
    last: {
      href: "http://localhost:9393/streams/definitions?page=4&size=2"
    }
  },
  page: {
    size: 2,
    totalElements: 10,
    totalPages: 5,
    number: 0
  }
}

Dataflow Java REST 客户端在 PagedModel 响应中公开此 HAL 响应，该响应提供 getNextLink()代码>方法。

警告 1) 但是，当前的实现（正如您所指出的）被硬编码为 2000 的页面大小。这意味着只有超过 2000 流定义，您才会看到此行为。

注意事项 2) 另一点需要注意的是，不会自动处理链接到“下一页”的遍历，您需要手动调用链接 URL 来检索下一页。

假设 StreamOperations.list 接受页面大小参数，代码可能如下所示：

int pageSize = 2;
PagedModel<StreamDefinitionResource> pageOfStreamDefs = streamOperations().list(pageSize);
pageOfStreamDefs.getNextLink()
    .ifPresent((link) ->  someFunctionToInvokeAndProcessNextPage(link.getHref());

有关 REST API 参数的更多详细信息，请访问 此处。

Answer 2

我想我有点晚了，但我遇到了同样的问题并找到了解决方法。正如 onobc 所说，任何资源的 PagedModel 都有一个 getNextLink() 方法，该方法返回带有下一页地址的 Link 。
您可以使用 DataflowTemplate 中的相同 RestTemplate 来处理接下来的请求：

PagedModel<StreamDefinitionResource> streamDefPage = dataflowTemplate.streamOperations().list();
// Process page here
if (streamDefPage.getNextLink().isPresent()) {
    Link link = streamDefPage.getNextLink().get();
    PagedModel<StreamDefinitionResource> streamDefNextPage = dataflowTemplate.getRestTemplate().getForObject(link.getHref(), StreamDefinitionResource.Page.class);
    // Process next page here
}

等等。

希望这有帮助！