This is an automated email from the ASF dual-hosted git repository.
nferraro pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit aaf41bf97dd9433228d21a22f9e17f72827b0aed
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Wed Mar 24 14:44:58 2021 +0100
Added AWS DDB Streams Source Kamelet
---
aws-ddb-streams-source.kamelet.yaml | 67 +++++++++++++++++++++++++++++++++++++
1 file changed, 67 insertions(+)
diff --git a/aws-ddb-streams-source.kamelet.yaml
b/aws-ddb-streams-source.kamelet.yaml
new file mode 100644
index 0000000..2d7c7a1
--- /dev/null
+++ b/aws-ddb-streams-source.kamelet.yaml
@@ -0,0 +1,67 @@
+apiVersion: camel.apache.org/v1alpha1
+kind: Kamelet
+metadata:
+ name: aws-ddb-streams-source
+ annotations:
+ camel.apache.org/kamelet.icon:
"data:image/svg+xml;base64,PHN2ZyBoZWlnaHQ9IjEwMCIgd2lkdGg9IjEwMCIgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIj48cGF0aCBmaWxsPSIjMkQ3MkI4IiBkPSJNNzQuMTc0IDMxLjgwN2w3LjQzNyA1LjM2N3YtNy42MDJsLTcuNDgtOC43NjV2MTAuOTU3bC4wNDMuMDE1eiIvPjxwYXRoIGZpbGw9IiM1Mjk0Q0YiIGQ9Ik01OS44MzggODUuNjY2bDE0LjI5My03LjE0NlYyMC43OTFsLTE0LjMwMy03LjEyNHoiLz48cGF0aCBmaWxsPSIjMjA1Qjk4IiBkPSJNMzkuNDk2IDg1LjY2NkwyNS4yMDMgNzguNTJWMjAuNzkxbDE0LjMwMy03LjEyNHoiLz48cGF0aCBmaWxsPSIjMkQ3Mk
[...]
+ camel.apache.org/provider: "Apache Software Foundation"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+spec:
+ definition:
+ title: "AWS DDB Streams Source"
+ description: |-
+ Receive events from AWS DDB Streams.
+ required:
+ - table
+ - accessKey
+ - secretKey
+ - region
+ properties:
+ bucketNameOrArn:
+ title: Table
+ description: Name of the DynamoDB table to look at
+ type: string
+ accessKey:
+ title: Access Key
+ description: The access key obtained from AWS
+ type: string
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ secretKey:
+ title: Secret Key
+ description: The secret key obtained from AWS
+ type: string
+ 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
+ iteratorType:
+ title: Iterator Type
+ description: Defines where in the DynaboDB stream to start getting
records. Note that using TRIM_HORIZON can cause a significant delay before the
stream has caught up to real-time. if {AT,AFTER}_SEQUENCE_NUMBER are used, then
a sequenceNumberProvider MUST be supplied. There are 4 enums and the value can
be one of TRIM_HORIZON, LATEST, AT_SEQUENCE_NUMBER, AFTER_SEQUENCE_NUMBER
+ type: String
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ default: LATEST
+ sequenceNumberProvider:
+ title: Sequence Number Provider
+ description: Provider for the sequence number when using one of the
two ShardIteratorType AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER iterator
types. Can be a registry reference or a literal sequence number.
+ type: string
+ example: "900000000005745712447"
+ types:
+ out:
+ mediaType: application/json
+ flow:
+ from:
+ uri: "aws2-ddbstream:{{tableName}}"
+ parameters:
+ secretKey: "{{secretKey}}"
+ accessKey: "{{accessKey}}"
+ region: "{{region}}"
+ iteratorType: "{{iteratorType}}"
+ sequenceNumberProvider: "{{sequenceNumberProvider}}"
+ steps:
+ - to: "kamelet:sink"
