Spring Batch:使用ExcecutionContext传递步骤属性
Spring Batch是一个轻量级的批处理框架，用于开发和执行大规模、高性能的批处理应用程序。它提供了一种简单而强大的方式来处理大量数据，例如批量导入/导出数据、定时任务、数据清洗和转换等。
在Spring Batch中，可以使用ExecutionContext来传递步骤属性。ExecutionContext是一个键值对的集合，用于在批处理的不同步骤之间传递数据。它可以存储和检索任意类型的对象，并且在整个批处理作业的生命周期内都是可用的。
使用ExecutionContext传递步骤属性的主要步骤如下：
- 在Job配置文件中定义StepScope，以便在步骤级别启用ExecutionContext的使用。
<bean class="org.springframework.batch.core.scope.StepScope" />- 在Step中使用@StepScope注解，将步骤属性注入到任务的执行上下文中。
@Bean
@StepScope
public ItemReader<MyObject> itemReader(@Value("#{stepExecutionContext['propertyName']}") String propertyValue) {
// 创建并配置ItemReader
}- 在任务的执行过程中，可以使用StepExecution对象来访问和修改ExecutionContext中的属性。
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) {
StepExecution stepExecution = chunkContext.getStepContext().getStepExecution();
ExecutionContext stepExecutionContext = stepExecution.getExecutionContext();
// 设置属性
stepExecutionContext.put("propertyName", propertyValue);
// 获取属性
String propertyValue = (String) stepExecutionContext.get("propertyName");
// 执行任务逻辑
// ...
return RepeatStatus.FINISHED;
}通过使用ExecutionContext传递步骤属性，可以在批处理的不同步骤之间共享数据，并且可以在任务执行期间动态地修改这些属性。这为开发人员提供了更大的灵活性和控制力，使得批处理应用程序更易于开发和维护。
推荐的腾讯云相关产品：腾讯云批量计算（BatchCompute），它是腾讯云提供的一种高性能、高可靠、弹性扩展的批量计算服务。您可以通过访问以下链接了解更多信息：腾讯云批量计算产品介绍。
相关·内容
2回答
stepExecution在春季批处理中的应用
java、spring
我正在尝试使用stepExecution在Spring批处理中保留数据。但是，当我试图在代码执行中使用它时，我遇到了一些问题：
ExecutionContext stepContext = this.stepExecution.getExecutionContext();
当我累的时候，stepExecution被认不出来了。我导入了org.springframework.batch.core.StepExecution并尝试了：
ExecutionContext context = StepExecution.getJobExecution().getExecutionContext();
浏览 5提问于2015-09-21得票数 1
回答已采纳
1回答
将JobParameters和ExecutionContext传递给@Bean Tasklet？
spring、spring-boot、spring-batch
我正在将基于Spring批处理XML的应用程序转换为Spring注释。在我的XML文件中，我不确定如何将这些jobParameters和执行上下文传递给tasklet？
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:batch="http://www.springframework.org/schema/batch" xmlns:jdbc="http://www.springframework.org/schema/jdbc"
xmlns:x
浏览 0提问于2018-08-11得票数 1
回答已采纳
1回答
将失败的步骤添加到执行上下文的步骤监听器
spring、spring-batch、listener
我想知道是否有一种方法可以使用afterStep并创建一个步骤执行侦听器来检查作业中任何失败的步骤，并将该步骤名称和退出状态添加到执行上下文中。 虽然我的作业中的一个步骤失败了，但我们返回RepeatStatus.FINISHED。我创建了一个电子邮件报告，并希望包括失败的步骤名称和状态。这是我的电子邮件任务 public class SendEmailTasklet implements Tasklet {
final static Logger LOGGER = LoggerFactory.getLogger(SendEmailTasklet.class);
@Aut
浏览 21提问于2019-04-17得票数 0
回答已采纳
3回答
春季批处理中各步骤之间的数据交换
spring-batch
我有一个由以下组件构建的作业
处理步骤-激活外部处理，将其结果记录在DB中并返回一个内部id，这样我就可以获取这个id并进一步处理它
日志步骤-由一个包含一个块的tasklet构建的
这个块是由一个项目读取器构建的，我计划使用#{stepExecutionContext'job.id'}作为xml文件中写入的sql的一部分，这样它就可以获得相关的日志信息。
我正在尝试使用这里建议的解决方案- ，但是当我试图在步骤执行上下文或作业执行上下文上添加一个属性时，会出现这个错误。
chunkContext.getStepContext().getStepExecutio
浏览 11提问于2014-06-05得票数 1
回答已采纳
3回答
在Spring中的步骤之间传递信息？
java、spring、spring-batch
我正在尝试创建一个Spring批处理，但我没有使用它的经验。
是否可以从每个批处理步骤传递信息，或者它们必须是完全独立的？
例如，如果我有
<batch:step id="getSQLs" next="runSQLs">
<batch:tasklet transaction-manager="TransactionManager"
ref="runGetSQLs" />
</batch:step>
<batch:step id
浏览 0提问于2015-09-18得票数 9
回答已采纳
1回答
Spring-Batch:测试自定义itemReader
java、junit、spring-batch
我正在尝试测试我的自定义itemReader：
@Bean
@StepScope
MyMultiLineItemReader itemReader(@Value("#{stepExecutionContext['fileName']}") String filename) throws MalformedURLException {
MyMultiLineItemReader itemReader = new MyMultiLineItemReader();
itemReader.setDelegate(myFlatFileItemReader(filename
浏览 4提问于2020-02-18得票数 2
回答已采纳
2回答
如何在春季批次中计算袋中的项目？
java、spring、spring-batch
我有一个Tasklet，想要计算已处理的项目。然后，一个普通的StepExecutionListener应该能够在afterStep()中读取那些已处理的项计数。
@Bean
public Step myStep() {
return stepBuilderFactory.get("Step2")
.tasklet(new Tasklet() {
@Override
public RepeatStatus execute(StepContribution contribution,
浏览 3提问于2016-02-05得票数 1
2回答
如何从春季批处理步骤返回自定义RepeatStatus
java、spring、spring-boot、spring-batch
Step类: GenerateReferenceNumber
package com.npst.imps.action;
import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
imp
浏览 3提问于2017-11-04得票数 1
回答已采纳
3回答
将Spring失败消息传递到报告步骤。
java、spring、spring-boot、spring-batch
我使用带有OpenCSV的Spring批处理Tasklet读取我的CSV文件。在提出问题之前，我知道块，但是在后面的步骤中文件之间存在交叉验证，所以我必须继续使用Tasklet。
我要做的是向我的报告步骤报告一个丢失的文件或解析错误。我不知道该怎么做才能把失败报告给我下一步。我有下面的代码。
读取文件的初始步骤.
public class CsvBatchReader<T> implements Tasklet, StepExecutionListener {
private final Logger logger = LoggerFactory.getLogger(Cs
浏览 2提问于2018-09-19得票数 1
回答已采纳
1回答
如何从从步骤处理读取器的FlatFileParseException
spring-boot、spring-batch、spring-annotations
我有弹簧批作业申请，它解析了许多包含用户详细信息的csv文件。为了解析用户详细信息，我有一个从csv文件解析的LineMapper。
因此，首先主步骤读取器从位置读取所有文件，然后使用分区程序，我有从步骤。所有从级步骤并行执行。这些从步骤逐行解析每个文件的用户详细信息。处理后，它将已处理的文件移动到已处理的文件夹。
在测试期间，我在一个文件中保留了一些错误的值，这会导致从步骤的读取器产生FlatFileParseException。在这里，我想把这个文件移到另一个文件夹，比如失败的文件夹。但我做不到。
如果任何从步骤读取器不能解析，我应该如何将文件写入失败的文件夹？
我正在使用Spring，基
浏览 1提问于2018-03-29得票数 1
回答已采纳
2回答
@BeforeStep注释方法未被调用
spring-batch
我正在编写一个spring batch作业。但是当这个实现微线程接口的Archive类加载时，注释@BeforeStep下的方法不会被调用。有人能帮我吗？谢谢
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.StandardCopyOption;
import java.util.Calendar;
import jav
浏览 0提问于2015-04-29得票数 7
回答已采纳
1回答
关于Spring Batch中的executionContexts的困惑
spring、spring-batch
Spring batch中的executionContext到底是什么？得到它的句柄允许我们做什么？这似乎是对术语executionContext的过载使用。下面的两个“上下文”有什么不同？其中一个有jobParameters，另一个只获取执行上下文。但是第一个从StepExecution而不是job获得jobParameters。这让我很困惑。有多少种不同类型的执行上下文？
chunkContext.getStepContext()
.getStepExecution().getJobParameters()
chunkContext.get
浏览 0提问于2014-02-07得票数 6
回答已采纳
1回答
使用jobParameters返回null在任务和步骤之间传递param
spring、spring-batch、spring-batch-admin
我定义了简单的工作。任务，然后开始。
我正试着在这两者之间通过filePath。
当我到达茎时，会调用读取器，在那里，filePath仍然是空的。
我遗漏了什么？
职务配置：
@Bean
public Job processFileJob() throws Exception {
return this.jobs.get("processFileJob").start(downloadFileStep()).next(processor()).build();//.next(pushToKafkaStep()).build();
}
浏览 2提问于2015-01-19得票数 0
回答已采纳
2回答
ItemReader集成测试抛出ClassCastException
spring-boot、java-8、integration-testing、spring-batch
我正在尝试集成测试一个ItemReader --这是一个类：
@Slf4j
public class StudioReader implements ItemReader<List<Studio>> {
@Setter private zoneDao zoneDao;
@Getter @Setter private BatchContext context;
private AreaApi areaApi = new AreaApi();
public List<Studio> read() throws Exception
浏览 0提问于2017-04-04得票数 0
1回答
用Mockito创建块Tasklet单元测试
java、unit-testing、mockito、spring-batch
我有一个Chunk Tasklet，有一个读者和作者，我试图为它做一个单元测试，但我面临多重问题。
我使用以下问题的答案来帮助创建我的单元测试：
这似乎是最接近，我想做的。
@ContextConfiguration(locations = { "classpath:config/beans-unittest-service.xml",
"classpath:config/beans-unittest-item.xml" })
@RunWith(SpringJUnit4ClassRunner.class)
public class KpiMet
浏览 0提问于2019-08-29得票数 1
回答已采纳
1回答
从ExecutionContext获取参数
java、parameters、spring-batch
我有一个使用web参数执行的spring批处理作业，如：
https://localhost:8443/batch/async/orz003A?id=123&name=test
我已经将这些参数，id和test添加到了我的ExecutionContext中
在我的安装程序Tasklet中，我很难访问它们，如下所示。
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ExecutionContext;
import org.springframewo
浏览 0提问于2018-09-21得票数 0
回答已采纳
2回答
如何在春季批处理任务中更新项目计数？
java、spring、spring-batch
我想创建一个通用的StepExecutionListener。它应该记录由Tasklet步骤处理的项计数。
问题:计数不会自动更新。所以我可能必须在Tasklet.execute()的某个地方做这件事。但是怎么做呢？
@Bean
@JobScope
public Tasklet myTasklet() {
return new Tasklet() {
@Override
public RepeatStatus execute(StepContribution contribution, ChunkConte
浏览 5提问于2016-10-06得票数 2
回答已采纳
1回答
早期检测到AsyncListItemWriter步长端
java、spring、spring-batch
我编写了一个异步版本的ItemWriter来异步地编写项目：
public class AsyncListItemWriter<T> implements ItemStreamWriter<T>, InitializingBean {
private ItemWriter<T> delegate;
private TaskExecutor taskExecutor = new SyncTaskExecutor();
public void afterPropertiesSet() throws Exception {
浏览 1提问于2021-03-16得票数 1
回答已采纳
1回答
在执行作业中检测到重复步骤
java、spring、spring-batch
因此，我创建了一个示例批处理运行，以学习如何使作业自身重复，直到满足条件。在大多数情况下，它按预期工作，但在执行程序时，我将得到以下日志条目
org.springframework.batch.core.job.SimpleStepHandler:重复步骤getStartingStep在job=infinateLoopJob的执行中检测到。如果这两个步骤都失败，则在重新启动时将再次执行这两个步骤。
虽然其他开发人员告诉我，这没什么大不了的，但是当我想依靠这些知识编写产品代码的时候，我宁愿做好这件事，也不要让任何奇怪的事情发生。我试图将时间戳生成添加到步骤的名称中，但是没有运气(它只在步骤初始创
浏览 0提问于2017-05-09得票数 2
回答已采纳
2回答
无法在Spring批处理中将JobParameters值传递给微线程
spring、spring-batch、spring-batch-tasklet
我已经遵循了链接：，但在将jobParameters值传递给tasklet时仍然面临问题。
我开发了如下代码：
JobConfiguration.java
@Component
public class JobConfiguration implements ApplicationContextAware{
@Autowired
private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Autowir
浏览 0提问于2018-12-13得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频活动推荐
腾讯云开发者
