シナリオ: 関数へのキュー・メッセージの送信

コネクタ・ハブを使用してキューをファンクションと統合します。

このシナリオでは、関数を作成し、その関数をコネクタ(コネクタ・ハブ)でターゲットとして参照して、キューからのメッセージを受信および処理します。

関数が受信したペイロードには、キューからのメッセージのみが含まれます。

関連チュートリアルについては、OCI関数およびOCIキューを使用した承認者に管理権限を公開せずにユーザー機能を認可を参照してください。

トラブルシューティングに関するヘルプは、コネクタのトラブルシューティングを参照してください。

• コンソール
• CLI
• API

• 1. 「コネクタ」リスト・ページで、「コネクタの作成」を選択します。リスト・ページの検索に関するヘルプが必要な場合は、コネクタのリストを参照してください。
  2. 「コネクタの作成」ページで、新しいコネクタのわかりやすい名前と説明(オプション)を入力します。機密情報を入力しないでください。
  3. 新しいコネクタを格納するコンパートメントを選択します。
  4. 「コネクタの構成」で、「ソース」に「キュー」を選択します。
  5. 「ターゲット」で、「ファンクション」を選択します。
  6. 「ソース接続の構成」で、必要なメッセージを含むキューを選択します:
     • コンパートメント: 必要なキューを含むコンパートメントを選択します。
     • キュー: 必要なメッセージを含むキューを選択します。

     • チャネル・フィルタ(「メッセージ・フィルタリング」の下) (オプション): キュー内のチャネルからのメッセージをフィルタするには、値を入力します。

       たとえば、チャネルIDでメッセージをフィルタするには、チャネルIDを入力します。

       サポートされている値については、GetMessages (キューAPI)のchannelFilterを参照してください。

     ノート
     
     コネクタのターゲットに転送されたメッセージは、「消費済」とみなされます。キュー・サービスの要件を満たすために、コネクタはソース・キューから転送されたメッセージを削除します。詳細は、メッセージの使用を参照してください。
  7. 「ターゲットの構成」で、キューからメッセージを送信するファンクションを構成します。
     • コンパートメント: 必要なファンクションを含むコンパートメントを選択します。
     • ファンクション・アプリケーション: 必要なファンクションを含むファンクション・アプリケーションの名前を選択します。
     • Function: データの送信先のfunctionの名前を選択します。
     • 追加オプションの表示: このリンクをクリックし、ファンクションに送信されるデータのバッチごとに制限を指定します。手動設定を使用するには、バッチ・サイズ制限(KBまたはメッセージ数)およびバッチ時間制限(秒)の値を指定します。

       たとえば、5,000KBまたは10メッセージを選択して、バッチ・サイズを制限します。バッチ時間制限の例は5秒です。

     注意事項:

     • コネクタはソース・データをJSONリストとしてバッチでフラッシュします。最大バッチ(ペイロード)サイズは6MBです。
     • ファンクションは、1回の呼出しで6MBのデータと同期するように呼び出されます。データが6MBを超えると、コネクタが再びファンクションを呼び出して制限を超えるデータを移動します。このような呼出しは順次処理されます。
     • ファンクションは最大5分間実行できます。Delivery Detailsを参照してください。
     • Functionsターゲットからコネクタにデータを返さないでください。コネクタ・ハブは、ファンクション・ターゲットから返されたデータを読み取りません。関数がエラーなしで正常に戻された場合、コネクタはバッチ内のメッセージを「消費済」として処理し、それらのメッセージをキューから削除します。
  8. デフォルト・ポリシーを受け入れます。各デフォルト・ポリシーに用意されている「作成」リンクを選択します。
  9. 「作成」をクリックします。

  作成プロセスが開始され、その進行状況が表示されます。完了すると、コネクタの詳細ページが開きます。
• 1. コネクタのキュー・ソースを定義します: source.jsonという名前のファイルを保存します。

     キュー・ソースのJSONファイル・コンテンツの例:

     {
         "kind": "plugin",
         "pluginName": "QueueSource",
         "configMap": {
             "queueId": "<queue_OCID>"
         }
     }

  2. コネクタのFunctionsターゲットを定義します: target.jsonという名前のファイルを保存します。

     FunctionsターゲットのJSONファイルのコンテンツの例:

     {
         "kind": "functions",
         "functionId": "<function_OCID>",
         "batchSizeInKbs": "5000",
         "batchSizeInNum": "10",
         "batchTimeInSec": "60"
       }

  3. oci sch service-connector createコマンドを使用して、コネクタを作成します。

     スキャン可能性用の行が追加されたコマンドの例:

     oci sch service-connector create
       --compartment-id <compartment_OCID>
       --display-name "Queues to Functions"
       --source file://source.json
       --target file://target.json

• CreateServiceConnector操作を実行してコネクタを作成します。

  リクエストの例:

  POST /20200909/serviceConnectors
  Host: service-connector-hub.us-phoenix-1.oraclecloud.com
  <authorization and other headers>
  {
    "displayName": "My Queue to Function Connector",
    "compartmentId": "<compartment_OCID>",
    "description": "My connector description",
    "source": {
      "kind": "plugin",
      "pluginName": "QueueSource",
      "configMap": {
        "queueId": "<queue_OCID>"
      }
    },
    "target": {
      "kind": "functions",
      "functionId": "<function_OCID>",
      "batchSizeInKbs": "5000",
      "batchSizeInNum": "10",
      "batchTimeInSec": "60"
    }
  }