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-k-examples.git
The following commit(s) were added to refs/heads/main by this push: new 67c52f6 Added Kamelets folder and first example AWS S3 to Log (#35) 67c52f6 is described below commit 67c52f69d37a73d436c37fe1c96d702b65c88904 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Jul 2 13:22:39 2021 +0200 Added Kamelets folder and first example AWS S3 to Log (#35) --- kamelets/README.md | 15 +++++++++++++++ kamelets/aws-s3-to-log/README.md | 18 ++++++++++++++++++ kamelets/aws-s3-to-log/flow-binding.yaml | 20 ++++++++++++++++++++ kamelets/aws-s3-to-log/log-sink.kamelet.yaml | 22 ++++++++++++++++++++++ 4 files changed, 75 insertions(+) diff --git a/kamelets/README.md b/kamelets/README.md new file mode 100644 index 0000000..4e1b59b --- /dev/null +++ b/kamelets/README.md @@ -0,0 +1,15 @@ +# Camel K Examples - Kamelets + +This folder contains a collection of Camel K examples based on Kamelets and KameletBinding CRD. + +## Before you begin + +Follow the instructions from the Repository Root Folder's README. + +## Important Notes + +All the Kamelet examples in this folder have been tested on Camel-K 1.5.0 SNAPSHOT. + +## Examples List + +- [AWS S3 to Log](./aws-s3-to-log): Create a Kamelet binding between an AWS S3 Source Kamelet and a Log Sink Kamelet diff --git a/kamelets/aws-s3-to-log/README.md b/kamelets/aws-s3-to-log/README.md new file mode 100644 index 0000000..3840d12 --- /dev/null +++ b/kamelets/aws-s3-to-log/README.md @@ -0,0 +1,18 @@ +# AWS S3 to Log + +- Open the flow-binding.yaml file and insert the correct credentials for AWS S3 account and the bucket name. + +- The Log Sink Kamelet is not available out of the box in 1.5.0 Camel-K release so you'll have to install it before installing the flow binding. + +- If camel-k has been installed in a specific namespace different from the default one, you'll need to add a parameter to all the command (-n <namespace_name>)s + +- Run the following commands + + kubectl apply -f log-sink.kamelet.yaml + kubectl apply -f flow-binding.yaml + +- Check logs + + kamel logs aws-s3-to-log + +- If you have files on your S3 bucket you should see their content consumed and the file in the bucket deleted diff --git a/kamelets/aws-s3-to-log/flow-binding.yaml b/kamelets/aws-s3-to-log/flow-binding.yaml new file mode 100644 index 0000000..2b431ad --- /dev/null +++ b/kamelets/aws-s3-to-log/flow-binding.yaml @@ -0,0 +1,20 @@ +apiVersion: camel.apache.org/v1alpha1 +kind: KameletBinding +metadata: + name: aws-s3-to-log +spec: + source: + ref: + kind: Kamelet + apiVersion: camel.apache.org/v1alpha1 + name: aws-s3-source + properties: + bucketNameOrArn: 'camel-kafka-connector' + accessKey: 'accessKey' + secretKey: 'secretKey' + region: 'region' + sink: + ref: + kind: Kamelet + apiVersion: camel.apache.org/v1alpha1 + name: log-sink diff --git a/kamelets/aws-s3-to-log/log-sink.kamelet.yaml b/kamelets/aws-s3-to-log/log-sink.kamelet.yaml new file mode 100755 index 0000000..a48fb41 --- /dev/null +++ b/kamelets/aws-s3-to-log/log-sink.kamelet.yaml @@ -0,0 +1,22 @@ +apiVersion: camel.apache.org/v1alpha1 +kind: Kamelet +metadata: + name: log-sink + annotations: + camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHZpZXdCb3g9IjAgMCAyNDAgMjQwIj48ZGVmcz48bGluZWFyR3JhZGllbnQgaWQ9ImEiIHgxPSIuNjY3IiB4Mj0iLjQxNyIgeTE9Ii4xNjciIHkyPSIuNzUiPjxzdG9wIG9mZnNldD0iMCIgc3RvcC1jb2xvcj0iIzM3YWVlMiIvPjxzdG9wIG9mZnNldD0iMSIgc3RvcC1jb2xvcj0iIzFlOTZjOCIvPjwvbGluZWFyR3JhZGllbnQ+PGxpbmVhckdyYWRpZW50IGlkPSJiIiB4MT0iLjY2IiB4Mj0iLjg1MSIgeTE9Ii40MzciIHkyPSIuODAyIj48c3RvcCBvZmZzZXQ9IjAiIHN0b3AtY29sb3I9IiNlZmY3Zm [...] + camel.apache.org/provider: "Apache Software Foundation" + labels: + camel.apache.org/kamelet.type: "sink" + camel.apache.org/kamelet.group: "Log" +spec: + definition: + title: "Log Sink" + description: |- + Log something + type: object + flow: + from: + uri: "kamelet:source" + steps: + - to: + uri: "log:info?showAll=true"