问题标签 [spring-cloud-task]

我在主类有一个带有 @EnableTask 注释的简单 webapp。我的应用程序在嵌入式 tomcat 上运行。是否可以在嵌入式 tomcat 中运行带有 @EnableTask 注释的 SpringBoot WebApp。是的，我可以举一个简单的例子吗？谢谢

我学习了 Spring Cloud Task 并编写了简单的应用程序，该应用程序分为 3 个服务。第一个TaskApplication是只有main()并实现CommandLineRunner的，第二个是TaskIntakeApplication接收请求并将它们发送到 RabbitMQ，第三个服务是TaskLauncherApplication从 RabbitMQ 接收消息并使用接收到的参数运行任务。

正如你所看到的，我通过提供 maven url 来调用我构建的工件，但我想知道如何从另一个 docker 容器调用工件？

我已经将我的 Spring Batch 应用程序部署到 Linux 环境和我的 SCDF 本地服务器，现在我想将我的 Spring Batch 应用程序注册到 SCDF。在 Windows 中，我通过提供 jar 文件路径来做到这一点。例如：file:///filePath/fineName。在 Linux 中，我可以将文件路径设为 /user/filePath/fileName。现在我需要将该文件路径注册到 SCDF。请建议我如何在 Linux 环境中做到这一点。

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

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

我创建了一个@EnableTaskLauncher带有spring-cloud-deployer-kubernetes. 它通过接收任务请求spring-cloud-stream并启动任务。

除了我希望将任务启动为Kind: Job而不是Kind: Deployment.

我找不到spring-cloud-deployer-kubernetes执行此操作的任何配置或属性，或者它是否可用。

我很好奇有没有办法通过 REST API 取消启动的任务？查看TaskOperations类（spring-cloud-dataflow-rest-client:1.3.0）我没有看到合适的方法（例如：取消、停止）。

我应该一直等到任务完成吗？

实际上我打算使用批处理作业，我想有可能获取作业执行 ID 并通过 停止它JobExecutionController，但是：

• 中没有对应的方法Taskoperations（不方便）
• 这真的是取消任务的唯一方法吗？

我有一个基于 web 的 spring 批处理应用程序。我的批处理作业将在 API 调用时启动。这是我作为 Web 服务公开的方法。

我的批处理作业运行良好，我有一个 Mysql 实例作为我的作业存储库。我已将 Spring Cloud 数据流集成到我的批处理应用程序中。我有我的 @EnableTask 注释和所有必要的依赖项。我已将 Spring Cloud 数据本地服务器连接到我的 Spring Batch jon Repository 实例。

这是我的 SCDF 命令行参数。

我的本地服务器正在运行并捕获所有作业执行实例。我已将我的 spring 批处理应用程序注册到 SCDF 并使用定义为 SCDF 定义了一个任务。

当我尝试从 SCDF 启动作业时，我得到“任务成功执行”。但我的工作没有得到执行。

如果我检查任务执行情况，我看到的是

StartTime N/A，EndTime N/A，如果我深入到任务执行，则没有运行批处理作业。请让我知道我们如何使用 Spring Cloud 数据流启动基于 Web 的 Spring Batch 作业。

我有 Spring Cloud Task，它将数据从 SQL Server 加载到 Cassandra DB，它将在 Spring Cloud Data Flow 上运行。

Spring Task 的要求之一是提供关系数据库来持久化元数据，例如任务执行状态。但我不想为此使用上述任何一个数据库。相反，我必须为持久性指定第三个数据库。但似乎 Spring Cloud 任务流会自动从 application.properties 中获取 SQL Server 的数据源属性。如何为任务状态持久性指定另一个数据库？

我的当前属性：

更新：1 我添加了下面的代码以指向 Michael Minella 建议的第三个数据库。现在 Spring Task 能够连接到这个数据库并保持状态。但是现在我的批处理作业源查询也连接到了这个数据库。我唯一改变的是为任务添加数据源。

更新#2：

更新#3： 如果我为存储库添加配置数据源，我现在得到以下异常。在您提到需要将其中一个数据源声明为 Primary 之前。我已经试过了。

@配置

我试图让spring boot batch application( 2.0.0.RC1) 与Spring cloud starter task( 2.0.0.M2) 一起工作。Spring cloud starter task使用spring boot 2.x 批处理应用程序时出现一系列错误。

我能够成功运行批处理应用程序spring-boot-starter-parent（1.5.10.RELEASE）Spring cloud starter task(2.0.0.M2)。

这是屏幕截图

但是当我尝试Spring cloud starter task(2.0.0.M2)使用时spring boot 2.0.0.RC1，我收到以下错误。

com.fasterxml.jackson.databind.exc.InvalidTypeIdException：无法将类型 id '' 解析为 [简单类型，类 java.lang.Object] 的子类型：

这是相同的屏幕截图。

所以我决定将 Spring Boot 降级到2.0.0.M7.Alas 我得到了一个不同的例外。

java.lang.IllegalStateException: org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@61f78561 已经关闭。

为什么会发生这种异常？任何帮助/指南将不胜感激。

我很好奇有没有办法从子任务中获取组合任务的executionID 。我尝试在子任务中使用TaskExecutionListener，但它返回该子任务的 Id，而不是“通用”。