You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/03/27 09:58:39 UTC
(camel-kamelets) branch 1909 created (now cf067213)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch 1909
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at cf067213 AWS DDB Stream Source: Expose Kamelet data type information
This branch includes the following new commits:
new cf067213 AWS DDB Stream Source: Expose Kamelet data type information
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel-kamelets) 01/01: AWS DDB Stream Source: Expose Kamelet data type information
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch 1909
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit cf06721301e5e07610b3d96a77d8305fcedc46a7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 27 10:58:24 2024 +0100
AWS DDB Stream Source: Expose Kamelet data type information
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/aws-ddb-streams-source.kamelet.yaml | 45 +++++++++++++++++++++-
.../kamelets/aws-ddb-streams-source.kamelet.yaml | 45 +++++++++++++++++++++-
2 files changed, 86 insertions(+), 4 deletions(-)
diff --git a/kamelets/aws-ddb-streams-source.kamelet.yaml b/kamelets/aws-ddb-streams-source.kamelet.yaml
index fd7de07d..29f828b1 100644
--- a/kamelets/aws-ddb-streams-source.kamelet.yaml
+++ b/kamelets/aws-ddb-streams-source.kamelet.yaml
@@ -89,9 +89,50 @@ spec:
description: The number of milliseconds before the next poll from the database.
type: integer
default: 500
- types:
+ dataTypes:
out:
- mediaType: application/json
+ default: json
+ headers:
+ CamelAwsDdbStreamEventSource:
+ title: The DDB Stream Event Source
+ description: The Amazon Web Services service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ type: string
+ CamelAwsDdbStreamEventId:
+ title: The DDB Stream Event Id
+ description: A globally unique identifier for the event that was recorded in this stream record.
+ type: string
+ types:
+ json:
+ format: "application-json"
+ description: Default Json representation of a DDB Stream Event.
+ mediaType: application/json
+ cloudevents:
+ format: "aws2-sqs:application-cloudevents"
+ description: |-
+ Data type transformer converts AWS Dynamo DB Streams get records response to CloudEvent v1_0 data format. The data
+ type sets Camel specific CloudEvent headers with values extracted from AWS Dynamo DB Streams get records.
+ headers:
+ CamelCloudEventID:
+ title: CloudEvent ID
+ description: The Camel exchange id set as event id
+ type: string
+ CamelCloudEventType:
+ title: CloudEvent Type
+ description: The event type
+ default: "org.apache.camel.event.aws.ddbstream.getRecords"
+ type: string
+ CamelCloudEventSource:
+ title: CloudEvent Source
+ description: The event source. By default, the DDB Stream Event source receipt handle with prefix "aws.ddbstream.".
+ type: string
+ CamelCloudEventSubject:
+ title: CloudEvent Subject
+ description: The event subject. The DDB Stream Event Id.
+ type: string
+ CamelCloudEventTime:
+ title: CloudEvent Time
+ description: The exchange creation timestamp as event time.
+ type: string
dependencies:
- "camel:gson"
- "camel:aws2-ddb"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
index fd7de07d..29f828b1 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
@@ -89,9 +89,50 @@ spec:
description: The number of milliseconds before the next poll from the database.
type: integer
default: 500
- types:
+ dataTypes:
out:
- mediaType: application/json
+ default: json
+ headers:
+ CamelAwsDdbStreamEventSource:
+ title: The DDB Stream Event Source
+ description: The Amazon Web Services service from which the stream record originated. For DynamoDB Streams, this is aws:dynamodb.
+ type: string
+ CamelAwsDdbStreamEventId:
+ title: The DDB Stream Event Id
+ description: A globally unique identifier for the event that was recorded in this stream record.
+ type: string
+ types:
+ json:
+ format: "application-json"
+ description: Default Json representation of a DDB Stream Event.
+ mediaType: application/json
+ cloudevents:
+ format: "aws2-sqs:application-cloudevents"
+ description: |-
+ Data type transformer converts AWS Dynamo DB Streams get records response to CloudEvent v1_0 data format. The data
+ type sets Camel specific CloudEvent headers with values extracted from AWS Dynamo DB Streams get records.
+ headers:
+ CamelCloudEventID:
+ title: CloudEvent ID
+ description: The Camel exchange id set as event id
+ type: string
+ CamelCloudEventType:
+ title: CloudEvent Type
+ description: The event type
+ default: "org.apache.camel.event.aws.ddbstream.getRecords"
+ type: string
+ CamelCloudEventSource:
+ title: CloudEvent Source
+ description: The event source. By default, the DDB Stream Event source receipt handle with prefix "aws.ddbstream.".
+ type: string
+ CamelCloudEventSubject:
+ title: CloudEvent Subject
+ description: The event subject. The DDB Stream Event Id.
+ type: string
+ CamelCloudEventTime:
+ title: CloudEvent Time
+ description: The exchange creation timestamp as event time.
+ type: string
dependencies:
- "camel:gson"
- "camel:aws2-ddb"