PutMongo 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-mongodb-nar
説明¶
FlowFile のコンテンツを MongoDB に書き込みます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
---|---|
文字セット |
データがエンコードされている文字セット |
モード |
プロセッサーがコンテンツを挿入するか更新するかを示します。 |
モンゴ・コレクション 名 |
使用するコレクションの名前 |
Mongo データベース名 |
使用するデータベース名 |
更新方法 |
MongoDB updateOne や updateMany など、コレクションの更新操作を実行するためのメソッドです。 |
クエリキーの更新 |
更新クエリの条件を作成する際に使用する、1つまたは複数のカンマ区切りのドキュメントキー名 (例えば_id)。 |
アップサート |
trueの場合、更新クエリの条件に一致するドキュメントがない場合にドキュメントを挿入します。このプロパティは更新モードを使用している場合にのみ有効で、それ以外の場合は無視されます。 |
mongo-client-service |
構成されている場合、このプロパティは接続プーリングに割り当てられたクライアント・サービスを使用します。 |
put-mongo-update-mode |
更新モードを選択します。JSON ドキュメントを指定して直接置き換えることもできますし、 $set、$unset、$inc などの更新演算子を含むドキュメントを指定することもできます。演算子モードが有効な場合、フローファイルのコンテンツは、演算子部分であることが期待されます。例えば {$set:{"key": "value"}、$inc:{"count":1234}} と更新クエリは、構成された更新クエリ・プロパティから取得されます。 |
putmongo-update-query |
更新/アップサートを行うルックアップ・クエリに使用する完全な MongoDB クエリを指定します。NOTE: 「更新クエリキー」の値が空でない場合、このフィールドは無視されます。 |
リレーションシップ¶
名前 |
説明 |
---|---|
failure |
MongoDB に書き込めないすべての FlowFiles は、このリレーションシップにルーティングされます。 |
success |
MongoDB に書き込まれたすべての FlowFiles は、このリレーションにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
---|---|
mongo.put.update.match.count |
更新/アップサートが実行された場合は結果からのマッチカウント、そうでない場合はセットされません。 |
mongo.put.update.modify.count |
更新/アップサートが実行された場合は結果からの変更回数、そうでない場合はセットされません。 |
mongo.put.upsert.id |
アップサートが実行された場合は'_id'の16進数値、そうでない場合はセットされません。 |