在Apache Camel中附加到具有标头的CSV文件

Question

我需要根据传入的消息构建一个csv文件。为此，我将以下内容附加到文件：

.toD("file://" + OUTPUT_PATH + "?FileName=${exchangeProperty.OUTPUT_FILENAME}" + "&FileExist=Append")

虽然这工作正常，但我遇到了一个问题。我还需要在CSV文件中包含一个标题行。现在我正在使用. mashall（）. csv（）编组成CSV格式，但这省略了标题。

虽然我可以创建一个CSV格式，标题为：

CsvDataFormat csvFormatWithHeader = new CsvDataFormat();
csvFormatWithHeader.setHeader(Arrays.asList(new String[] { "A", "B", "C", "D" }.clone()));

.marshall(csvFormatWithHeader)

这将为我添加的每一行添加标题行。因此，我想要实现的是仅在创建新文件时添加标题。

我尝试了两种方法，但都没有成功：

1. 检查路由中是否存在文件，并相应地应用csv格式

作为最后一个选择，我可以在文件关闭时添加头，但这感觉效率很低，因为我不知道该文件可能会变得多大。

如何使用Apache Camel 2.23.2实现这两种方法之一。

Answer 1

好的，最终使用一个标题，我能够让选项1工作。这就是我现在的路线：

.setProperty("OUTPUT_FILENAME",method(this, "determineOutputFilename()"))
.setHeader("fileExists", method(this, "outputFileExists"))
.choice()
  .when(header("fileExists"))
    .marshal().csv()
  .endChoice()
  .otherwise()
    .marshal(csvFormatWithHeader)
  .endChoice()
.end()

文件检查逻辑是（在route类中实现）：

public boolean outputFileExists(@ExchangeProperty("OUTPUT_FILENAME") String fileName){
    boolean fileExists = new File(PROCESSING_PATH + "/" + fileName).exists();
    return fileExists;
}