Flex Gateway新着情報
Governance新着情報
Monitoring API ManagerMongoDB 用 Anypoint Connector (MongoDB Connector) は、Mule Runtime Engine (Mule) と MongoDB サーバー上のサードパーティソフトウェア間の接続を可能にするクローズドソースのコネクタです。
リリースノート: MongoDB Connector リリースノート
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Name (名前) |
String (文字列) |
この設定の名前。コネクタはこの名前の設定を参照します。 |
x |
|
Connection (接続) |
この設定に指定する接続型。 |
x |
||
Read Concern (読み取りの問題) |
Enumeration (列挙)。次のいずれかになります。
|
レプリカセットやレプリカセットシャードから読み込まれたデータの一貫性および分離プロパティを制御できます。 |
||
Read Preference (読み取り設定) |
Enumeration (列挙)。次のいずれかになります。
|
この接続の読み取り設定を指定します。 |
PRIMARY |
|
Maximum Staleness Seconds (最大期限 (秒)) |
Number (数値) |
クライアントが読み取り操作で MongoDB クラスターのセカンダリノードを使用しなくなるまでの期限を秒単位で指定します。 |
-1 |
|
Read Preference Tags (読み取り設定タグ) |
レプリカセットメンバーがタグに関連付けられている場合、読み取り設定でタグセット (タグ仕様ドキュメントの配列) を指定して、それらのメンバーを対象にすることができます。 |
|||
Expiration Policy (有効期限ポリシー) |
動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。これは、インスタンスが有効期限の対象となった瞬間にプラットフォームでそのインスタンスが期限切れになるということではありません。必要に応じて、インスタンスがパージされます。 |
|||
Write Concern Acknowledgment (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
SECONDS |
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Servers (host:port) (サーバー (host:port)) |
MongoDB インスタンスが配置されるサーバー。複数のサーバーを指定できます。 |
x |
||
Database (データベース) |
String (文字列) |
接続するデータベース名を指定します。 |
x |
|
Username (ユーザー名) |
String (文字列) |
認証に使用するユーザー名。 |
||
Password (パスワード) |
String (文字列) |
認証に使用するパスワード。認証を使用しない場合、パスワードとユーザー名の両方を空にする必要があります。 |
||
Replica Set Name (レプリカセット名) |
String (文字列) |
接続するレプリカセットの名前。この項目を使用して MongoDB クラスターに接続します。 |
||
Authentication Source (認証ソース) |
String (文字列) |
|||
Compressors (圧縮ツール) |
Array of String (文字列の配列) |
クライアントと mongod または mongos インスタンス間の通信のネットワーク圧縮を有効にする圧縮ツールのリスト。複数の圧縮ツールを指定した場合、圧縮ツールをリストする順序が重要になります。ドライバーはリストの最初の圧縮ツールを使用します。 |
||
Zlib Compression Level (Zlib 圧縮レベル) |
Number (数値) |
zlib を使用してネットワークを圧縮する場合の圧縮レベルを指定する整数。 |
-1 |
|
Connection Timeout (接続タイムアウト) |
Number (数値) |
ソケット接続を確立する場合の接続タイムアウト。接続がタイムアウトしないようにする場合は、この項目を |
30 |
|
Connection Timeout Timeunit (接続タイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
接続タイムアウトの単位。 |
SECONDS |
|
Local Threshold (ローカルしきい値) |
Number (数値) |
複数の適切な MongoDB インスタンスの中から選択する場合のレイテンシー期間のサイズ。 |
15 |
|
Local Threshold Time Unit (ローカルしきい値時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
ローカルしきい値の時間単位。 |
MILLISECONDS |
|
Server Selection Timeout (サーバー選択タイムアウト) |
Number (数値) |
例外をスローするまでのサーバー選択のブロック期間を指定します。 |
30 |
|
Server Selection Timeout Time Unit (サーバー選択タイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
サーバー選択の時間単位。 |
SECONDS |
|
Socket Timeout (ソケットタイムアウト) |
Number (数値) |
ソケットのタイムアウト。I/O ソケットの読み取りおよび書き込み操作で使用されます。デフォルトは 0 です。ソケットの読み取りおよび書き込み操作がタイムアウトしないようにする場合は、この項目を |
||
Socket Timeout Unit (ソケットタイムアウト単位) |
Enumeration (列挙)。次のいずれかになります。
|
ソケットタイムアウトの単位。 |
SECONDS |
|
Retry Writes (書き込みを再試行) |
Boolean (ブール) |
再試行可能な書き込みを有効にします。 |
false |
|
Authentication Mechanism (認証メカニズム) |
Enumeration (列挙)。次のいずれかになります。
|
この接続で使用される認証メカニズム。 |
||
Tls Context (TLS コンテキスト) |
||||
Min Connection Pool Size (最小接続プールサイズ) |
Number (数値) |
接続プールの最小サイズ。 |
||
Max Connection Pool Size (最大接続プールサイズ) |
Number (数値) |
接続プールの最大サイズ。 |
100 |
|
Max Wait Queue Time (最大待機キュー時間) |
Number (数値) |
接続プールの最大待機キュー時間。 |
120 |
|
Max Wait Queue Time Unit (最大待機キュー時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
接続プールの最大待機キュー時間単位。 |
SECONDS |
|
Max Connection Life Time (最大接続有効期間) |
Number (数値) |
接続プールの最大接続有効期間。 |
||
Max Connection Life Time Unit (最大接続有効期間単位) |
Enumeration (列挙)。次のいずれかになります。
|
接続プールの最大接続有効期間の時間単位。 |
SECONDS |
|
Max Connection Idle Time (最大接続アイドル時間) |
Number (数値) |
接続プールの最大接続アイドル時間。 |
||
Max Connection Idle Time Unit (最大接続アイドル時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
接続プールの最大接続アイドル時間の時間単位。 |
SECONDS |
|
Reconnection (再接続) |
アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。 |
<mongo:object-listener>
|
このソース (リスナー) では、ウォーターマークの保存にオブジェクトストアが使用されます。使用しているオブジェクトストアの実装 (CloudHub デプロイメント用のオブジェクトストアやオンプレミスデプロイメント用のオブジェクトストア) に固有の制限がある可能性があるため、ニーズに合わせてオブジェクトストアを設定してください。 詳細は、 「The Different Types of Object Stores Explained (異なる種別のオブジェクトストアの説明)」を参照してください。 |
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
一致するドキュメントを検出するために監視するコレクション。 |
x |
|
Watermark Field (ウォーターマーク項目) |
String (文字列) |
トリガー条件に一致するオブジェクトを検出するために照会する項目。 |
x |
|
Primary Node Only (プライマリノードのみ) |
Boolean (ブール) |
クラスターでの実行時にこのソースをプライマリノード上でのみ実行する必要があるかどうかを示します。 |
||
Scheduling Strategy (スケジュール戦略) |
scheduling-strategy |
ポーリングをトリガーするスケジューラーを設定します。 |
x |
|
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Redelivery Policy (再配信ポリシー) |
同じメッセージの再配信を処理するためのポリシー。 |
|||
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:add-user>
このデータベースの新しいユーザーを追加します。
<mongo:collection-exists>
指定されたコレクションが存在する場合、true を返します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
コレクションの名前。 |
x |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:count-documents>
指定したクエリに一致するドキュメント数を数えます。クエリが渡されなかった場合、この操作はコレクション内の要素数を返します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
対象のコレクション。 |
x |
|
Query (クエリ) |
Binary (バイナリ) |
ドキュメントを数えるための省略可能なクエリ。クエリに一致するドキュメントのみが数えられます。指定されていない場合は、すべてのドキュメントが数えられます。値は {"field1": "value1"} のようになります。また、{"field1": {$gte: 1, $lt: 10}} ように演算子を含めることもできます。 |
||
Write Concern Acknowledgement (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:create-collection>
新しいコレクションを作成します。コレクションがすでに存在する場合は、MongoException がスローされます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
作成するコレクションの名前。 |
x |
|
Max Objects (最大オブジェクト数) |
Number (数値) |
新しいコレクションに含めることができるドキュメントの最大数。 |
||
Collection Size (コレクションサイズ) |
Number (数値) |
新しいコレクションの最大サイズ。 |
||
Collection Size Data Unit (コレクションサイズデータ単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Collection Size (コレクションサイズ)] パラメーターのデータ単位 (デフォルトではバイト)。 |
BYTE (バイト) |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:create-file>
データベースに新しいファイルを作成し、指定された content、filename、contentType、extraData を保存します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Content (コンテンツ) |
Binary (バイナリ) |
新しいファイルのコンテンツ。このコンテンツは InputStream です。 |
#[payload] |
x |
Filename (ファイル名) |
String (文字列) |
新しいファイルの名前。 |
x |
|
Metadata (メタデータ) |
Binary (バイナリ) |
保存する情報を保持する JSON オブジェクト。 |
||
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:create-index>
新しいインデックスを作成します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
インデックスが作成されるコレクションの名前。 |
x |
|
Field Name (項目名) |
String (文字列) |
インデックスを付ける項目の名前。 |
x |
|
Sort Order (並び替え順) |
Enumeration (列挙)。次のいずれかになります。
|
インデックスを付ける順序。 |
ASC |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:drop-collection>
コレクションとそのコレクションに含まれるすべてのオブジェクトを削除します。コレクションが存在しない場合、この操作は NOT_FOUND エラーをスローします。
<mongo:drop-database>
現在のデータベースを削除します。
<mongo:drop-index>
既存のインデックスを削除します。
<mongo:dump>
指定した出力ディレクトリへのデータベースのダンプを実行します。出力ディレクトリが指定されていない場合は、デフォルトの /dump ディレクトリが使用されます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Output Directory (出力ディレクトリ) |
String (文字列) |
ダンプファイルが作成される出力ディレクトリ。 |
x |
|
Output Name Prefix (出力名プレフィックス) |
String (文字列) |
出力ファイル名のプレフィックス。指定されていない場合は、データベース名が使用されます。 |
||
Oplog |
Boolean (ブール) |
任意の時点のバックアップ (oplog が必要)。 |
false |
|
Operation Timeout (操作タイムアウト) |
Number (数値) |
ダンプの最大待機時間。 |
60 |
|
Operation Timeout Unit (操作タイムアウト単位) |
Enumeration (列挙)。次のいずれかになります。
|
ダンプの最大待機時間の時間単位。 |
SECONDS |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:execute-command>
データベースでコマンドを実行します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Command (コマンド) |
Binary (バイナリ) |
ドキュメントとしてデータベースで実行するコマンド。 |
#[payload] |
|
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:find-documents>
指定したクエリに一致するすべてのドキュメントを検索します。クエリが指定されていない場合は、コレクションのすべてのドキュメントを取得します。項目オブジェクトが指定されていない場合は、すべての項目を取得します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Query (クエリ) |
Binary (バイナリ) |
ドキュメントを検索するための省略可能なクエリ。指定されていない場合は、すべてのドキュメントが取得されます。値は {"field1": "value1"} のようになります。また、{"field1": {$gte: 1, $lt: 10}} ように演算子を含めることもできます。 |
||
Sort By (並び替え基準) |
Binary (バイナリ) |
結果リストを並び替えることができます。ファイルは、file_id または uploadDate でのみ並び替えることができます。 |
||
Page Size (ページサイズ) |
Number (数値) |
返される各ページのドキュメントのサイズ。 |
100 |
|
Limit (制限) |
Number (数値) |
返されるドキュメントの制限。 |
||
Write Concern Acknowledgement (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
||
Streaming Strategy (ストリーミング戦略) |
|
メッセージのストリーミング戦略を設定します。 |
||
Collection Name (コレクション名) |
String (文字列) |
x |
||
Fields (項目) |
String (文字列) |
各ドキュメントから返される項目のカンマ区切りのリスト。ドキュメントのすべての項目を取得するには、この値を |
x |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:find-files>
指定したクエリに一致するすべてのファイルをリストします。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Query (クエリ) |
Binary (バイナリ) |
すべてのファイルをリストするために使用されるクエリオブジェクト。値は {"field1": "value1"} のようになります。また、{"field1": {$gte: 1, $lt: 10}} ように演算子を含めることもできます。 |
||
Sort (並び替え) |
Binary (バイナリ) |
結果リストを並び替えることができます。ファイルは、file_id または uploadDate でのみ並び替えることができます。 |
||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:get-file-content>
ファイル ID で指定されたファイルのコンテンツに対する InputStream を取得します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
File Id (ファイル ID) |
Binary (バイナリ) |
必須のファイル ID。 |
#[payload] |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:insert-document>
ドキュメントをコレクションに挿入します。id 項目を使用してオブジェクトを指定しない場合、MongoDB によって自動的に生成されます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
指定したドキュメントを挿入するコレクションの名前 |
x |
|
Document (ドキュメント) |
Binary (バイナリ) |
挿入するドキュメント。 |
#[payload] |
|
Write Concern Acknowledgement (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
||
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:insert-documents>
ドキュメントをコレクションに挿入します。_id 項目を使用してオブジェクトを指定しない場合、MongoDB によって自動的に生成されます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
指定したドキュメントを挿入するコレクションの名前。 |
x |
|
Documents (ドキュメント) |
Binary (バイナリ) |
挿入するドキュメントのリスト。 |
#[payload] |
|
Write Ordered (Write の順序付け) |
Boolean (ブール) |
ドキュメントのリストが順番に実行されるかどうかを示します。true に設定し、いずれかの書き込み操作の処理時にエラーが生じた場合、MongoDB はリストの残りの書き込み操作を処理せずに戻ります。 |
false |
|
Write Concern Acknowledgement (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:list-collections>
このデータベースで使用可能なコレクションの名前をリストします。
<mongo:list-indexes>
コレクションの既存のインデックスをリストします。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
コレクションの名前。 |
x |
|
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
型 |
インデックス の配列 |
<mongo:map-reduce>
次のようにコレクションを集約グループのコレクションに変換します。 . 付属の要素マッピング関数を各要素に適用して、各要素をキー-値ペアに変換します。 . 変換後のペアをキー別にグループ化します。 . JavaScript でコーディングされた付属の「reduce」関数を適用して各グループの値を減らします。
詳細は、MongoDB のドキュメントを参照してください。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
マップして減らすコレクションの名前。 |
x |
|
Mapping Function (マッピング関数) |
String (文字列) |
JavaScript でエンコードしたマッピング関数。 |
x |
|
Reduce Function (縮約関数) |
String (文字列) |
JavaScript でエンコードした縮約関数。 |
x |
|
Output Collection (出力コレクション) |
String (文字列) |
結果を書き込む出力コレクションの名前。これにより、既存のコレクションが置き換えられます (ある場合)。結果のオブジェクトが 16MB より大きい場合、この項目は必須です。Output Collection (出力コレクション) が指定されていない場合は、演算がメモリ内で行われ、保持されません。 |
||
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:remove-documents>
指定したクエリに一致するすべてのドキュメントを削除します。クエリが指定されていない場合は、すべてのドキュメントが削除されます。この操作を使用するよりも、接続を削除して再作成する方が効率的です。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
要素を削除するコレクション。 |
x |
|
Query (クエリ) |
Binary (バイナリ) |
削除する要素の検出に使用するクエリオブジェクト。値は {"field1": "value1"} のようになります。また、{"field1": {$gte: 1, $lt: 10}} ように演算子を含めることもできます。 |
||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:remove-files>
指定したファイル ID に一致するファイルを削除します。ファイル ID が指定されていない場合は、すべてのファイルを削除します。
<mongo:restore-from-directory>
Dump 操作から出力を取り出して復元し、インデックスを生成します。この操作では、ID がまだデータベースに存在していないレコードのみが挿入されます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Input Path (入力パス) |
String (文字列) |
ダンプファイルの入力パス。このパスはディレクトリである必要があります。 |
x |
|
Drop Collections (コレクションを削除) |
Boolean (ブール) |
復元を実行する前に既存のコレクションを削除するかどうか。 |
false |
|
Oplog Replay (oplog の再生) |
Boolean (ブール) |
任意の時点の復元で oplog を再生します。 |
false |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:restore-from-file>
1 つの .bson ファイルまたは zip ファイルを復元します。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
復元するコレクションの名前。 |
x |
|
Input (入力) |
Binary (バイナリ) |
ダンプファイルを参照する InputStream。zip ファイルまたは .bson ファイルのいずれかにできます。 |
#[payload] |
|
Drop Collection |
Boolean (ブール) |
復元を実行する前に既存のコレクションを削除するかどうか。 |
false |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
<mongo:update-documents>
指定したクエリに一致するドキュメントを更新します。クエリが指定されていない場合は、すべてのドキュメントが取得されます。複数のパラメーターが false に設定されている場合は、クエリに一致する最初のドキュメントのみが更新されます。それ以外の場合は、クエリに一致するすべてのドキュメントが更新されます。
| 名前 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Configuration (設定) |
String (文字列) |
使用する設定の名前。 |
x |
|
Collection Name (コレクション名) |
String (文字列) |
更新するコレクションの名前。 |
x |
|
Query (クエリ) |
Binary (バイナリ) |
更新する要素の検出に使用するクエリオブジェクト。値は {"field1": "value1"} のようになります。また、{"field1": {$gte: 1, $lt: 10}} ように演算子を含めることもできます。 |
||
Content To Update (更新するコンテンツ) |
Binary (バイナリ) |
クエリに一致するオブジェクトを置換するオブジェクト。 |
#[payload] |
|
Multiple Update (複数の更新) |
Boolean (ブール) |
クエリに一致する最初のドキュメントのみを更新するかどうかを示します。 |
false |
|
Upsert |
Boolean (ブール) |
true に設定されていると、クエリ条件に一致するドキュメントがない場合に新しいドキュメントが作成されます。デフォルト値は false で、一致が見つからない場合に新しいドキュメントは挿入されません。 |
false |
|
Write Concern Acknowledgement (書き込みの問題の肯定応答) |
String (文字列) |
指定の数の MongoDB インスタンスに伝播された書き込み操作に関して MongoDB から要求された肯定応答のレベル。インスタンスの数 ( |
||
Write Concern Timeout (書き込みの問題のタイムアウト) |
Number (数値) |
[Write Concern Acknowledgement (書き込みの問題の肯定応答)] の時間制限をミリ秒単位で指定します。値は |
||
Write Concern Timeout Timeunit (書き込みの問題のタイムアウト時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
[Write Concern Timeout (書き込みの問題のタイムアウト)] の時間単位 |
||
Streaming Strategy (ストリーミング戦略) |
メッセージのストリーミング戦略を設定します。 |
|||
Target Variable (対象変数) |
String (文字列) |
操作の出力を保存する変数の名前 |
||
Target Value (対象値) |
String (文字列) |
操作の出力に対して評価される式。この式の結果が対象変数に保存されます。 |
#[payload] |
|
Reconnection Strategy (再接続戦略) |
接続エラーが発生した場合の再試行戦略。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Host (ホスト) |
String (文字列) |
接続するホスト。 |
x |
|
Port (ポート) |
Number (数値) |
接続するホストのポート。 |
27017 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Enabled Protocols (有効化されたプロトコル) |
String (文字列) |
このコンテキストで有効化されたプロトコルのカンマ区切りリスト。 |
||
Enabled Cipher Suites (有効化された暗号化スイート) |
String (文字列) |
このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。 |
||
Trust Store (トラストストア) |
||||
Key Store (キーストア) |
||||
Revocation Check (取り消し確認) |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Path (パス) |
String (文字列) |
トラストストアの場所 (可能な場合、現在のクラスパスとファイルシステムを基準として解決されます)。 |
||
Password (パスワード) |
String (文字列) |
トラストストアを保護するために使用するパスワード。 |
||
Type (型) |
String (文字列) |
使用するストアの型。 |
||
Algorithm (アルゴリズム) |
String (文字列) |
トラストストアで使用するアルゴリズム。 |
||
Insecure (安全ではない) |
Boolean (ブール) |
true の場合、証明書の検証が行われず、接続が攻撃に対して脆弱になります。この値は各自の責任で使用してください。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Path (パス) |
String (文字列) |
キーストアの場所 (可能な場合、現在のクラスパスとファイルシステムを基準として解決されます)。 |
||
Type (型) |
String (文字列) |
使用するストアの型。 |
||
Alias (別名) |
String (文字列) |
キーストアに多数の非公開キーがある場合、この属性は、使用する鍵の別名を示します。定義しない場合、ファイルにある最初のキーがデフォルトで使用されます。 |
||
Key Password (キーパスワード) |
String (文字列) |
非公開キーを保護するために使用するパスワード。 |
||
Password (パスワード) |
String (文字列) |
キーストアを保護するために使用するパスワード。 |
||
Algorithm (アルゴリズム) |
String (文字列) |
キーストアで使用するアルゴリズム。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Only End Entities (最後のエンティティのみ) |
Boolean (ブール) |
証明書チェーンの最後の要素のみを確認します。 |
||
Prefer Crls (CRL を優先) |
Boolean (ブール) |
最初に OCSP ではなく CRL を試みます。 |
||
No Fallback (代替なし) |
Boolean (ブール) |
第 2 の確認方法 (以前に選択されていない方法) を使用しません。 |
||
Soft Fail (ソフトフェール) |
Boolean (ブール) |
取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に検証エラーを回避します。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Url |
String (文字列) |
OCSP レスポンダーの URL。 |
||
Cert Alias (証明書の別名) |
String (文字列) |
(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Fails Deployment (デプロイメントに失敗) |
Boolean (ブール) |
アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。 |
||
Reconnection Strategy (再接続戦略) |
使用する再接続戦略。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Frequency (頻度) |
Number (数値) |
再接続する頻度 (ミリ秒)。 |
||
Count (数) |
Number (数値) |
再接続を試みる回数 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Max Idle Time (最大アイドル時間) |
Number (数値) |
有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値 |
||
Time Unit (時間単位) |
Enumeration (列挙)。次のいずれかになります。
|
maxIdleTime 属性の時間単位 |
このモードでストリーミングする場合、Mule はコンテンツのバッファにディスクを使用しません。バッファサイズを超えた場合、メッセージは失敗します。
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Initial Buffer Size (初期バッファサイズ) |
Number (数値) |
ストリームをコンシュームしてランダムにアクセスするために割り当てられるメモリ量。このバッファに入りきらない量のデータがストリームに含まれている場合、バッファは bufferSizeIncrement 属性と maxInMemorySize の上限に従って拡張されます。 |
||
Buffer Size Increment (バッファサイズ増分) |
Number (数値) |
バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。 |
||
Max Buffer Size (最大バッファサイズ) |
Number (数値) |
使用するメモリの最大量。これを超えると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。0 以下の値は無制限を意味します。 |
||
Buffer Unit (バッファ単位) |
Enumeration (列挙)。次のいずれかになります。
|
これらのすべての属性の単位 |
ファイルストアの反復可能なストリームにはバッファが必要であり、さまざまなバッファ戦略があります。Mule はコンテンツの一部をメモリに保持します。ストリームのコンテンツが、設定されたバッファサイズよりも大きい場合、Mule はバッファのコンテンツをディスクにバックアップしてからメモリをクリアします。
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
In Memory Size (メモリ内サイズ) |
Number (数値) |
データをメモリ内に保持するためにストリームで使用する最大メモリを定義します。これを超えると、ディスクのコンテンツがバッファされます。 |
||
Buffer Unit (バッファ単位) |
Enumeration (列挙)。次のいずれかになります。
|
maxInMemorySize で表される単位 |
場合によって、反復可能ストリーム機能を無効にして反復不可能ストリームを使用することが必要になることがあります。これにより、パフォーマンスオーバーヘッド、メモリ使用量、およびコストが軽減される可能性があります。
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Transactional Action (トランザクションアクション) |
Enumeration (列挙)。次のいずれかになります。
|
トランザクションに関する操作で使用できる結合アクションの種別。 |
|
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Max Redelivery Count (最大再配信数) |
Number (数値) |
プロセス失敗メッセージをトリガーするまでに、正常に処理されないメッセージを再配信できる最大回数。 |
||
Use Secure Hash (セキュアハッシュを使用) |
Boolean (ブール) |
再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用するかどうか。 |
||
Message Digest Algorithm (メッセージダイジェストアルゴリズム) |
String (文字列) |
使用するセキュアハッシュアルゴリズム。 |
SHA-256 |
|
Id Expression (ID 式) |
String (文字列) |
メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式を定義します。このプロパティは、useSecureHash が |
||
Object Store (オブジェクトストア) |
Object Store (オブジェクトストア) |
各メッセージの再配信カウンターが保存されるオブジェクトストア。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Initial Buffer Size (初期バッファサイズ) |
Number (数値) |
ストリームをコンシュームし、ランダムアクセスを提供するために、最初にメモリ内に保持するインスタンスの数。ストリームのデータ量がこのバッファサイズを超える場合は、bufferSizeIncrement 属性に従って、maxInMemorySize を上限としてバッファが拡張されます。デフォルト値は 100 インスタンスです。 |
||
Buffer Size Increment (バッファサイズ増分) |
Number (数値) |
バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。デフォルト値は 100 インスタンスです。 |
||
Max Buffer Size (最大バッファサイズ) |
Number (数値) |
使用するメモリの最大量。これを超えると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。0 以下の値は無制限を意味します。 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
In Memory Objects (メモリ内オブジェクト) |
Number (数値) |
メモリ内に保持されるインスタンスの最大数。これ以上の量が必要な場合、ディスク上のコンテンツがバッファされます。 |
||
Buffer Unit (バッファ単位) |
Enumeration (列挙)。次のいずれかになります。
|
maxInMemorySize で表される単位 |
| 項目 | 型 | 説明 | デフォルト値 | 必須 |
|---|---|---|---|---|
Id |
Any (任意) |
|||
Items (項目) |
Bulk Item (一括項目) の配列 |
|||
Successful (成功) |
Boolean (ブール) |