关于使用弹簧云流作为源执行的任务的说明

Question

当阅读this documentation时，似乎我们可以编写一个带有@EnableTask的微服务，该服务具有一个源，其发送的消息作为spring-cloud-task的执行步骤被记录。

我想对此声明有几点澄清，以实现这一点没有spring-cloud-dataflow：

• 这是否意味着，如果我们有一个Source豆与InboundChannelAdapter，我们并不需要声明CommandLineRunner？
• 通过定义一个任务应该发出的数据的一个时间，如何再现与调查定期间隔Source这种行为？
• ，我打算给spring-boot应用程序中混合使用@EnableTask和AggregateApplicationBuilder一些配置直接连接我的Source到Sink，而不需要利用Kafka或RabbitMQ，但似乎spring-cloud-task需要的粘合剂。有没有办法跳过它？

感谢

Answer 1

什么是可利用的今天是听任务的生命周期事件，并将它们发布到一个名为（重写）信道用于下游分析/处理目标的能力。这只需通过在类路径中实现特定的Spring Cloud Stream的绑定器即可实现自动化。

这是否意味着如果我们有一个带有InboundChannelAdapter的Source bean，我们不需要声明一个CommandLineRunner？

好像你想在你的引导应用混合云春流（SCST）和Spring云任务（SCT）的注释。这不是它打算如何使用。如果你还没有准备好，请参阅this sample进行了解。

根据定义，任务预计会发出一次数据，如何重现这种行为与定期间隔轮询源？

任务运行时间为“有限的时间段”，这是由嵌入应用程序的业务逻辑的运行时间来描述的。任务还需要某种形式的触发器才能启动。您可以使用调度程序进行重复定时启动或通过流启动它。这里是你如何会在春季云数据流（SCDF）流启动它write-up。

如果你做到这一点民防部队之外，你还上自己运行triggertask并设置正确的env-VAR的，所以流+任务应用程序通过公共信道目的地有关连。

...但它似乎弹簧云的任务需要的粘合剂。有没有办法跳过它？

SCST与SCT之间的连接是通过spring-cloud-task-stream和spring-cloud-stream-binder-<type-of-binder>依赖性做，有没有其他的方法了。