当前位置: 首页 > 知识库问答 >
问题:

可以使用Spring Cloud数据流根据负载动态提供从进程吗?

柴兴贤
2023-03-14

我们目前正在使用Spring Batch-Remote分块来扩展批处理过程。考虑使用云数据流,但想知道是否可以基于负载动态配置从服务器?我们部署在谷歌云中,因此如果云数据流适合我们的需求,我们也想为kubernetes使用Spring云数据流支持?

共有1个答案

曹渝
2023-03-14

当使用Spring Cloud Task的批处理扩展(特别是DeployerPartitionHandler)时,worker将根据需要动态启动。PartitionHandler允许您配置最大数量的辅助程序,然后它将作为独立的辅助程序处理每个分区,直到最大数量(在其他分区完成时处理其余分区)。“动态”方面实际上是由分区器返回的分区数控制的。返回的分区越多,意味着启动的工人就越多。

您可以看到一个配置为使用CloudFoundry的简单示例:https://github.com/mminella/s3jdbc。它与您所需要的主要区别在于,您将CloudFoundryTaskLauncher替换为KubernetestaskLauncher,这是适当的配置。

 类似资料:
  • 我知道iBeacon的定义是它正在传输的广告包的固定规范: 9字节iBeacon前缀 16字节UUID 2字节主要 2字节次要 1字节TX电源 也就是说,有没有什么可以阻止信标发送广告iBeacon数据包来唤醒手机的应用程序,并作为BLE数据包的一部分传输实际数据内容?为了发送/传输额外的数据,是否需要大量的握手? 信标还有其他传输数据的方式吗?我最大的担忧之一是欺骗我的信标,以伪造我试图收集的数

  • 我想用Selenium和TestNG来模拟谷歌搜索,同时使用各种搜索参数。下面是我的测试类和testng。xml。我已经使用下面的注释

  • 我正在尝试使用pact jvm进行用户驱动合约测试,并且能够生成用户端合约文件。在提供者端验证过程中,如何提供公共API而不是localhost大多数示例只使用localhost作为提供者,请提供帮助

  • 有人知道TestNG如何根据为测试方法指定的数据提供者名称计算出数据提供者方法是什么吗? 我找到了这个解决方案:https://gist.github.com/ae6rt/3805639 但是,它没有考虑到数据提供者可能是: 在完全不同的类别中定义,或 在父类中定义,并且 该方法可以是静态的,也可以是非静态的 我试图自己破解一些东西,但后来我想我不可能是第一个试图解决这个问题的人,特别是因为显然T

  • Entity Framework Core 通过一个提供程序模型来允许使用 EF 访问各种不同的数据库。一些概念对于大部分数据库是通用的,这些都包含在主要的 EF Core 组件中,包括 LINQ 的查询表达、事务以及从数据中加载出来后对象的变更跟踪。一些概念则是特定于个别提供程序,比如 SQL Server 提供程序允许你配置内存优化表(一个特定于 SQL Server 的功能),另外一些概念则

  • 有没有办法在运行时从数据库添加新的 IdP,同时使用适用于 SAML 2.0 的 Spring 安全扩展 如何在运行时从用户处获取所需的属性,而无需重新启动服务器或应用程序,从而将新的身份提供者添加到Java Web应用程序中。 以及需要将哪些所有通用属性(如entityId、SSO身份验证URL和公共X.509证书)作为输入,以便在不重新启动服务器的情况下将新IdP添加到现有Web应用程序中。