java - 将流从 java 发送到 apache nifi 处理器

问题描述

大家早上好所以我有这个java代码可以解析成swagger文档文件（一个JSON文件）并拆分它：

{ Swagger swagger = new SwaggerParser().read("C:/Users/admin/Desktop/testdownload.txt");
  Map<String, Path> paths = swagger.getPaths();
  for (Map.Entry<String, Path> p : paths.entrySet()) {
    Path path = p.getValue();
    Map<HttpMethod, Operation> operations = path.getOperationMap();
    for (java.util.Map.Entry<HttpMethod, Operation> o : operations.entrySet()) {
      System.out.println("===");
      System.out.println("PATH:" + p.getKey());
      System.out.println("Http method:" + o.getKey());
      System.out.println("Summary:" + o.getValue().getSummary());
      System.out.println("Parameters number: " + o.getValue().getParameters().size());
      for (Parameter parameter : o.getValue().getParameters()) {
        System.out.println(" - " + parameter.getName());
      }
      System.out.println("Responses:");
      for (Map.Entry<String, Response> r : o.getValue().getResponses().entrySet()) {
        System.out.println(" - " + r.getKey() + ": " + r.getValue().getDescription());
      }
      System.out.println("");
    }

  }
}

这是输入：输出是：

我想问的是：是否可以将此输出逐个路径发送到 apache Nifi ？Nifi是否有任何解决方案可以提取这些输出并将它们中的每一个都放在一个依赖处理器中？

标签： javaapache-nifi

您可以在 NiFi 中启动 HTTP 列表服务。使用HandleHttpRequest

前段时间我做了这样的事情。并且正在从我的 Java 应用程序向这个 HandleHttpRequest 发送数据。此处理器旨在与 HandleHttpResponse 处理器结合使用，以创建 Web 服务

您只需将数据发布到此 Web 服务，Web 服务就可以使用它，并且您已经在 NiFi 中拥有数据。从那时起，您可以随心所欲地操纵和控制您的数据。

您还可以查看ListenHTTP

java - 将流从 java 发送到 apache nifi 处理器

问题描述

解决方案

推荐阅读