This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 7e1110d10e2153a3fd8b45b79b8494798d2bb8e1
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Apr 2 08:29:55 2021 +0200

    CAMEL-16185 - Regen docs
---
 .../camel/catalog/docs/aws2-s3-component.adoc       | 21 +++++++++++++++++++++
 .../modules/ROOT/pages/aws2-s3-component.adoc       | 21 +++++++++++++++++++++
 2 files changed, 42 insertions(+)

diff --git 
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
 
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
index b9f86e9..5d5ea99 100644
--- 
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
+++ 
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-s3-component.adoc
@@ -553,6 +553,27 @@ This operation will return an S3Object instance related to 
the camelKey object i
 
 This operation will return a download link url for the file camel-key in the 
bucket mycamelbucket and region region
 
+== Stream mode
+
+With the stream mode enabled users will be able to upload data to S3 without 
knowing ahead of time the dimension of the data, by leveraging multipart upload.
+The upload will be completed when: the batchSize has been completed or the 
batchMessageNumber has been reached.
+There are two possible naming strategy: progressive and random. With the 
progressive strategy each file will have the name composed by keyName option 
and a progressive counter, and eventually the file extension (if any), while 
with the random strategy a UUID will be added after keyName and eventually the 
file extension will appended.
+
+As an example:
+
+[source,java]
+--------------------------------------------------------------------------------
+from(kafka("topic1").brokers("localhost:9092"))
+        .log("Kafka Message is: ${body}")
+        
.to(aws2S3("camel-bucket").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+
+from(kafka("topic2").brokers("localhost:9092"))
+         .log("Kafka Message is: ${body}")
+         
.to(aws2S3("camel-bucket").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+--------------------------------------------------------------------------------
+
+The default size for a batch is 1 Mb, but you can adjust it according to your 
requirements.
+
 == Bucket Autocreation
 
 With the option `autoCreateBucket` users are able to avoid the autocreation of 
an S3 Bucket in case it doesn't exist. The default for this option is `true`.
diff --git a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc 
b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
index 5799ff8..d9b4856 100644
--- a/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-s3-component.adoc
@@ -555,6 +555,27 @@ This operation will return an S3Object instance related to 
the camelKey object i
 
 This operation will return a download link url for the file camel-key in the 
bucket mycamelbucket and region region
 
+== Stream mode
+
+With the stream mode enabled users will be able to upload data to S3 without 
knowing ahead of time the dimension of the data, by leveraging multipart upload.
+The upload will be completed when: the batchSize has been completed or the 
batchMessageNumber has been reached.
+There are two possible naming strategy: progressive and random. With the 
progressive strategy each file will have the name composed by keyName option 
and a progressive counter, and eventually the file extension (if any), while 
with the random strategy a UUID will be added after keyName and eventually the 
file extension will appended.
+
+As an example:
+
+[source,java]
+--------------------------------------------------------------------------------
+from(kafka("topic1").brokers("localhost:9092"))
+        .log("Kafka Message is: ${body}")
+        
.to(aws2S3("camel-bucket").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic1}}/{{kafkaTopic1}}.txt"));
+
+from(kafka("topic2").brokers("localhost:9092"))
+         .log("Kafka Message is: ${body}")
+         
.to(aws2S3("camel-bucket").streamMode(true).batchMessageNumber(25).namingStrategy(AWS2S3EndpointBuilderFactory.AWSS3NamingStrategyEnum.progressive).keyName("{{kafkaTopic2}}/{{kafkaTopic2}}.txt"));
+--------------------------------------------------------------------------------
+
+The default size for a batch is 1 Mb, but you can adjust it according to your 
requirements.
+
 == Bucket Autocreation
 
 With the option `autoCreateBucket` users are able to avoid the autocreation of 
an S3 Bucket in case it doesn't exist. The default for this option is `true`.

Reply via email to