0

目标是通过使用 Camel 3.0.0 比较两个 CSV 文件，每小时生成一份报告。一个位于 FTP 服务器上，另一个位于磁盘上。如何结合使用轮询丰富模式以及使用 Bindy 数据格式解组磁盘上的 CSV？

示例代码（为简单起见，将 FTP 端点替换为文件端点）：

@Component
public class EnricherRoute extends RouteBuilder {
    @Override
    public void configure() {
        from("file://data?fileName=part_1.csv&scheduler=quartz2&scheduler.cron=0+0+0/1+*+*+?")
            .unmarshal().bindy(BindyType.Csv, Record.class)
            .pollEnrich("file://data?fileName=part_2.csv", new ReportAggregationStrategy())
            .marshal().bindy(BindyType.Csv, Record.class)
            .to("file://reports?fileName=report_${date:now:yyyyMMdd}.csv");

    }
}

这个例子中的问题是在ReportAggregationStrategy（resource来自data/part_2.csv，见下文）中没有解组。如何解组data/part_2.csv？

public class ReportAggregationStrategy implements AggregationStrategy {
    @Override
    public Exchange aggregate(Exchange original, Exchange resource) {
        final List<Record> originalRecords = original.getIn().getBody(List.class);
        final List<Record> resourceRecords = resource.getIn().getBody(List.class); // Results in errors!

        ...
    }
}
4

1 回答 1

2

您可以使用直接端点包装丰富并在那里进行解组。

from("file://data?fileName=part_1.csv&scheduler=quartz2&scheduler.cron=0+0+0/1+*+*+?")
    .unmarshal().bindy(BindyType.Csv, Record.class)
    .enrich("direct:enrich_record", new ReportAggregationStrategy())
    .marshal().bindy(BindyType.Csv, Record.class)
    .to("file://reports?fileName=report_${date:now:yyyyMMdd}.csv");

from("direct:enrich_record")
    .pollEnrich("file://data?fileName=part_2.csv")
    .unmarshal().bindy(BindyType.Csv, Record.class);
于 2020-01-05T23:17:03.877 回答