This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit d6ca46cf71295800fc96491a5b3818df724db106 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Jun 4 13:14:28 2021 +0200 Added AWS-S3 Streaming Upload Sink Kamelet --- .../aws-s3-streaming-upload-sink.kamelet.yaml | 101 +++++++++++++++++++++ 1 file changed, 101 insertions(+) diff --git a/library/camel-kamelets-catalog/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml b/library/camel-kamelets-catalog/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml new file mode 100644 index 0000000..393bb64 --- /dev/null +++ b/library/camel-kamelets-catalog/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml @@ -0,0 +1,101 @@ +apiVersion: camel.apache.org/v1alpha1 +kind: Kamelet +metadata: + name: aws-s3-streaming-upload-sink + annotations: + camel.apache.org/kamelet.support.level: "Preview" + camel.apache.org/catalog.version: "main-SNAPSHOT" + camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB2ZXJzaW9uPSIxLjEiIGlkPSJMYXllcl8xIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHg9IjAiIHk9IjAiIHZpZXdCb3g9IjAgMCAyNDguMiAzMDAiIHhtbDpzcGFjZT0icHJlc2VydmUiPjxzdHlsZT4uc3QyOHtmaWxsOiM4YzMxMjN9LnN0Mjl7ZmlsbDojZTA1MjQzfTwvc3R5bGU+PHBhdGggY2xhc3M9InN0MjgiIGQ9Ik0yMCA1Mi4xTDAgNjJ2MTc1LjVsMjAgOS45LjEtLjFWNTIuMmwtLjEtLjEiLz48cGF0aCBjbGFzcz0ic3QyOSIgZD0iTTEyNyAyMjJMMjAgMjQ3LjVWNTIuMUwxMjcgNzd2MTQ1Ii8+PHBhdGggY2xhc3M9InN0MjgiIG [...] + camel.apache.org/provider: "Apache Software Foundation" + camel.apache.org/kamelet.group: "AWS S3" + labels: + camel.apache.org/kamelet.type: "sink" +spec: + definition: + title: "AWS S3 Streaming upload Sink" + description: |- + Upload data to AWS S3 in streaming upload mode. + required: + - bucketNameOrArn + - accessKey + - secretKey + - region + - keyName + type: object + properties: + bucketNameOrArn: + title: Bucket Name + description: The S3 Bucket name or ARN. + type: string + accessKey: + title: Access Key + description: The access key obtained from AWS. + type: string + format: password + x-descriptors: + - urn:alm:descriptor:com.tectonic.ui:password + secretKey: + title: Secret Key + description: The secret key obtained from AWS. + type: string + format: password + x-descriptors: + - urn:alm:descriptor:com.tectonic.ui:password + region: + title: AWS Region + description: The AWS region to connect to. + type: string + example: eu-west-1 + autoCreateBucket: + title: Autocreate Bucket + description: Setting the autocreation of the S3 bucket bucketName. + type: boolean + x-descriptors: + - 'urn:alm:descriptor:com.tectonic.ui:checkbox' + default: false + streamingUploadMode: + title: Streaming Upload Mode + description: Setting the Streaming Upload Mode + type: boolean + x-descriptors: + - 'urn:alm:descriptor:com.tectonic.ui:checkbox' + default: true + restartingPolicy: + title: Restarting Policy + description: The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart + type: string + default: "lastPart" + batchMessageNumber: + title: Batch Message Number + description: The number of messages composing a batch in streaming upload mode + type: int + default: 10 + namingStrategy: + title: Naming Strategy + description: The naming strategy to use in streaming upload mode. There are 2 enums and the value can be one of progressive, random + type: string + default: "progressive" + keyName: + title: Key Name + description: Setting the key name for an element in the bucket through endpoint parameter. In Streaming Upload, with the default configuration, this will be the base for the progressive creation of files. + type: string + dependencies: + - "camel:aws2-s3" + - "camel:kamelet" + flow: + from: + uri: "kamelet:source" + steps: + - to: + uri: "aws2-s3:{{bucketNameOrArn}}" + parameters: + secretKey: "{{secretKey}}" + accessKey: "{{accessKey}}" + region: "{{region}}" + autoCreateBucket: "{{autoCreateBucket}}" + streamingUploadMode: "{{streamingUploadMode}}" + restartingPolicy: "{{restartingPolicy}}" + batchMessageNumber: "{{batchMessageNumber}}" + namingStrategy: "{{namingStrategy}}" + keyName: "{{keyName}}" +
