如何使用Camel和Hazelcast将文件从SFTP发送到S3？

Question

from(source)
    .pollEnrich(source)
    .log("Uploading file ${file:name} started...")
    .setHeader(S3Constants.CONTENT_LENGTH, simple("${in.header.CamelFileLength}"))
    .setHeader(S3Constants.KEY, simple("${in.header.CamelFileNameOnly}"))
    .toF("hazelcast:%sfoo", HazelcastConstants.SEDA_PREFIX);

fromF("hazelcast:%sfoo", HazelcastConstants.SEDA_PREFIX)
     .idempotentConsumer(simple("*"), hazelcastIdempotentRepo)
     .setHeader(HazelcastConstants.OBJECT_ID, simple("${exchangeId}"))
     .setHeader(HazelcastConstants.OPERATION, constant(HazelcastConstants.PUT_OPERATION))
     //.setHeader(S3Constants.CONTENT_LENGTH, simple("${in.header.CamelAwsS3ContentLength}"))
     .setHeader(S3Constants.KEY, header(S3Constants.KEY))  // How to get file name here ??
     .toF(destination)
     .log("Uploading file ${file:name} completed...");

java.lang.IllegalArgumentException: AWS S3 Key header missing.

.setHeader(S3Constants.KEY, simple("${in.header.CamelFileNameOnly}"))

.setHeader(S3Constants.KEY, constant("test.txt"))

如何从Hazelcast队列中获取文件名头？

Answer 1

有关文件语言，请参阅Camel文档

http://camel.apache.org/file-language.html

使用simple language（http://camel.apache.org/simple.html）使用${file:onlyname}获取extn中唯一的name部分