问题标签 [spring-cloud-dataflow]

我知道可以安排云任务，并且可以使用流进行配置，也可以执行。作为一名开发人员，我想使用 rest-api 执行我的 spring 云任务，以便我可以按需执行任务。基本上我有一个工作流程管理系统，我们正在使用 control-m 代理。所以现在一些作业将由control-m执行，一些任务将部署在spring cloud dataflow server上。现在，当一项作业完成时，必须执行云上的另一项作业。因此，为此我需要能够调用 rest api 并按需执行云任务。我确信此功能必须存在，但我无法找到文档示例。有人可以帮帮我吗。提前致谢。

我是学习 Spring 云任务和 SCDF 的新手，所以问这个。

我想根据一个事件执行我的 SCT（比如将一条消息发布到 Rabbit MQ），所以我认为它可以通过两种方式完成：

1. 创建一个从 RabbitMQ 轮询消息并将数据发送到流的源，现在创建一个从流中读取数据的接收器，一旦数据到达接收器（来自源流），任务就会启动。

   不确定这是否可能？

2. 其他方式可能是使用任务启动器。这里任务启动器将配置一个流，一个监听器将从 rabbitMQ 轮询消息。因此，当收到消息时，触发器将启动该过程，而 tasklauncher 将启动该任务。但是这里不确定我将如何将消息数据放入我的任务中？我是否必须将数据添加到 TaskLaunchRequest 中？

   /li>

• Spring Cloud 数据流服务器 Cloudfoundry - 1.0.0.RELEASE
• Spring Cloud 配置服务器 - 1.1.3

这是一种奇怪的行为。我们正在观察部署到 Spring Cloud Data Flow 中的 Spring Cloud Stream 应用程序，并且绑定的配置服务器实例正在从属性文件中读取 {cipher} 前缀值作为纯文本值，而不是尝试解密它们。

我在调试应用程序时看到这样的东西：

而不是这样的：

就配置服务器的配置方式以及它从我们的 Git 存储库加载属性文件的事实而言，其他一切似乎都是有序的。它只是不解密密码值。我们忘记了什么简单的事情？

我有一个流，它会根据给定的时间间隔启动任务。我想与它一起使用rabbit binder，但我缺少提供rabbitmq 代理属性的语法。有人可以帮助我。

我们正在尝试使用 spring-cloud-dataflow 在开发环境中部署我们的微服务。每个应用程序都登录到 /tmp 目录，并将 /tmp 目录用作工作目录。

这会耗尽我们机器上可用的可悲磁盘空间。有没有办法配置这个？

我已经更改了 spring 云数据流，以便移动它的日志，并查看 /etc/init.d/spring-cloud-dataflow-server-local 但看不到任何帮助。

根据我所见，在 Spring Cloud Dataflow (SCDF) 中创建流将部署底层应用程序、绑定通信服务（如 RabbitMQ）、设置 Spring Cloud Stream 环境变量并启动应用程序。这一切都可以使用 cf push 命令轻松手动完成。

同时，我遇到了 Spring Cloud Dataflow 的一些缺点：

• SCDF 服务器是 PCF 上的内存占用者（我有一个只有 6 个应用程序的流，但我需要大约 10GB 的服务器空间）
• 应用程序命名、内存、实例等方面没有灵活性。（您通常会在 manifest.yml 中设置的所有内容）
• 与构建工具（如 Bamboo）的集成将需要额外的工作，因为我们必须使用 SCDF CLI 而不仅仅是 PCF CLI
• 无法修改现有流。要进行蓝绿部署，您必须手动部署应用程序（绑定服务并手动设置环境变量）。然后，一旦完成蓝绿部署，SCDF 将流显示为失败，因为它不知道底层应用程序之一已更改。
• 我遇到的各种错误，例如尝试重新部署失败的流时出现 MySQL 主键约束错误

那么我错过了什么？为什么使用 Spring Cloud Dataflow 有利于手动部署应用程序？

我们正在考虑使用 Spring Cloud Task / Spring Cloud Data Flow 来满足我们的批处理需求，因为我们正在从遗留系统进行现代化改造。我们不想要或不需要整个微服务产品......我们希望能够部署作业/任务，启动批处理，让它们记录到日志文件，并共享数据库连接池和消息队列。我们不需要 Spring Cloud Foundry 提供的整个 PaaS，我们也不想为此付费，但我们确实希望数据流/任务框架得到商业支持。有这样的选择吗？

启动 Spring Cloud Data Flow 流时，由于各种 Kafka 相关错误，应用程序经常无法在我的机器上部署。例如： org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder [...] Caused by: kafka.common.KafkaException: fetching topic metadata for topics [Set(xxx)] from broker [List()] failed

但我也看到了这个： kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0

在这两种情况下，Kafka 进程（以及 ZooKeeper）都在运行，所以我假设已经通过了某种超时阈值。

通用配置和特定于Kafka 的配置似乎都没有提供任何超时选项。

有什么方法可以影响 Kafka 客户端放弃并假设代理已经离开的时间量？

我们正在使用需要设置系统环境变量的第三方安全库。我们可以在流定义中作为参数传递，还是在为每个应用程序单独部署流时传递？

应用信息：

• Spring Cloud Data Flow Server Cloudfoundry 1.0.0.RELEASE（使用Spring Cloud Config Server依赖DIY搭建）
• Spring Cloud 配置服务器
• PCF 弹性运行时 1.7.x

我很好奇应用程序和部署程序在多大程度上依赖于 Git 存储库和 Maven 工件存储库我将我的 SCDF 实例和我的 Spring Cloud Config Server 实例绑定到 PCF 中。

我怀疑 Maven 存储库仅在部署时使用，此时需要下载工件以在 PCF 空间中安装和部署。此外，我认为 Git 存储库可能会在应用程序初始化或发生刷新事件时由配置服务器克隆，这需要重新读取存储在 Git 中的配置信息。

这是真的吗，或者是否存在需要这些外部资源具有高可用性的持续依赖关系？我的问题与灾难恢复计划活动有关，以及这些特定资源需要多快恢复才能使 Spring Cloud Data Flow 及其部署的流在不利条件下继续工作。