2017-11-26 1 views
0

Mein DSL start ist so etwas wie diese:Wie S3-Datei lesen nur einmal in Apache Camel

from("aws-s3://" + s3_bucket_name + "?amazonS3Client=#amazonS3Client&deleteAfterRead=false&fileName=myfile.csv")

danach ich jede Zeile in eine JSON-Datei verdeckte und Dump in ein lokales Verzeichnis.

Das Problem ist, dass es so weitergeht wie in einer Endlosschleife.

Irgendeine Idee, wie ich die Datei nur einmal verarbeiten und dann aufhören?

Antwort

0

können Sie Idempotent Consumer

from("aws-s3://" + s3_bucket_name + "?amazonS3Client=#amazonS3Client&deleteAfterRead=false&fileName=myfile.csv") 
.idempotentConsumer(header("CamelAwsS3Key"), idempotentRepository) 

Sie bieten auf Ihren Bedarf basierte Implementierung von idempotentRepository verwenden, wie in obigen Link erwähnt.