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 リージョンの DynamoDB テーブル my-table から変更イベントを読み取るように IntegrationSource API を設定します。auth.secret.ref.name フィールドは、AWS 認証情報を保存する Kubernetes Secret (my-secret) を参照します。イベントは、シンクセクションで定義された default の 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 region 内の Amazon Resource Name (ARN) arn:aws:s3:::my-bucket で識別される Amazon S3 バケットを監視するように IntegrationSource API を設定します。auth.secret.ref.name フィールドは、AWS 認証情報を保存する Kubernetes Secret (my-secret) を参照します。イベントは、シンクセクションで定義された default の 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) を参照します。イベントは、シンクセクションで定義された default の 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

   このマニフェストは、IntegrationSource が 2000 ミリ秒 (2 秒) ごとに "Hello from Timer source" メッセージを送信するように設定します。生成されたメッセージは、シンクセクションで定義された default の Knative ブローカーに送信されます。