如何在 spring 云任务完成时执行清理

How to perform clean ups on spring cloud task completion

我正在编写支持流和任务应用程序的 SCDF spi 实现。作为其中的一部分,我们需要在任务完成后执行一些清理操作。

有人可以提供有关 SCDF 是否会在任务完成时收到回调的信息。如果不是,那么执行清理的替代方法是什么。

任务是一种短暂且有限的操作。根据您要完成的任务,您可以执行以下操作之一来调用任何自定义清理例程。

1) 任务 运行 批处理作业,在该作业中,您可以将 "n" 步数定义为工作流的一部分,并且在上游步骤成功后,最后一步可以调用清理例程。

2) 你可以有一个 stream in SCDF listening to Task-complete events (a batch-job example here),它最终可以启动另一个 task/job 来调用清理例程。

3) 您可以定义一个 composed-task graph (via Dashboard/shell) ,其中每个步骤(又名任务)都可以 运行 其预期的操作,并且在成功转换或失败事件时,您有机会踢关闭清理程序。