Spring Batch Mongo DB to .csv to email
Spring Batch是一个开源框架，用于在Java平台上构建可扩展的、批处理式的应用程序。它通过提供一种高效、可重复和可靠的方式来处理大规模数据和复杂的业务逻辑。
MongoDB是一个面向文档的NoSQL数据库，它以灵活的数据模型和可扩展性而闻名。它支持复杂的查询和索引，适用于处理大量数据和大规模应用。
将Spring Batch与MongoDB集成，可以使用Spring Data MongoDB提供的API，从MongoDB数据库中读取数据并进行批处理操作。Spring Batch提供了一个模块化的结构，可以定义读取器（ItemReader）、处理器（ItemProcessor）和写入器（ItemWriter）来执行特定的业务逻辑。
将数据从MongoDB导出为.csv文件可以使用Spring Batch提供的FlatFileItemWriter，该写入器可以将数据逐行写入.csv文件中。可以根据具体需求定义csv文件的格式和字段分隔符等。
发送邮件可以使用JavaMail API来实现，Spring Batch提供了EmailItemWriter来简化邮件发送的过程。可以配置收件人、发件人、主题和正文等信息，并在需要的时候附加.csv文件作为附件。
以下是一个完整的Spring Batch Mongo DB to .csv to email的示例：
- Spring Batch读取MongoDB数据：
- 使用Spring Data MongoDB连接MongoDB数据库，参考链接：https://spring.io/projects/spring-data-mongodb
- 定义MongoItemReader来读取MongoDB数据，参考链接：https://docs.spring.io/spring-batch/docs/current/api/org/springframework/batch/item/data/MongoItemReader.html
- Spring Batch将数据写入.csv文件：
- 定义FlatFileItemWriter来将数据逐行写入.csv文件，参考链接：https://docs.spring.io/spring-batch/docs/current/api/org/springframework/batch/item/file/FlatFileItemWriter.html
- 发送带有.csv附件的邮件：
- 使用JavaMail API发送邮件，参考链接：https://javaee.github.io/javamail/
- 配置EmailItemWriter发送带有附件的邮件，参考链接：https://docs.spring.io/spring-batch/docs/current/api/org/springframework/batch/item/mail/EmailItemWriter.html
通过将这些步骤结合起来，可以构建一个完整的Spring Batch Mongo DB to .csv to email的应用程序。它可以定期从MongoDB中读取数据，将数据导出为.csv文件，并发送包含该文件作为附件的邮件。这在需要批量处理数据并将结果通过邮件发送的场景中非常有用。
相关·内容
我需要定期读取mongo DB表数据，并使用spring boot将其发布到Kafka主题中。我在Mongo DB中创建了一个集合，并在Mongo DB中插入了一些记录。此外，我希望定期从Mongo DB读取数据，并需要使用spring boot在Kafka的主题中发布这些表数据。我是spring batch scheduler的新手。你能给我一个实现这一目标的想法吗？ 提前谢谢。
浏览 22提问于2020-10-02得票数 0
1回答
我正在使用spring batch framework在mongo db中处理大量数据，并再次存储在mongo db中。
代码如下：
Aggregation agg = newAggregation(
project("field1")
//projection on few fields
group("field1")
//gro
浏览 2提问于2016-05-13得票数 0
在Mongodb中，在插入少量数据后，插入变慢了，我使用batch_insert进行插入。在插入时，我还需要检查一些条件。
插入20k数据本身需要超过1个小时。
在temporary_table中，我有1L数据
$batchSize = 20;
$documents = array();
$count = count($pending_contacts_data);
$count =1;
$temporary_data = array();
for($i=0;$i<$count;$i++){
$multiple_temporary_data = $this->mongo_d
浏览 12提问于2017-08-21得票数 1
回答已采纳
我正在开发Spring Batch XML to MongoDB示例。在本例中，我无法将Date和BigDecimal值保存到MongoDB中。
Report.java
@XmlRootElement(name="report")
@XmlAccessorOrder(XmlAccessOrder.UNDEFINED)
public class Report implements Serializable{
private static final long serialVersionUID = 1L;
private int id;
private D
浏览 5提问于2016-04-04得票数 0
回答已采纳
1回答
我正在上运行示例，因为它没有改变任何东西，但是当我试图运行该项目时，我将得到以下输出。而且，MongoDB没有显示任何集合。请尽快告诉我这里出了什么问题。
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exit
浏览 2提问于2015-06-26得票数 2
我试图检查item ['email']是否已经存在于数据库中，如果它不存在，那么插入到pymongo数据库中。
我不想在pymongo数据库中重复电子邮件。
不管我怎么理解
ValueError:字典更新序列元素#0的长度为17；2是必需的
到目前为止，这就是我所拥有的
Pipelines.py
class myExporter(object):
def __init__(self):
i = 0
while os.path.exists(SRCFILE % i):
i += 1
self
浏览 0提问于2018-03-30得票数 1
我正在处理spring batch，它从一个位置读取csv文件中的记录并保存到mongo DB中。我想读取特定对象类型的记录，但在写入时应该使用不同的对象类型。例如，如果我使用obj1读取文件，那么我希望将obj1设置为obj2并保存到DB。下面是我的代码。 @Bean
public Job readCSVFileJob() {
return jobBuilderFactory
.get("readCSVFileJob")
.incrementer(new RunIdIncrementer
浏览 28提问于2020-07-19得票数 0
这是我的问题陈述， -Step 1:调用mongo db并获取当天的所有文档(基本上是一个请求)。 MongoDB2:对于上面的每个文档，对不同的-Step进行另一个调用，最终获取大约70k个文档。 -Step 3:然后对上面的70k文档(某些字段)进行分块处理，创建一个.csv文件。 -Step 4:然后此.csv文件将存储在驱动器中，位置信息将通过电子邮件发送给用户。 -Step 5:对步骤1中的每个文档重复步骤2到4。 为了实现这一点，我正在探索Spring Batch选项(更乐观的性能)，但不能弄清楚该如何做。任何专业建议/指导都会更有帮助。 谢谢,
浏览 12提问于2020-07-22得票数 0
回答已采纳
1回答
背景:我们正在构建一个应用程序MuleSoft，作为需求的一部分，我们必须编写大量记录(约.30K)转换为csv文件。在此之前，我们需要从DB2中提取XML形式的数据。然后我们应用一些转换/映射规则，最后我们将数据写入csv文件并通过FTP传输csv文件。我正在附加XML。
问题:在仅处理了大约2500-2600条记录后，进程在某处挂起。它不会抛出任何错误。它只是停留在那里，它不会做任何事情。我们尝试了像1这样的选项。将流作为mule批处理流的一部分。没有观察到差异2.设置max error count = -1，因为我们在博客的某个地方找到了这个
如果有人能提供任何建议，那将是非常有帮助的。
浏览 2提问于2016-10-25得票数 0
在Spring 项目中，我得到了下面的错误，不知道这里发生了什么？
我只是从mysql读取表并使用FlatFileItemWriter将其写入文件。还可以使用分区器读取代码并将其写入平面文件。Spring Boot Parent版本2.0.2.RELEASE.
org.springframework.batch.item.ItemStreamException: File is not writable: [C:\Spring_Learning\spring-batch\spring-batch-classic-db\csv\outputs\users.processed201-250.csv
浏览 0提问于2018-07-11得票数 2
回答已采纳
1回答
我使用以下代码以csv格式转储一个sql文件：$file_path = "/tmp/app_users.csv"；
$sql = "SELECT 'id','username','name','email',
'phone_number','city',
'batch_code','course_type' UNION ALL
SELECT id, username, name, emai
浏览 2提问于2013-08-04得票数 3
回答已采纳
1回答
我们正在开发一个使用Java和Spring Batch的应用程序，目前使用的是MySQL数据库。但很快我们就会使用Oracle和Mongo DB。这是我可以使用的设计模式或最佳方法，以防我需要在不同的数据库之间切换而不做太多的代码更改。
浏览 19提问于2020-06-17得票数 1
回答已采纳
我正在开发Spring Batch Example – XML File To MongoDB Database。我开发了所有必需的代码，但当尝试运行主代码时，它失败了，不确定为什么？任何帮助都是非常感谢的。我正在使用mongodb version 3.0.6。
代码参考：
可供参考的错误：
org.springframework.dao.OptimisticLockingFailureException: Attempt to update step execution id=1 with wrong version (1), where current version is 2
a
浏览 1提问于2016-03-13得票数 2
1回答
我正在使用触发一个云函数，该函数将上传的CSV写入Cloud。问题是csv文件的数量超过了8000 rows，而且函数对9mins的最大超时是不够的。
Error: 4 DEADLINE_EXCEEDED: Deadline exceeded
我也尝试过批处理操作，但仍然存在相同的超时问题。，我是否可以在不涉及太多重新架构的情况下使用另一种解决方案？
const {Datastore} = require('@google-cloud/datastore');
const {Storage} = require('@google-cloud/storage');
浏览 5提问于2020-08-06得票数 0
我遇到了这个奇怪的问题，我尝试了很多不同的建议在这里找到，但最终没有任何效果。
总之:我有一个Spring应用程序，它使用mongodb数据库。我想启动应用程序和数据库使用坞-撰写，但应用程序没有启动。
Dockerfile
FROM openjdk:14-alpine
VOLUME /tmp
EXPOSE 8080
ADD target/batch-jobs-0.0.1-SNAPSHOT.jar batch-jobs.jar
ENTRYPOINT ["java","-Dspring.data.mongodb.uri=mongodb://docker_mongo:
浏览 4提问于2021-03-23得票数 1
我需要开发一个应用程序来使用Spring Batch执行以下活动。从数据库读取数据-->处理数据并准备rest API请求-->写入或发布到第三方restful服务。
我已经看到了很多从数据库读取写入CSV、DB、JMS的示例。但我找不到任何写入web服务的选项。是否可以使用spring batch或建议其他技术来执行此活动。
浏览 0提问于2017-05-27得票数 0
我需要知道从多个数据库访问存储库和实体类的简单步骤。示例:我的用户表位于DB1中，Email在DB2中必须从单个服务请求中访问。
DB 1
spring.datasource.url = jdbc:mysql://localhost:3306/dbName1?useSSL=false
spring.datasource.username = user
spring.datasource.password = password
spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5InnoDBDialect
s
浏览 0提问于2018-09-11得票数 2
回答已采纳
这是我的场景..
我需要读取csv文件并将输出存储到ElasticSearch。我正在使用Spring Batch读取csv文件。谁能给我举个例子，如何使用Spring Batch或Spring Batch扩展在elasticsearch中保存？
浏览 1提问于2016-02-28得票数 3
我想用profile.email更新所有集合字段emails..address，如下所示：
update dbo.users
set profile.email=emials.[0].address
我知道这个愚蠢的代码也不能在SQL上工作。只是为了让它对我所需要的有意义。
它是这样的，但不起作用：
db.getCollection('users').update(
{_id: "QYoHQkTuTXnEC6Pws"},
{$set:
{'profile.email': db.getCollection(&
浏览 1提问于2017-04-27得票数 1
回答已采纳
我试图在mongoexport的查询字段中使用一个正则表达式，这样我就可以限制那些不是测试电子邮件来运行测试用户、电子邮件、密码和apiKey的测试邮件的字段。
我用了一个发现
db.users.find({email:/@company.com/},{apiKey:1,email:1}).pretty()
这只检索了我想要的记录，但如下所示：
mongoexport -d db_dev -c users -f apiKey,email -q "{{email:{/@company.com/}}}" --csv -o usersKeys.csv
似乎不适合我。有什么指示吗？我在
浏览 2提问于2014-07-23得票数 1
回答已采纳
我需要读取DB2数据库，并使用Spring Batch将数据复制到mongoDB。因为我要将数据写入mongoDB，所以我不需要事务。我只想将元数据表脚本保存在mongoDB中，而不是DB2中，但是我找不到mongoDB的元数据表脚本。在服务器启动时，spring boot将batch_job_instance表放在Db2中，而不是mongoDB中。我将mongoDB注释为主代码，但它仍然抛出错误。
有人能帮我这个忙。提前谢谢。
MongoConfig.java：
@Configuration
@EnableMongoRepositories("com.test.mongodb"
浏览 0提问于2017-12-01得票数 0
回答已采纳
我正在尝试对以下内容进行批量更新
mongoimport -d my_db -c db_collection -upsertFields email ~/Desktop/update_list.csv
我尝试导入的csv如下所示。
email, full_name
stack@overflow.com,stackoverflow
mongo@db.com,mongodb
它应该检查电子邮件列作为查询参数，并相应地更新全名。但是，没有一个被导入，它遇到了错误。
exception:Failure parsing JSON string near: abc@sa
abc@sasa.com,abc
浏览 1提问于2011-02-07得票数 6
我使用Spring Data Mongo和简单的mongo查询来获取活动状态部门的列表。
当我使用下面的查询时，它仍然会提取InActive记录。
db.getCollection('employee').find({"departments.status" : "A"})
样本数据-
{
"firstName" : "Sichita",
"lastName" : "Vinchurkar",
"email" : "svinchurkar
浏览 1提问于2020-04-02得票数 0
回答已采纳
我正在开发Spring Batch - MongoDB to XML示例。当我运行我的主程序时，我已经成功地开发了代码。我看到下面的错误出现了。我不知道到底出了什么问题。我跟踪了许多链接，但我不认为它不工作良好。
org.springframework.dao.DataAccessResourceFailureException: Unable to write to file resource: [class path resource [report.xml]]; nested exception is java.io.FileNotFoundException: class path r
浏览 0提问于2017-01-08得票数 1
1回答
这里的文档使用jdbc模板。
我想问一下如何使用MongoDB编写与Spring集成的测试？最好，如果你们能给我一个具体的例子。
我使用这些依赖项作为您的信息。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
浏览 1提问于2021-02-07得票数 0
回答已采纳
我是Mongodb的新手。当我尝试mongoimport时，我得到了下面的错误。
我把文件放在c:\mongo\data\db\mongo.csv里了..。有人能帮帮我吗？
C:\mongodb\bin>mongoimport.exe -d test -c foo --file c:\mongo\data\db\mongo.csv --type csv
connected to: 127.0.0.1
file doesn't exist: c:\mongo\data\db\mongo.csv
浏览 0提问于2012-10-09得票数 0
我有一个简单的批处理应用程序，将csv读入postgres数据库。
我已经在bitbucket中上传了下面的repo代码
https://github.com/soasathish/spring-batch-with-jpa.git
我在使用spring将写入数据库时遇到了问题。我被管理豆找不到.issue。
这个相同的jpa spring数据配置在不同的项目中工作，当我试图与spring集成时，它失败了，而manage没有找到。
批配置有spring作业，只有一个步骤。
1)从csv文件中读取-read。处理器对文件应用了一些规则。Drools请运行schema-postgresql.sql
浏览 3提问于2017-07-17得票数 1
在我的Mule流中，我有一条信息丰富了她的内容，如下所示：
<set-variable doc:name="Variable" value="#[payload['MeterUID']]" variableName="#['theKey']"/>
<enricher target="#[payload]" doc:name="Message Enricher">
<mongo:find-objects-using-query-map config
浏览 2提问于2014-05-26得票数 1
回答已采纳
我使用的是spring boot 1.2.8和Mongo db 2.4.10。我计划将mongo db升级到3.2.0。
因此，对于当前sprinb boot 1.2.8，我在pom中使用，
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
我在依赖层次结构中看到它附带了
浏览 14提问于2016-05-07得票数 5
我在带有Windows 7、64位、4Gb RAM和虚拟内存自动管理的桌面上运行mongo服务器。过了一段时间，我试图向我的数据库中添加另一个条目，我得到了这个错误。我现在无法运行mongo服务器，无法修复数据库等。
2014-05-12T15:11:03.711-0400 [FileAllocator] allocating new datafile C:\mongodb\data\db\dbTestJig.8, filling with zeroes...
2014-05-12T15:11:06.628-0400 [FileAllocator] done allocating datafi
浏览 2提问于2014-05-13得票数 0
回答已采纳
1回答
在不升级spring框架版本的情况下，是否可以将spring data mongo版本升级到2.2。目前我使用的是spring框架3.2版。我需要升级spring data mongo db版本以支持mongo db 4.2 TLS支持。
浏览 102提问于2020-01-03得票数 0
1回答
在Spring Boot中，我尝试使用Spring Batch读取一个包含1000个条目的JSON文件，进行一些处理，然后将输出写入CSV文件。每当我使用TaskExecutor启用multiThreaded步骤时，就会出现此问题。我实现TaskExecutor的代码 @Bean
public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(2);
executor
浏览 20提问于2020-09-17得票数 0
我编写了这个函数来使用Yii框架命令行生成一个CSV文件，现在的问题是我有超过30万行的数据要写入CSV文件中。所以我所做的是，我把每个CSV文件的数据分成10,000个。
public function Targets2($offset,$limit,$batch){
if($offset == ''){
echo 'provied an offset!';
exit;
}
if($limit == ''){
echo 'provide a limit'
浏览 1提问于2014-11-30得票数 2
回答已采纳
有一个包含许多记录的CSV文件，其中CSV标头名称和DB域对象名称不同。如何在Spring Batch中获取CSV数据并创建模型以持久化数据库？下面抛出错误，因为标头和db或jpa名称不同。 例如，employee.csv Employee Id, Employee Name, Employee Address, Employee Address 2, Date Of Birth 域对象Employee.java public string empId;
public string empName;
public string empAddress;
public stri
浏览 16提问于2021-07-31得票数 1
回答已采纳
1回答
我试图在MongoDB中为特定的请求实现缓存策略。
命名空间- xmlns:mongo="http://www.mulesoft.org/schema/mule/mongo"
schemalocation - http://www.mulesoft.org/schema/mule/mongo http://www.mulesoft.org/schema/mule/mongo/current/mule-mongo.xsd
尝试2种方法：
1) i配置了MongoDB连接器。
连接器- <mongo:config name="Mongo_DB" doc:nam
浏览 10提问于2015-12-02得票数 1
1回答
我有Spring mongo db应用程序，当我开始运行这个应用程序时，如果mongo主机还活着，就能够看到我的应用程序已经启动并成功运行，如果我的mongo主机在启动应用程序时关闭了，那么我的应用程序就无法启动。有没有任何方式，甚至认为如果芒果主机停机，我的应用程序应该启动和运行。
有人能帮我一下吗？
在我的应用程序中使用spring mongo属性。
spring.data.mongodb.repositories.enabled=true
spring.data.mongodb.port=27017
spring.data.mongodb.database=db
spring.da
浏览 0提问于2019-02-11得票数 1
我创建了一个spring批处理，用于查询Azure SQL server数据库并将数据写入CSV文件。我没有数据库的create权限。我在运行批处理时得到了这个错误Invalid Object name BATCH_JOB_INSTANCE。我不希望在主数据库中创建春季批处理元数据表。或者，如果我可以将它们放在另一个本地或内存中的数据库(如h2db )中，将是有帮助的。我还添加了spring-batch-initialize-schema=never，这是大多数类似问题的答案，但这并没有帮助。
编辑：
我通过扩展Invalid Object name类和重写setDataSource方法来阻止
浏览 10提问于2020-09-27得票数 1
当使用Spring Batch将数据从csv插入到db时，某些行没有插入两个双引号(默认一个引号，第二个引号连同数据)。csv数据示例：
"1","abc","xyz",""Hyderabad""
或
"1","abc","xyz","\"Hyderabad\""
预期的数据库行：
1 abc xyz "Hyderabad"
这里的City值必须用双引号引起来。
有人能帮上忙吗。
浏览 5提问于2015-12-19得票数 3
1回答
有谁能帮我把这个mongoDB聚合转换成spring呢？
我正试图在每一份邀请文件中获得未提醒与会者的电子邮件列表。
让它在mongo中工作，但需要在Spring数据mongo中这样做。
我的shell查询
db.invitation.aggregate(
[
{ $match : {_id : {$in : [id1,id2,...]}}},
{ $unwind : "$attendees" },
{ $match : { "attendees.reminded" : false}},
{ $project : {_id :
浏览 3提问于2015-09-20得票数 4
回答已采纳
我试图从资源/input/user_*. csv中的多个csv文件中读取数据，并写入资源/output/user.csv中的一个csv文件。
这是我的BatchConfig
@Configuration
@EnableBatchProcessing
public class BatchConfig {
private static final Logger log = LoggerFactory.getLogger(BatchConfig.class);
@Autowired
private StepBuilderFactory stepBuilderFactory
浏览 8提问于2022-08-22得票数 1
我在Heroku服务器上得到了这个错误，但它完全在本地工作。 这是控制器，它从表单中获取CSV文件，并尝试将其存储在资源文件夹中。 @PostMapping(value = "/import-csv")
public ModelAndView uploadCSV(HttpServletRequest request, HttpServletResponse response, @RequestParam("file") MultipartFile multipartFile) throws IOException, JobParametersInval
浏览 42提问于2020-04-02得票数 0
我正在开发Spring Batch - MongoDB to XML示例。在这个例子中，当我运行main方法时，我看到下面的错误正在出现。请指导以下错误。我试图在网络上找到解决方案，但我在网上找不到任何有用的东西。
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'step1': Cannot resolve reference to bean 'mongodbItemRead
浏览 5提问于2017-01-06得票数 1
回答已采纳
1回答
我有以下针对spring框架的mongo db配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
浏览 1提问于2015-08-18得票数 0
1回答
我有一个流，它从目录读取csv文件，拆分行，然后处理每一行并从每一行提取2个对象。然后将这两个对象发送到两个独立的int-mongodb:outbound-channel-adapter。在处理和保存所有行之后，我希望删除传入的文件。我看过使用事务管理器对入站适配器执行此操作的示例，但没有使用出站适配器。有办法这样做吗？
我的配置如下所示：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans
浏览 2提问于2015-06-11得票数 2
回答已采纳
如何在mongo中添加SSL密钥存储和信任存储文件路径和密码:客户端选项使用spring xml连接TLS上的mongo db。还需要知道如何在xml的mongo:client属性中添加ssl允许的无效主机名。我使用的是spring data mongo db 2.2.3。
浏览 6提问于2020-01-07得票数 0
1回答
我正在使用csv批量导入neo4j将一个关系数据库转换为py2neo，这是在中描述的。我是这样组织代码的：
delivery = "Delivery.csv"
graph = Graph("http://localhost:7474/db/data/")
graph.cypher.execute("CREATE CONSTRAINT ON (delivery:Delivery) ASSERT delivery.name IS UNIQUE")
with open(delivery, 'r+') as in_file:
r
浏览 5提问于2015-07-04得票数 2
回答已采纳
我正在创建一个春季批处理应用程序，它从CSV文件中读取并写入DB2数据库。
Spring版本:2.0.5 version
<dependency>
<groupId>com.ibm.db2.jcc</groupId>
<artifactId>db2jcc</artifactId>
<version>db2jcc4</version>
</dependency>
当Spring试图插入到BadSqlGrammarException表时，我得到了一个BATCH_JOB_EXECU
浏览 6提问于2019-11-30得票数 0
1回答
我正在将Spring批处理MongoDB开发为示例。我已经成功地创建了这个项目，但是当我运行它时，我看到下面的错误即将出现，我不知道这里到底出了什么问题。参考误差
Exception in thread "main" org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'step1': Initialization of bean failed; nested exception is org.springframework.beans.Co
浏览 1提问于2017-01-06得票数 1
回答已采纳
当我们在Spring batch中使用singleItemPeekableItemReader来读取CSV时，是否可以使用多线程？
我有一个包含100000条记录的CSV文件，需要使用Spring Batch读取该文件并将其加载到数据库中。我已经为它使用了4个线程。但是现在我有一个需求，那就是根据条件组合行，并一次读取。为此，我使用了Spring Batch的SingleItemPeekableItemReader。但是在这之后我就不能使用多线程了。
如何在SingleItemPeekableItemReader中实现多线程
浏览 0提问于2018-06-11得票数 1
我有一个Spring Boot / Batch应用程序。我想使用一个"app数据目录“(与属性文件不同)，而不是一个基于db的数据存储(即SQL/Mongo)。
存储在应用程序数据目录中的数据是从多个and服务聚合而来的，并存储为XML。Job中的每一步都将获取数据并在本地写入，然后链中的下一步将获取已创建的文件并处理下一步(依此类推)。
这里的问题是，每一步只会获取之前的应用程序运行数据。例如，在应用程序开始时的数据，而不是在步骤执行之后的数据。
我知道这里发生了什么，Spring在启动时检查所有资源，并在步骤实际运行之前按原样使用它们。
在应用启动时请求Spring停止加载指定的资
浏览 2提问于2016-11-28得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
