検索

15.2. Knative チャネルにサブスクライブしてメッセージを取得

download PDF

Knative チャネルからメッセージを受信したときにインテグレーションの実行をトリガーするには、Knative コネクションをシンプルなインテグレーションの最初のコネクションとして追加します。このように開始するインテグレーションは、指定期間内にチャネルからメッセージを受信しないと自動的に 0 Pod にスケールダウンされます。デフォルトの期間は 1 分です。

この自動スケーリングはリソースを節約します。そのため、AMQ ブローカーへのコネクションなどの、他のコネクションで始まるシンプルなインテグレーションよりも優れています。

前提条件

  • Knative リソースへのコネクションが有効になっている必要があります。
  • メッセージを取得する Knative リソースが Fuse Online と同じクラスターにある必要があります。
  • コネクションがメッセージを取得する Knative チャネルの名前を知っている必要があります。

手順

  1. Fuse Online の左側のパネルで Integrations をクリックします。
  2. Create Integration をクリックします。
  3. Choose a connection ページで Knative コネクションをクリックします。
  4. Receive from Channel アクションを選択します。
  5. Channel name フィールドをクリックし、使用できる Knative チャネルの一覧を表示します。
  6. メッセージを取得するリソースの Knative チャネル名を選択します。
  7. Next をクリックし、Receive from Channel アクションの出力タイプを指定します。これは、インテグレーションでコネクションが次のステップに渡すタイプです。

    1. データタイプの認識が必要がない場合は、Select Type フィールドに Type specification not required を使用し、Next をクリックします。残りの手順を行う必要はありません。

      ただし、構造化データタイプが推奨されます。たとえば、コネクション出力をデータマッパーステップでマップする場合、データタイプを指定する必要があります。データマッパーは、非構造化データのフィールドを表示できません。

      データタイプを指定するには、Select Type フィールドをクリックし、以下の 1 つをスキーマタイプとして選択します。

      • JSON schema は JSON データの構造を記述するドキュメントです。ドキュメントのメディアタイプは application/schema+json です。
      • JSON instance は JSON データが含まれるドキュメントです。ドキュメントのメディアタイプは application/json です。
      • XML schema は XML データの構造を記述するドキュメントです。ドキュメントのファイル拡張子は .xsd です。
      • XML instance は XML データが含まれるドキュメントです。このドキュメントのファイル拡張子は .xml です。
    2. Definition 入力ボックスに、選択したスキーマタイプに準拠する定義を貼り付けます。たとえば、JSON schema を選択した場合は、メディアタイプが application/schema+json の JSON スキーマファイルの内容を貼り付けます。
    3. Data Type Name フィールドにはデータタイプに選択した名前を入力します。たとえば、ベンダーの JSON スキーマを指定する場合は、Vendor をデータタイプ名として指定することができます。

      このタイプを指定するコネクションを使用するインテグレーションを作成または編集するときにこのデータタイプ名が表示されます。Fuse Online では、インテグレーションビジュアライゼーションとデータマッパーにタイプ名が表示されます。

    4. Data Type Description フィールドには、このタイプを区別するのに便利な情報を提供します。データマッパーでこのタイプを処理するステップにカーソルを合わせると、この説明が表示されます。
    5. Next をクリックします。

結果

Fuse Online は、シンプルなインテグレーションの最後のコネクションを追加するよう要求します。

実行中、選択した Knative チャネルが新しいメッセージを受信するたびに、Knative コネクションはインテグレーションの次のステップにメッセージを渡します。

次のステップ

必要なすべてのコネクションをインテグレーションに追加します。その後、インテグレーションを開始する Knative コネクションの後にデータマッパーステップを追加します。ソース message フィールドを、次のコネクションのターゲットフィールドにマップマップします。

Red Hat logoGithubRedditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

© 2024 Red Hat, Inc.