5.13. MongoDB
5.13.1. camel-mongodb-kafka-connector sink configuration リンクのコピーリンクがクリップボードにコピーされました!
コネクターの説明: MongoDB ドキュメントおよびコレクションに対して操作を実行します。
camel-mongodb-kafka-connector をシンクとして使用する場合、以下の Maven 依存関係を使用してコネクターをサポートするようにしてください。
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-mongodb-kafka-connector</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel Kafka connector version -->
</dependency>
Kafka コネクションでこのシンクコネクターを使用するには、以下の connector.class を設定する必要があります。
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnector
camel-mongodb シンクコネクターは、以下に示す 24 のオプションをサポートします。
| 名前 | 説明 | デフォルト | 必要性 | 優先順位 |
|---|---|---|---|---|
| camel.sink.path.connectionBean | データベースに接続するためにクライアントをルックアップするために使用される接続 Bean 参照を設定します。 | null | true | HIGH |
| camel.sink.endpoint.collection | このエンドポイントにバインドする MongoDB コレクションの名前を設定します | null | false | MEDIUM |
| camel.sink.endpoint.collectionIndex | コレクションのインデックスを設定します (JSON FORMAT : { field1 : order1、field2 : order2}) | null | false | MEDIUM |
| camel.sink.endpoint.createCollection | コレクションが存在しない場合は、初期化中にコレクションを作成します。デフォルトは true です。 | true | false | MEDIUM |
| camel.sink.endpoint.database | ターゲットに設定する MongoDB データベースの名前を設定します | null | false | MEDIUM |
| camel.sink.endpoint.mongoConnection | データベースに接続するためのクライアントとして使用される接続 Bean を設定します。 | null | false | MEDIUM |
| camel.sink.endpoint.operation | このエンドポイントが MongoDB に対して実行する操作を設定します。[findById] [findOneByQuery] [findAll] [findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate] [getDbStats] [getColStats] [count] [command] のいずれか | null | false | MEDIUM |
| camel.sink.endpoint.outputType | プロデューサの出力を選択したタイプ (DocumentList Document または MongoIterable) に変換します。DocumentList または MongoIterable は、findAll および aggregate に適用されます。ドキュメントは、他のすべての操作に適用されます。One of: [DocumentList] [Document] [MongoIterable] | null | false | MEDIUM |
| camel.sink.endpoint.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.sink.endpoint.cursorRegenerationDelay | MongoDB の Tailable カーソルは、新しいデータが到着するまでブロックされます。新しいデータが挿入されない場合、しばらくするとカーソルが自動的に解放され、MongoDB サーバーによって閉じられます。クライアントは、必要に応じてカーソルを再生成する必要があります。この値は、新しいカーソルのフェッチを試行するまでの待機時間と、試行が失敗した場合に次の試行が行われるまでの時間を指定します。デフォルト値は 1000ms です。 | 1000L | false | MEDIUM |
| camel.sink.endpoint.dynamicity | このエンドポイントが受信 Exchange プロパティーからターゲットデータベースとコレクションを動的に解決しようとするかどうかを設定します。それ以外の場合は静的なエンドポイント URI で指定されたデータベースとコレクションを実行時にオーバーライドするために使用できます。パフォーマンスを向上させるために、デフォルトでは無効になっています。有効にすると、パフォーマンスへの影響は最小限に抑えられます。 | false | false | MEDIUM |
| camel.sink.endpoint.readPreference | MongoDB クライアントが読み取り操作をレプリカセットのメンバーにルーティングする方法を設定します。使用可能な値は、PRIMARY、PRIMARY_PREFERRED、SECONDARY、SECONDARY_PREFERRED または NEAREST 次のいずれか [PRIMARY] [PRIMARY_PREFERRED] [SECONDARY] [SECONDARY_PREFERRED] [NEAREST] | PRIMARY | false | MEDIUM |
| camel.sink.endpoint.writeConcern | スタンドアロンの mongod、レプリカセット、またはクラスターへの書き込み操作のために MongoDB から要求された確認応答のレベルで接続 Bean を設定します。可能な値は、ACKNOWLEDGED、W1、W2、W3、UNACKNOWLEDGED、JOURNALED、または MAJORITY です。次のいずれか: [ACKNOWLEDGED] [W1] [W2] [W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | ACKNOWLEDGED | false | MEDIUM |
| camel.sink.endpoint.writeResultAsHeader | 書き込み操作では、OUT メッセージのボディとして WriteResult を返す代わりに、IN メッセージを OUT に転送し、WriteResult をヘッダーとして添付するかどうかを決定します。 | false | false | MEDIUM |
| camel.sink.endpoint.streamFilter | 変更ストリームコンシューマーのフィルター条件。 | null | false | MEDIUM |
| camel.sink.endpoint.persistentId | 1 つのテールトラッキングコレクションで、複数のテーラブルコンシューマー用に多数のトラッカーをホストできます。それらを分離しておくために、各トラッカーには独自の固有の persistentId が必要です。 | null | false | MEDIUM |
| camel.sink.endpoint.persistentTailTracking | 永続的な tail トラッキングを有効にします。これは、システムの再起動時に最後に消費されたメッセージを追跡するメカニズムです。次にシステムが起動すると、エンドポイントは最後にレコードを一気に読み込むのを停止した地点からカーソルを回復します。 | false | false | MEDIUM |
| camel.sink.endpoint.tailTrackCollection | テールトラッキング情報が保持されるコレクション。指定しない場合、MongoDbTailTrackingConfig#DEFAULT_COLLECTION がデフォルトで使用されます。 | null | false | MEDIUM |
| camel.sink.endpoint.tailTrackDb | テールトラッキングメカニズムが保持されるデータベースを示します。指定しない場合、現在のデータベースがデフォルトで選択されます。動的性は有効になっていても考慮されません。つまり、テールトラッキングデータベースは、エンドポイントの初期化を過ぎても変化しません。 | null | false | MEDIUM |
| camel.sink.endpoint.tailTrackField | 最後に追跡された値が配置されるフィールド。指定しない場合、MongoDbTailTrackingConfig#DEFAULT_FIELD がデフォルトで使用されます。 | null | false | MEDIUM |
| camel.sink.endpoint.tailTrackIncreasingField | 増加する性質の着信レコードの相関フィールドであり、生成されるたびに tail カーソルを配置するために使用されます。カーソルは次のタイプの tailTrackIncreasingField で (再) 作成されます:整数、日付、文字列などの型にすることができます。注: 現時点ではドット表記がサポートされていないため、フィールドはドキュメントの最上位にある必要があります。 | null | false | MEDIUM |
| camel.component.mongodb.mongoConnection | 接続に使用される共有クライアント。コンポーネントから生成されたすべてのエンドポイントは、この接続クライアントを共有します。 | null | false | MEDIUM |
| camel.component.mongodb.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.component.mongodb.autowiredEnabled | 自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。 | true | false | MEDIUM |
camel-mongodb シンクコネクターには、すぐに使えるコンバーターはありません。
camel-mongodb シンクコネクターには、すぐに使える変換はありません。
camel-mongodb シンクコネクターには、すぐに使用できる集約ストラテジーはありません。