GetMongoRecord 2025.5.31.15

バンドル

org.apache.nifi | nifi-mongodb-nar

説明

MongoDB 結果セットを書き込むために Record ライターを使用する GetMongo の記録ベースのバージョン。

タグ

fetch, get, json, mongo, mongodb, record

入力要件

ALLOWED

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

false

プロパティ

プロパティ

説明

バッチサイズ

バッチでサーバーから返される要素の数。

Limit

返す要素の最大数

モンゴ・コレクション 名

使用するコレクションの名前

Mongo データベース名

使用するデータベース名

投影

結果セット内の文書から返されるフィールド。有効な BSON 文書でなければなりません。

クエリ

検索を行う選択基準。フィールドが空白のままだと、他のプロセッサーからの接続からの入力を探し、 FlowFile の本文の中に有効な JSON ドキュメントとしてクエリを提供します。このフィールドが空白のままで、着信接続の代わりにタイマーが有効になっている場合、 "{}" クエリを使用してフル・コレクション・フェッチになります。

ソート

有効な BSON ドキュメントである必要があります。

get-mongo-record-writer-factory

結果セットの書き込みに使用するRecord Writer。

mongo-client-service

構成されている場合、このプロパティは接続プーリングに割り当てられたクライアント・サービスを使用します。

mongo-query-attribute

セットされた場合、クエリは出力フローファイルの指定された属性に書き込まれます。

mongodb-schema-name

クエリ結果に使用する、構成済みスキーマ・レジストリ内のスキーマ名。

リレーションシップ

名前

説明

failure

失敗したクエリの実行に含まれるすべての入力 FlowFiles。

original

クエリ実行の一部であるすべての入力 FlowFiles はここにあります。

success

クエリ実行に成功した結果を持つすべての FlowFiles。

属性の書き込み

名前

説明

mongo.database.name

結果を取得したデータベース。

mongo.collection.name

結果が得られたコレクション。