RunMongoAggregation 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-mongodb-nar

説明¶

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

タグ¶

aggregate, aggregation, mongo

入力要件¶

ALLOWED

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

false

プロパティ¶

プロパティ	説明
バッチサイズ	バッチでサーバーから返される要素の数。
モンゴ・コレクション名	使用するコレクションの名前
Mongo データベース名	使用するデータベース名
allow-disk-use	大きなデータセットを扱うときに、集約パイプラインのステージング中にメモリ使用量の上限を超えないようにするために、一時ファイルにデータを書き込むことを有効にするには、これをtrueにセットします。
json-type	デフォルトでは、 MongoDB の Java ドライバーは "extended JSON" を返します。この JSON のバリアントの機能のいくつかは、標準的な JSON タイプと規約のみを期待する他の JSON パーサーに問題を引き起こすかもしれません。この構成設定は、拡張 JSON を使用するか、標準 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	集約の結果セットは、このリレーションシップに送られます。