Spring xd 流网络服务响应

Question

我正在尝试使用 spring xd 从使用 HTTP/1.1 协议的 Web 服务获取 text/xml 响应。目标是将 xml 响应转换为 json 并插入 mongodb。但是现在我无法从流中获得任何响应。我想以编程方式而不是在 shell 中执行此操作，下面是我的代码

public static void main(String[] args) {
        SpringXDTemplate template = null;
        try {
            template = new SpringXDTemplate(new URI("http://localhost:9393"));
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
        String name = "test";
        String definition = "time --fixedDelay=5 | http-client --url='''http://www.ctabustracker.com/bustime/api/v2/getvehicles?key=key&vid=1''' | file";
        template.streamOperations().destroy(name);
        template.streamOperations().createStream(name, definition, true);
}

我期待找到写入 C:\tmp\xd\output\test.out 的响应，但没有创建文件。我看到流是在管理员 ui 中创建的，我没有看到任何异常。我如何获得向此 url 发送请求的响应？

Answer 1

开启调试日志；您应该看到时间源每 5 秒发出一条消息；按照流程中的消息找出问题所在。

Spring xd 流网络服务响应

Spring xd stream web service responses

spring-xd