RunMongoAggregation 2025.10.2.19¶

バンドル¶

org.apache.nifi | nifi-mongodb-nar

説明¶

フローファイルを受信するたびに集約クエリを実行するプロセッサー。

タグ¶

aggregate, aggregation, mongo

入力要件¶

ALLOWED

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

false

プロパティ¶

プロパティ	説明
バッチサイズ	バッチでサーバーから返される要素の数。
モンゴ・コレクション名	使用するコレクションの名前
Mongo データベース名	使用するデータベース名
allow-disk-use	大きなデータセットを扱うときに、集約パイプラインのステージング中にメモリ使用量の上限を超えないようにするために、一時ファイルにデータを書き込むことを有効にするには、これをtrueにセットします。
json-type	By default, MongoDB's Java driver returns "extended JSON". Some of the features of this variant of JSON may cause problems for other JSON parsers that expect only standard JSON types and conventions. This configuration setting controls whether to use extended JSON or provide a clean view that conforms to standard JSON.
mongo-agg-query	実行する集約クエリ。
mongo-charset	ドキュメントデータの文字セットを指定します。
mongo-client-service	構成されている場合、このプロパティは接続プーリングに割り当てられたクライアント・サービスを使用します。
mongo-date-format	Mongo から返される日付フィールドの形式に使う日付書式文字列。JSON 出力形式が Standard JSON にセットされている場合にのみ適用されます。
mongo-query-attribute	セットされた場合、クエリは出力フローファイルの指定された属性に書き込まれます。
results-per-flowfile	一度にフローファイルに入れる結果の数。本文は JSON の配列として扱われます。

リレーションシップ¶

名前	説明
failure	クエリが失敗した場合、入力フローファイルはこのリレーションシップに送られます。
original	クエリが成功すると、入力フローファイルはこのリレーションシップに送信されます。
results	集約の結果セットは、このリレーションシップに送られます。