问题标签 [itemwriter]

我有一个弹簧批处理，它将读取 CSV 文件，然后处理并将其写入另一个 CSV 文件。我想根据处理结果将结果写入两个不同的平面文件。需要将处理成功的记录写入一个文件，失败的记录写入另一个文件。

我看到几个使用“CompositeItemWriter”的例子，但没有多个“FlatfileItemWriters”的确切例子。

任何人，请分享我的用例的示例？

我已经ResourceAware在我的域对象中实现了在使用MultiResourceItemReader. 我成功地检索到处理器中的资源名称。但是，我无法访问其中的资源名称，FlatFileItemWriter因为在使用ClassifierCompositeItemWriter. 任何帮助将非常感激。

配置

作家

处理对文件的写入回滚的逻辑是否可行？

据我了解， BufferWriter 仅在调用 .close() 或 .flush() 时写入。

我想知道发生错误时是否可以回滚写入或撤消对文件的任何更改？这意味着 BufferWriter 充当临时存储来存储对文件所做的更改。

我可以使用单个ItemReader和多个子步骤编写 Spring Batch 步骤，每个子步骤都有一个ItemProcessor后跟一个ItemWriter吗？

我正在尝试实现这样的目标：

补充笔记

• 为避免不一致，我不希望将项目阅读两次。
• 第二个ItemProcessor需要过滤掉一些项目，这些项目应该由第一个编写ItemWriter，而不是由第二个编写。

我相信这个问题与Spring Batch 不同：一个阅读器，多个处理器和编写器，因为我需要按顺序处理项目，而不是并行处理。

我们需要从目录中读取数据，并且需要根据每行中存在的字段（实体类型）在不同的目标目录中过滤和写入数据。支持的 entityTypes 的值是可配置的。我已经使用 ClassifierCompositeItemwriter 构建了一个解决方案。问题是，在这种情况下，我需要在 spring config 中预先定义所有编写器，并将它们注册为流。现在将来，如果我们需要支持任何新的实体类型，我们需要根据需要更改代码，为实体类型定义一个新的编写器，并将其注册为步骤上的流。

有什么办法，我们可以在运行时根据配置的值实例化项目编写器并将它们注册为流？

我的 Step 执行上下文包含： "writer.unclosedHeaderCallbackElements":["java.util.LinkedList",[["javax.xml.namespace.QName","{someURI}SomeObject"],["javax.xml.namespace.QName ","{someURI}SomeObject"

反序列化时出现以下错误：

我应该做任何配置来防止它吗？

是否可以在 Spring 批处理项目中使用 RestAPI (REST TEMPLATE) 从 DB 中读取数据，对其进行处理并在 ItemWriter 中发送到另一个系统？我所能看到的只是获取数据并将其写入 csv 文件。

我用的是弹簧批。

当项目出错时，在实现跳过侦听器的类中，我将写入带有页眉和页脚的文件 *.REJECTED。

对于其他没有错误的项目，在 itemWriter 上，我使用页眉和页脚写入文件 *.OK。

但是在处理过程中，当一个项目被跳过时，文件*.OK中不会写入任何标题。

如果没有跳过，则标头存在于文件 *.OK 中。

你有解释吗？

谢谢

例如

有一个 csv 文件，它有 20 列 id,name,....

我希望将前 10 列数据写入一个表中，就像其他 10 列数据在不同表中一样

如何在 Spring Batch 中使用 ItemReader、ItemWriter 来实现这一点

我有一个使用分区器的 Spring Batch 进程。
作为其中的一部分，我对每个分区都有一个步骤过程，并且分区与 itemreader 的不同输入并行运行。在 ItemWriter 部分的步骤中，我将数据连同标题一起写入 CSV 文件。在将数据写入 CSV 文件的过程中，ItemWriter 中定义的标头会两次写入文件，并且这种行为并非一直发生。这是我的 ItemWriter 代码：

我应该怎么做才能防止 ItemWriter 两次写入标题？提前致谢！