基于arrivalnode的批处理代理
在Anylogic模型中，我的源块根据定义代理必须到达哪个节点的数据库值在不同节点上生成代理。
相同位置的订单同时到达（例如，7:30，3个代理订单到达node1，4个代理订单到达node2）。
现在我想做的是，节点1上的订单生成一批1x2和1x1，而节点2上的订单生成一批2。这些代理将扣押将这些批次运输到同一位置的运输公司，然后解除批次。
因此，我的问题是如何基于从数据库加载的Arrivalocation创建批。
谢谢
共有1个答案
在类型为矩形节点的代理中创建变量。将代理所在的节点存储在源块中。
使用“源”块下游的SelectOutput块，该块按其当前节点拆分代理。
然后，像往常一样使用批处理对象，因为到达的代理现在按其节点位置进行拆分。
-
我想分散加工大批量。这个想法是使用Spring Batch在云中激发一堆AMQP消费者，然后加载廉价的任务（如项目ID）并将它们提交给AMQP交换。结果的书写将由消费者自己完成。 null
-
11.4 基于ItemReaders的driving query 在readers 和writers章节中对数据库分页进行了讨论,很多数据库厂商,比如DB2,如果读表也需要使用的在线应用程序的其他部分,悲观锁策略,可能会导致问题.此外,打开游标在超大数据集可能导致某些供应商的问题.因此,许多项目更喜欢使用一个’Driving Query’的方式读入数据.这种方法是通过遍历keys,而不是整个对象,
-
我们目前正在将一个复杂的spring boot batch+admin UI系统迁移到一个spring-cloud-task基础设施中，该基础设施将被管理云数据流。 作为POC的第一阶段，我们必须能够将所有Spring批处理作业打包在同一个部署JAR下，并且能够使用自定义作业参数一个接一个地运行它们，并且支持某种REST API远程执行作业/任务。 我们删除了所有spring-batch管理依赖项
-
我正在尝试实现一个Spring批处理作业，为了处理记录，它需要2-3个db调用，这会减慢记录的处理速度（大小为100万）。如果我使用基于块的处理，它会单独处理每条记录，性能会很慢。因此，我需要一次性处理1000条记录，作为批量处理，这将减少数据库调用，并提高性能。但我的问题是，如果我实现Tasklet，那么我也会失去可重启性和重试/跳过功能，如果使用AggregateInputReader实现，我
-
我有以下工作要处理在一定的时间间隔或特别的基础上。 作业中的步骤如下： 我也想要用户界面，在那里我可以触发一个特别的基础上的工作，而且我应该能够提供参数从用户界面。 我想用Spring batch来完成这个任务，但它更多的是用于读->处理->写之类的工作。这里，在第一步中，我正在生成由第二步读取的数据。我不确定我是否还可以使用Spring batch来实现这个，或者有更好的方法来实现这个。
-
我在Spring中设置了几个线性步骤。如果在任何一点上，一个步骤失败了，作业应该失败。 这些步骤包括多个微线程，然后是一个基于块的步骤。即。： 步骤1 任务1 小任务2 读者 处理器 作家 如果出现问题，最明显的做法就是抛出异常。Spring Batch将处理此问题并记录所有内容。这种行为，尤其是打印堆栈跟踪，是不可取的，如果作业可以优雅地结束，并将状态设置为。 Tasklet当前直接在上设置。它