如何在 Apache Camel 批处理后移动文件？

Question

我从 Amazon S3 带来一个文件并使用 Spring Batch 处理它，所有这些都与 Apache Camel 集成。

批处理后，消息体不再是文件内容，而是de Job。但我想将文件移动到另一个 s3 存储桶。如何取回文件内容？ （我确实有标题）

（使用 S3 是间接的）

        from("aws-s3://my-bucket...")
            .idempotentConsumer(header("CamelAwsS3Key"),
                  MemoryIdempotentRepository.memoryIdempotentRepository(200))
            .setHeader("CamelFileName", simple("${in.header.CamelAwsS3Key}"))
            .to("file:my-files/")
            .log("Copied from S3.")
            .to("spring-batch:historicoJob")
            .choice()
            .when(simple("${in.body.status} == 'COMPLETED'"))
            .to("direct:moveIt")
            .endChoice();

    from("direct:moveIt")
             ...
            .to("aws-s3://done-bucket...");

Answer 1

您可以访问原始消息（骆驼交换->工作单元上有一些api），或者您可以将消息正文复制到spring批处理之前的交换属性，然后再次恢复。