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

在csv中使用Spring批处理在标题之前添加行

殳俊
2023-03-14

在使用Spring批处理实现标题之前,我必须在CSV文件中添加一行免责声明。例如,下面是我预期的CSV文件:

免责声明XYZ。。。Col1 Col2 Col3 abc efg pqr

目前,我正在使用FlatFileItemWriter和FlatFileHeaderCallBack创建CSV文件,并在其中写入标题及其相应的值。

但我不能添加免责声明,然后按照上面显示的标题。

下面是我的代码一瞥:

stepWriter.setHeaderCallback(new FlatFileHeaderCallback()
    public void writeHeader(Writer writer) throws IOException{`
    writer.write(disclaimer);
    writer.write(“Col1”, “Col2”,”Col3”);
    }
});

但根据上述代码,实际的CSV如下所示:

免责声明XYZ Col1 Col2 Col3

共有1个答案

诸葛雅达
2023-03-14

根据您的描述,免责声明XYZ是我的标题的一部分,因此我会保持简单,并将标题回调更新为如下内容:

stepWriter.setHeaderCallback(new FlatFileHeaderCallback() {
    @Override
    public void writeHeader(Writer writer) throws IOException {
        writer.write("Disclaimer-XYZ");
        writer.write(System.lineSeparator());
        writer.write("Col1 Col2 Col3");
    }
})

这应该打印:

Disclaimer-XYZ
Col1 Col2 Col3
...
 类似资料:
  • 问题内容: 如何在csv中编写多头标头,以便第二个标头值应来自数据库 //预期的输出 //以下是用于弹簧批处理写入csv的代码段 问题答案: 您可以在中执行查询,并将结果附加到标题的第一行。

  • 问题内容: 我有一个带有1000个json对象的json文件。有什么办法可以在每个json文档之前添加标题行?有没有最简单的方法? 示例:我有1000个这样的对象 我想为每个json对象添加如下所示的索引标头,以便可以在Elasticsearch Bulk api中使用 问题答案: 如果您愿意利用Logstash,则无需修改文件,而可以简单地逐行读取文件,并使用利用Bulk API 的输出将其流式

  • 几个月前,我用Spring Batch制作了一个项目。 该项目工作正常,包括JobExecution决策器的实现 这使fini仅与Spring Batch配合使用。 现在我必须将其用于Spring Boot批处理。在决策步骤之前,所有流程都运行良好。其中,我返回了良好的FlowExecutionStatus,但我不知道为什么,作业以“失败”状态完成。 有人知道为什么不工作了? 谢谢

  • 我刚刚意识到,一旦在 Kafka 主题上收到的消息会丢失标题。有没有办法在将消息发布到 Kafka 主题然后在消费者处阅读之前向消息添加标头?我正在使用Java 11,Spring Cloud Hoxton.SR6,Spring 2.2.4,kafka_2.13-2.6.0。提前感谢!

  • 我有一些火花代码来处理csv文件。它对其进行一些转换。我现在想将此RDD保存为csv文件并添加一个标头。此RDD的每一行都已正确格式化。 我不知道怎么做。我想用头字符串和我的RDD进行联合,但头字符串不是RDD,因此无法工作。

  • 我正在使用Spring Batch Admin从我的主项目的批处理模块中启动批处理。 在Spring batch Admin项目的依赖项中,将批处理模块编译为JAR addedstrong文本,如下所示: 因为我在一个reader类上添加了“@stepscope”,所以在部署Spring Batch Admin时,我会遇到以下错误 但是我没有找到如何使用类似的声明来防止Spring Batch A