From d95b2bdcc1923bff95f7c4bbc8b885fd4aad1c5e Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 3 Nov 2022 15:17:22 +0100 Subject: [PATCH] aws-s3-sink kamelet ignores keyName property Signed-off-by: Andrea Cosentino --- kamelets/aws-s3-sink.kamelet.yaml | 35 +++++++++++-------- .../kamelets/aws-s3-sink.kamelet.yaml | 35 +++++++++++-------- 2 files changed, 40 insertions(+), 30 deletions(-) diff --git a/kamelets/aws-s3-sink.kamelet.yaml b/kamelets/aws-s3-sink.kamelet.yaml index ca62484c4..61a5dc555 100644 --- a/kamelets/aws-s3-sink.kamelet.yaml +++ b/kamelets/aws-s3-sink.kamelet.yaml @@ -108,22 +108,27 @@ spec: uri: "kamelet:source" steps: - choice: + precondition: true when: - - simple: "${header[file]}" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${header[file]}" - - simple: "${header[ce-file]}" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${header[ce-file]}" - - simple: "${propertiesExist:!keyName}" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${exchangeId}" + - simple: '${propertiesExist:!keyName}' + steps: + - choice: + when: + - simple: "${header[file]}" + steps: + - set-header: + name: CamelAwsS3Key + simple: "${header[file]}" + - simple: "${header[ce-file]}" + steps: + - set-header: + name: CamelAwsS3Key + simple: "${header[ce-file]}" + otherwise: + steps: + - set-header: + name: CamelAwsS3Key + simple: "${exchangeId}" - to: uri: "aws2-s3:{{bucketNameOrArn}}" parameters: diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml index d8d8ab6f6..61a5dc555 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml @@ -108,22 +108,27 @@ spec: uri: "kamelet:source" steps: - choice: + precondition: true when: - - simple: "${header[file]}" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${header[file]}" - - simple: "${header[ce-file]}" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${header[ce-file]}" - - simple: "'{{?keyName}}' == ''" - steps: - - set-header: - name: CamelAwsS3Key - simple: "${exchangeId}" + - simple: '${propertiesExist:!keyName}' + steps: + - choice: + when: + - simple: "${header[file]}" + steps: + - set-header: + name: CamelAwsS3Key + simple: "${header[file]}" + - simple: "${header[ce-file]}" + steps: + - set-header: + name: CamelAwsS3Key + simple: "${header[ce-file]}" + otherwise: + steps: + - set-header: + name: CamelAwsS3Key + simple: "${exchangeId}" - to: uri: "aws2-s3:{{bucketNameOrArn}}" parameters: