2.7. IntegrationSource 시작하기

프로세스

1. 다음 YAML 매니페스트를 integration-source-aws-ddb.yaml 로 저장합니다.

   apiVersion: sources.knative.dev/v1alpha1
   kind: IntegrationSource
   metadata:
     name: integration-source-aws-ddb
     namespace: knative-samples
   spec:
     aws:
       ddbStreams:
         table: "my-table"
         region: "eu-north-1"
       auth:
         secret:
           ref:
             name: "my-secret"
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1
         kind: Broker
         name: default

   Copy to Clipboard Toggle word wrap

2. 다음 명령을 실행하여 매니페스트를 적용합니다.

   $ oc apply -f integration-source-aws-ddb.yaml

   Copy to Clipboard Toggle word wrap

   이 매니페스트는 eu-north-1 리전의 my-table 에서 변경 이벤트를 읽을 수 있도록 IntegrationSource API를 구성합니다. auth.secret.ref.name 필드는 AWS 인증 정보를 저장하는 Kubernetes Secret(my-secret)을 참조합니다. 이벤트는 sink 섹션에 정의된 기본 Knative 브로커로 전송됩니다.

프로세스

1. 다음 YAML 매니페스트를 integration-source-aws-s3.yaml 로 저장합니다.

   apiVersion: sources.knative.dev/v1alpha1
   kind: IntegrationSource
   metadata:
     name: integration-source-aws-s3
     namespace: knative-samples
   spec:
     aws:
       s3:
         arn: "arn:aws:s3:::my-bucket"
         region: "eu-north-1"
       auth:
         secret:
           ref:
             name: "my-secret"
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1
         kind: Broker
         name: default

   Copy to Clipboard Toggle word wrap

2. 다음 명령을 실행하여 매니페스트를 적용합니다.

   $ oc apply -f integration-source-aws-s3.yaml

   Copy to Clipboard Toggle word wrap

   이 매니페스트는 eu-north-1 리전 의 Amazon Resource Name (ARN)arn:aws:s3:::my-bucket 에서 식별된 Amazon S3 버킷을 모니터링하도록 IntegrationSource API를 구성합니다. auth.secret.ref.name 필드는 AWS 인증 정보를 저장하는 Kubernetes Secret(my-secret)을 참조합니다. 이벤트는 sink 섹션에 정의된 기본 Knative 브로커로 전달됩니다.

프로세스

1. 다음 YAML 매니페스트를 integration-source-aws-sqs.yaml 로 저장합니다.

   apiVersion: sources.knative.dev/v1alpha1
   kind: IntegrationSource
   metadata:
     name: integration-source-aws-sqs
     namespace: knative-samples
   spec:
     aws:
       sqs:
         arn: "arn:aws:sqs:eu-north-1:123456789012:my-queue"
         region: "eu-north-1"
       auth:
         secret:
           ref:
             name: "my-secret"
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1
         kind: Broker
         name: default

   Copy to Clipboard Toggle word wrap
   참고

   ARN이 SQS 큐 지역, 계정 번호 및 큐 이름을 정확하게 반영하는지 확인합니다. 예: arn:aws:sqs:<region>:<account-id>:<queue-name>

2. 다음 명령을 실행하여 매니페스트를 적용합니다.

   $ oc apply -f integration-source-aws-sqs.yaml

   Copy to Clipboard Toggle word wrap

   이 매니페스트는 eu-north-1 리전의 ARN으로 식별되는 Amazon SQS 큐를 모니터링하도록 IntegrationSource API를 구성합니다. auth.secret.ref.name 필드는 AWS 인증 정보를 저장하는 Kubernetes Secret(my-secret)을 참조합니다. 이벤트는 sink 섹션에 정의된 기본 Knative 브로커로 전달됩니다.

프로세스

1. 다음 YAML 매니페스트를 integration-source-timer.yaml 로 저장합니다.

   apiVersion: sources.knative.dev/v1alpha1
   kind: IntegrationSource
   metadata:
     name: integration-source-timer
     namespace: knative-samples
   spec:
     timer:
       period: 2000
       message: "Hello from Timer source"
     sink:
       ref:
         apiVersion: eventing.knative.dev/v1
         kind: Broker
         name: default

   Copy to Clipboard Toggle word wrap

2. 다음 명령을 실행하여 매니페스트를 적용합니다.

   $ oc apply -f integration-source-timer.yaml

   Copy to Clipboard Toggle word wrap

   이 매니페스트는 2000 밀리초 (2 초)마다 "Hello from Timer source" 메시지를 내보내도록 IntegrationSource 를 구성합니다. 생성된 메시지는 sink 섹션에 정의된 기본 Knative 브로커로 전송됩니다.