PutMongoRecord 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-mongodb-nar

説明¶

このプロセッサーは、 MongoDB にデータを挿入／アップサートするための記録認識プロセッサーです。構成されたRecord Readerとスキーマを使用して、フローファイルの本文から受信記録セットを読み取り、それらの記録のバッチを構成された MongoDB コレクションに挿入/アップサートします。このプロセッサーは削除をサポートしていません。一度に挿入/アップサートするドキュメントの数は、「バッチサイズ」構成プロパティによって制御されます。この値は、 MongoDB が一度に多くの演算子で過負荷にならないように、適度な大きさにセットする必要があります。

タグ¶

insert, mongodb, put, record, update, upsert

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
モンゴ・コレクション名	使用するコレクションの名前
Mongo データベース名	使用するデータベース名
bypass-validation	挿入または更新操作時にドキュメントスキーマ検証をバイパスすることを有効または無効にします。ドキュメント検証の回避は、 MongoDB における権限アクションです。このプロパティを有効にすると、権限が制限されているユーザーに対して認証エラーが発生することがあります。
insert_count	MongoDB に対する 1 回の挿入/アップサート操作でグループ化する記録数。
mongo-client-service	構成されている場合、このプロパティは接続プーリングに割り当てられたクライアント・サービスを使用します。
ordered	順序付きまたは順序なしの演算子の実行
record-reader	受信データのパースとスキーマの決定に使用する Controller Service を指定します。
update-key-fields	更新が必要なドキュメントを識別するためのフィールドのカンマ区切りリスト。このプロパティがセットされている場合、 NiFi はすべての文書に対してアップサート操作を試みます。このプロパティがセットされていない場合、すべてのドキュメントが挿入されます。
update-mode	単一のドキュメントを更新するか、受信記録ごとに複数のドキュメントを更新するかを選択します。

リレーションシップ¶

名前	説明
failure	MongoDB に書き込めないすべての FlowFiles は、このリレーションシップにルーティングされます。
success	MongoDB に書き込まれたすべての FlowFiles は、このリレーションにルーティングされます。