Chapter 9. AWS Lambda Sink

9.1. Authentication methods
링크 복사

In this Kamelet you can avoid using explicit static credentials by specifying the useDefaultCredentialsProvider option and set it to true.

The order of evaluation for Default Credentials Provider is the following:

Java system properties - aws.accessKeyId and aws.secretKey.
Environment variables - AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY.
Web Identity Token from AWS STS.
The shared credentials and config files.
Amazon ECS container credentials - loaded from the Amazon ECS if the environment variable AWS_CONTAINER_CREDENTIALS_RELATIVE_URI is set.
Amazon EC2 Instance profile credentials.

You can also use the Profile Credentials Provider, by setting the useProfileCredentialsProvider option to true and profileCredentialsName to the profile name.

Only one of access key/secret key or default credentials provider could be used

For more information, see the AWS credentials documentation

9.2. Configuration Options
링크 복사

The following table summarizes the configuration options available for the aws-lambda-sink Kamelet:

Expand

Property	Name	Description	Type	Default
function *	Function Name	The Lambda Function name.	string
region *	AWS Region	The AWS region to access.	string
accessKey	Access Key	The access key obtained from AWS.	string
profileCredentialsName	Profile Credentials Name	If using a profile credentials provider this parameter sets the profile name.	string
secretKey	Secret Key	The secret key obtained from AWS.	string
sessionToken	Session Token	Amazon AWS Session Token used when the user needs to assume a IAM role.	string
useDefaultCredentialsProvider	Default Credentials Provider	If true, the Lambda client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).	boolean	False
useProfileCredentialsProvider	Profile Credentials Provider	Set whether the Lambda client should expect to load credentials through a profile credentials provider.	boolean	False
useSessionCredentials	Session Credentials	Set whether the Lambda client should expect to use Session Credentials. This is useful in situation in which the user needs to assume a IAM role for doing operations in Lambda.	boolean	False

* = Fields marked with an asterisk are mandatory.

9.3. Dependencies
링크 복사

9.3.1. Quarkus dependencies
링크 복사

<dependencies>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifactId>camel-kamelets-utils</artifactId>
    <version>4.8.5</version>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws-lambda</artifactId>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-lambdan</artifactId>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-kamelet</artifactId>
  </dependency>
</dependencies>

<dependencies>
  <dependency>
    <groupId>org.apache.camel.kamelets</groupId>
    <artifactId>camel-kamelets-utils</artifactId>
    <version>4.8.5</version>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws-lambda</artifactId>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-lambdan</artifactId>
  </dependency>
  <dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-kamelet</artifactId>
  </dependency>
</dependencies>

Copy to Clipboard

Toggle word wrap

9.4. Usage
링크 복사

9.4.1. Camel JBang usage
링크 복사

9.4.1.1. Prerequisites for JBang
링크 복사

Install JBang.
You have executed the following command:
```
jbang app install camel@apache/camel
```
```
jbang app install camel@apache/camel
```
Copy to Clipboard Toggle word wrap

9.4.1.2. Running a route with JBang
링크 복사

Suppose you have a file named route.yaml with this content:

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

- route:
    from:
      uri: "kamelet:timer-source"
      parameters:
        period: 10000
        message: 'test'
      steps:
        - to:
            uri: "kamelet:log-sink"

Copy to Clipboard

Toggle word wrap

You can now run it directly through the following command.

camel run route.yaml

camel run route.yaml

Copy to Clipboard

Toggle word wrap

9.4.2. Knative Sink
링크 복사

You can use the aws-lambda-sink Kamelet as a Knative sink by binding it to a Knative object.

aws-lambda-sink-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: aws-lambda-sink-binding
spec:
  source:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: aws-lambda-sink
    properties:
      accessKey: "The Access Key"
      function: "The Function Name"
      region: "eu-west-1"
      secretKey: "The Secret Key"

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: aws-lambda-sink-binding
spec:
  source:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: aws-lambda-sink
    properties:
      accessKey: "The Access Key"
      function: "The Function Name"
      region: "eu-west-1"
      secretKey: "The Secret Key"

Copy to Clipboard

Toggle word wrap

9.4.3. Kafka Sink
링크 복사

You can use the aws-lambda-sink Kamelet as a Kafka sink by binding it to a Kafka topic.

aws-lambda-sink-binding.yaml

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: aws-lambda-sink-binding
spec:
  source:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: aws-lambda-sink
    properties:
      accessKey: "The Access Key"
      function: "The Function Name"
      region: "eu-west-1"
      secretKey: "The Secret Key"

apiVersion: camel.apache.org/v1
kind: Pipe
metadata:
  name: aws-lambda-sink-binding
spec:
  source:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1
      name: aws-lambda-sink
    properties:
      accessKey: "The Access Key"
      function: "The Function Name"
      region: "eu-west-1"
      secretKey: "The Secret Key"

Copy to Clipboard

Toggle word wrap

9.5. Kamelets source file
링크 복사

https://github.com/jboss-fuse/camel-kamelets/blob/camel-kamelets-4.10.3-branch/kamelets/aws-lambda-sink.kamelet.yaml

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

9.1. Authentication methods
링크 복사

9.2. Configuration Options
링크 복사

9.3. Dependencies
링크 복사

9.3.1. Quarkus dependencies
링크 복사

9.4. Usage
링크 복사

9.4.1. Camel JBang usage
링크 복사

9.4.1.1. Prerequisites for JBang
링크 복사

9.4.1.2. Running a route with JBang
링크 복사

9.4.2. Knative Sink
링크 복사

9.4.3. Kafka Sink
링크 복사

9.5. Kamelets source file
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

Chapter 9. AWS Lambda Sink

9.1. Authentication methods링크 복사링크가 클립보드에 복사되었습니다!

9.2. Configuration Options링크 복사링크가 클립보드에 복사되었습니다!

9.3. Dependencies링크 복사링크가 클립보드에 복사되었습니다!

9.3.1. Quarkus dependencies링크 복사링크가 클립보드에 복사되었습니다!

9.4. Usage링크 복사링크가 클립보드에 복사되었습니다!

9.4.1. Camel JBang usage링크 복사링크가 클립보드에 복사되었습니다!

9.4.1.1. Prerequisites for JBang링크 복사링크가 클립보드에 복사되었습니다!

9.4.1.2. Running a route with JBang링크 복사링크가 클립보드에 복사되었습니다!

9.4.2. Knative Sink링크 복사링크가 클립보드에 복사되었습니다!

9.4.3. Kafka Sink링크 복사링크가 클립보드에 복사되었습니다!

9.5. Kamelets source file링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

9.1. Authentication methods
링크 복사

9.2. Configuration Options
링크 복사

9.3. Dependencies
링크 복사

9.3.1. Quarkus dependencies
링크 복사

9.4. Usage
링크 복사

9.4.1. Camel JBang usage
링크 복사

9.4.1.1. Prerequisites for JBang
링크 복사

9.4.1.2. Running a route with JBang
링크 복사

9.4.2. Knative Sink
링크 복사

9.4.3. Kafka Sink
링크 복사

9.5. Kamelets source file
링크 복사