澄清以spring云流作为源执行的任务

Question

在读取这份文件时，我们似乎可以用@EnableTask编写一个微服务，该服务具有一个源，其发出的消息被spring-cloud-task记录为执行步骤。

为了在没有spring-cloud-dataflow的情况下实现这一点，我想对这一声明作出几点澄清。

• 这是否意味着如果我们有一个Source bean和一个InboundChannelAdapter，我们不需要声明一个CommandLineRunner
• 根据定义，任务一次将发出数据，如何使用定期轮询的Source来再现此行为？
• 我试图在spring-boot应用程序中混合使用@EnableTask和AggregateApplicationBuilder的一些配置，以直接将Source连接到Sink，而不需要利用Kafka或RabbitMQ，但spring-cloud-task似乎需要一个绑定器。有办法跳过吗？

谢谢

Answer 1

现在可用的功能是侦听任务的生命周期事件，并将它们发布到指定的(可覆盖的)通道目的地进行下游分析/处理。这仅仅是通过在类路径中拥有特定Stream的绑定器实现就可以实现自动化的。

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

似乎您正在尝试将(SCSt)和Spring (SCT)注释混合到您的引导应用程序中。这不是我们打算使用的方式。如果你还没有，请看这个样本得到一个想法。

根据定义，任务一次将发出数据，如何使用定期轮询的源来再现此行为？

一个任务运行一段“有限的时间”，这可以用嵌入在应用程序中的业务逻辑运行多长时间来描述。任务还需要某种形式的触发器才能启动。您可以使用调度程序进行定期启动或通过流启动。下面是关于如何通过Spring (SCDF)中的流启动它的笔迹。

如果要在SCDF之外执行此操作，仍然需要自己运行triggertask并设置正确的env-var，因此Stream + Task应用程序通过公共通道目的地连接。

..。但春季云任务似乎需要一个绑定器。有办法跳过吗？

SCSt和SCT之间的连接是通过spring-cloud-task-stream和spring-cloud-stream-binder-<type-of-binder>依赖关系完成的，并且没有其他方法。