キュー・ソースとのコネクタの作成
キュー・サービスのキューからターゲット・サービスにメッセージを転送するコネクタ・ハブにコネクタを作成します。
キュー・サービスの詳細は、キューを参照してください。
キュー・ソースおよび(オプション)ファンクション・タスクで定義されたコネクタでは、ファンクション、通知、オブジェクト・ストレージおよびストリーミングのターゲットがサポートされます。コネクタ・ハブ・ワークフローの例は、「コネクタ・ハブの概要」を参照してください。
ロング・投票
デフォルトでは、コネクタは長いポーリングを使用してキューからメッセージを読み取ります。ロング・ポーリングは、キューが空の場合にタイト・ループの再試行を防止するのに役立ちます。キューからの読み取りの読み取りタイムアウトは30秒です。各移動操作では、コネクタは、キューで消費可能なメッセージが使用可能になるのを待機します。読取りタイムアウトが経過し、消費可能なメッセージがない場合、コネクタはリクエストを終了し、別のリクエストで再試行します。
フィルタと消費されたメッセージ数
特定のチャネルのキューをフィルタできます。キューをフィルタするためのAPIおよびCLIパラメータについては、チャネルからのメッセージの消費を参照してください。コネクタのターゲットに転送されたメッセージは、「消費済」とみなされます。キュー・サービスの要件を満たすために、コネクタはソース・キューから転送されたメッセージを削除します。詳細は、メッセージの使用を参照してください。
保持期間: キュー・ソース
キュー・ソースを使用してコネクタを作成するには、oci sch service-connector createコマンドと必要なパラメータを使用します:
oci sch service-connector create [...] --source <queue_json_input>
JSONファイルを使用してソースの詳細をCLIに渡すには:
oci sch service-connector create [...] --source file:queue_source.json
JSONファイルのコンテンツの例:
{ "kind": "plugin", "pluginName": "QueueSource", "configMap": { "queueId": "<queue_json_input>" } }
CLIコマンドのパラメータおよび値の完全なリストは、CLIコマンド・リファレンスを参照してください。
CreateServiceConnector操作を実行して、コネクタを作成します。
キュー・ソースを持つコネクタを作成するには、リクエスト(CreateServiceConnectorDetails)の
source
に、キューを使用するコネクタ・プラグイン(pluginName
QueueSource
、各キューOCIDはconfigMap
)を移入します。例については、PluginSourceDetailsを参照してください。