blocks|key|1408911|text|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1408912|我可以使用spring-cloud-dataflow(kubernetes)来执行递归任务吗？我需要根据当前结果创建流的新实例(递归)。我需要任务的分布式处理。|blockquote|1408913|1408914|1408915|您正在寻找的是我们在Spring+XD中拥有的“组合任务”feature，它在路线图中将其移植到Spring+Cloud数据流中。同时，您可以通过以下方式以编程方式调用任务:基于上游任务结果的REST-APIs或Dataflow+Template。|offset|length|1408916|1408917|+1)是否需要使用消息源？据我所知，数据流使用自己的消息代理(兔，kafka)。|1408918|1408919|1408920|SCDF+没有有自己的消息代理。我们提供的是一个绑定器抽象，并且有Kafka，Rabbit，Google+pub/sub和其他的实现。您可以选择最适合您的需求的绑定器实现。|style|BOLD|1408921|1408922|我是否需要安装另一个代理，或者我可以在数据流代理中创建队列？|1408923|1408924|1408925|SCDF不需要代理，但反过来，它是流管道中包含的“应用程序”需要它们。请观看今年早些时候来自SpringOne的recording会议。本文涵盖了基础知识和体系结构细节。|1408926|1408927|+2)我可以在没有队列的情况下这样做吗？|1408928|1408929|1408930|SCDF中的流处理需要消息传递中间件。您可以选择您选择的中间件。默认情况下，我们对rabbit和kafka都使用release+streams+apps。|1408931|1408932|流vs任务？|1408933|1408934|1408935|不清楚你这么说是什么意思。|1408936|entityMap|0|LINK|mutability|MUTABLE|url|http://docs.spring.io/spring-xd/docs/1.3.2.BUILD-SNAPSHOT/reference/html/#composed-jobs|1|http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#api-guide|2|http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#dataflow-template|3|https://www.youtube.com/watch?v=H-T-0WdZ3Sk&index=174&list=PLAdzTan_eSPQ1fuLSBhyB4eEZF7JQM0Mx|4|http://repo.spring.io/libs-snapshot/org/springframework/cloud/stream/app/^0|0|0|0|0|T|7|0|2O|9|1|2Y|H|2|0|0|0|0|0|5|2|0|0|0|0|0|1K|9|3|0|0|0|0|0|1K|K|4|0|0|0|0|0|0^^$0|@$1|2|3|-4|4|5|6|1T|7|@]|8|@]|9|$]]|$1|A|3|B|4|C|6|1U|7|@]|8|@]|9|$]]|$1|D|3|-4|4|5|6|1V|7|@]|8|@]|9|$]]|$1|E|3|-4|4|5|6|1W|7|@]|8|@]|9|$]]|$1|F|3|G|4|5|6|1X|7|@]|8|@$H|1Y|I|1Z|1|20]|$H|21|I|22|1|23]|$H|24|I|25|1|26]]|9|$]]|$1|J|3|-4|4|5|6|27|7|@]|8|@]|9|$]]|$1|K|3|L|4|C|6|28|7|@]|8|@]|9|$]]|$1|M|3|-4|4|5|6|29|7|@]|8|@]|9|$]]|$1|N|3|-4|4|5|6|2A|7|@]|8|@]|9|$]]|$1|O|3|P|4|5|6|2B|7|@$H|2C|I|2D|Q|R]]|8|@]|9|$]]|$1|S|3|-4|4|5|6|2E|7|@]|8|@]|9|$]]|$1|T|3|U|4|C|6|2F|7|@]|8|@]|9|$]]|$1|V|3|-4|4|5|6|2G|7|@]|8|@]|9|$]]|$1|W|3|-4|4|5|6|2H|7|@]|8|@]|9|$]]|$1|X|3|Y|4|5|6|2I|7|@]|8|@$H|2J|I|2K|1|2L]]|9|$]]|$1|Z|3|-4|4|5|6|2M|7|@]|8|@]|9|$]]|$1|10|3|11|4|C|6|2N|7|@]|8|@]|9|$]]|$1|12|3|-4|4|5|6|2O|7|@]|8|@]|9|$]]|$1|13|3|-4|4|5|6|2P|7|@]|8|@]|9|$]]|$1|14|3|15|4|5|6|2Q|7|@]|8|@$H|2R|I|2S|1|2T]]|9|$]]|$1|16|3|-4|4|5|6|2U|7|@]|8|@]|9|$]]|$1|17|3|18|4|C|6|2V|7|@]|8|@]|9|$]]|$1|19|3|-4|4|5|6|2W|7|@]|8|@]|9|$]]|$1|1A|3|-4|4|5|6|2X|7|@]|8|@]|9|$]]|$1|1B|3|1C|4|5|6|2Y|7|@]|8|@]|9|$]]|$1|1D|3|-4|4|5|6|2Z|7|@]|8|@]|9|$]]]|1E|$1F|$4|1G|1H|1I|9|$1J|1K]]|1L|$4|1G|1H|1I|9|$1J|1M]]|1N|$4|1G|1H|1I|9|$1J|1O]]|1P|$4|1G|1H|1I|9|$1J|1Q]]|1R|$4|1G|1H|1I|9|$1J|1S]]]]

<blockquote>
 Can I use spring-cloud-dataflow(kubernetes) for recursive tasks? I need to create new instance of flow depending on current results(recursive). I need distributed processing of tasks.
</blockquote>

What you're looking for is "composed task" <a href="http://docs.spring.io/spring-xd/docs/1.3.2.BUILD-SNAPSHOT/reference/html/#composed-jobs" rel="nofollow noreferrer">feature</a> that we had in Spring XD and it is in the roadmap to port it over to Spring Cloud Data Flow. In the meantime, you could programmatically invoke the Task via: <a href="http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#api-guide" rel="nofollow noreferrer">REST-APIs</a> or <a href="http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#dataflow-template" rel="nofollow noreferrer">Dataflow Template</a> based on an upstream task result.

<blockquote>
 1) Do I need to use message-source? As I unerstand, dataflow uses own message broker(rabbit, kafka). 
</blockquote>

SCDF doesn't have its own message broker. What we provide is a binder abstraction and there's implementation for Kafka, Rabbit, Google pub/sub and others. You could choose a binder implementation that works best for your requirements. 

<blockquote>
 Do I need to install another broker or I can create queue in dataflows broker?
</blockquote>

SCDF doesn't require a broker, but in turn, it is the "apps" included in streaming pipeline that need them. Please watch this <a href="https://www.youtube.com/watch?v=H-T-0WdZ3Sk&amp;index=174&amp;list=PLAdzTan_eSPQ1fuLSBhyB4eEZF7JQM0Mx" rel="nofollow noreferrer">recording</a> from SpringOne conference earlier this year. This covers the basics and architecture specifics. 

<blockquote>
 2) Can I do that without queue?
</blockquote>

Stream processing in SCDF requires a messaging middleware. You have the option to choose a middleware of your choice. By default, we <a href="http://repo.spring.io/libs-snapshot/org/springframework/cloud/stream/app/" rel="nofollow noreferrer">release streams apps</a> for both rabbit and kafka. 

<blockquote>
 Stream vs task?
</blockquote>

It is unclear what you mean by this.

Can I use spring-cloud-dataflow(kubernetes) for recursive tasks?
I need to create new instance of flow depending on current results(recursive). I need distributed processing of tasks. 

1) Do I need to use message-source? As I unerstand, dataflow uses own message broker(rabbit, kafka). Do I need to install another broker or I can create queue in dataflows broker?

2) Can I do that without queue?

3) Stream vs task?

thx

Recursion in spring-cloud-dataflow

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

我可以使用spring-cloud-dataflow(kubernetes)来执行递归任务吗？我需要根据当前结果创建流的新实例(递归)。我需要任务的分布式处理。1)是否需要使用message-source？据我所知，数据流使用自己的消息代理(兔，kafka)。我是否需要安装另一个代理，或者我可以在数据流代理中创建队列？2)我可以在没有队列的情况下完成吗？3)流与任务？thx

问spring-cloud-dataflow中的递归
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问spring-cloud-dataflow中的递归EN