【问题标题】:how to use dataflowtemplate in spring cloud data flow API.1.7.3spring cloud数据流API.1.7.3中如何使用dataflowtemplate
【发布时间】:2019-01-17 14:50:45
【问题描述】:

我的问题是如何在spring cloud数据流api中使用dataflowtemplate。

https://docs.spring.io/spring-cloud-dataflow/docs/current/api/

register(String name, ApplicationType type, String uri, String metadataUri, boolean force)

知道什么是uri,但不知道什么是metadataUri,能举个例子吗?

当我启动一个任务时,它总是说空点错误?什么意思?

dataFlowTemplate.taskOperations().launch("task",null,null);

DataFlowTemplate dataFlowTemplate = new DataFlowTemplate(new URI("http://localhost:9393/"),
    restTemplate);

dataFlowTemplate.appRegistryOperations().register("batch", ApplicationType.task,"maven://com.example:demo:jar:0.0.1-SNAPSHOT",null,true);
dataFlowTemplate.taskOperations().create("task","batch");
dataFlowTemplate.taskOperations().launch("task",null,null);

【问题讨论】:

    标签: spring-cloud-dataflow


    【解决方案1】:

    恭喜 StackOverflow 发布第一个帖子!

    参考指南中有几个示例:DataFlowTemplate。 --metadataUri 属性是选项,它用于注册一个伴随工件,其中包括已注册应用程序的所有受支持属性的键/值选项。同样,reference guide 中的更多详细信息。

    我们还有一整套依赖 DataFlowTemplate 在 SCDF 中创建和启动任务的测试工具。请参考AbstractTaskTests了解更多使用模式。

    【讨论】:

    • 感谢您的回复。
    • DataFlowTemplate dataFlowTemplate = new DataFlowTemplate( new URI("localhost:9393/"),restTemplate); dataFlowTemplate.appRegistryOperations().register("batch", ApplicationType.task,"maven://com.example:demo: jar:0.0.1-SNAPSHOT",null,true); dataFlowTemplate.taskOperations().create("task_job","batch"); 在这段代码中,我成功注册并创建了一个名为task_job的任务。我可以找到task_job和在数据流shell中输入命令行:task launch task_job,启动成功。
    • 但是如果我不使用shell,我会使用restful call (dataFlowTemplate.taskOperations().launch("task_job",null,null);) 来启动task_job。它说引起:java.lang.NullPointerException:null
    • 再次,请看我上面分享的示例。它完全符合您对 RESTTemplate 的要求。没有使用外壳。
    猜你喜欢
    • 2017-01-31
    • 1970-01-01
    • 2020-11-22
    • 2019-03-02
    • 2018-11-27
    • 2019-03-28
    • 1970-01-01
    • 2019-07-23
    • 2016-10-13
    相关资源
    最近更新 更多