RunMongoAggregation 2025.10.2.19¶

번들¶

org.apache.nifi | nifi-mongodb-nar

설명¶

flowfile이 수신될 때마다 집계 쿼리를 실행하는 프로세서입니다.

태그¶

aggregate, aggregation, mongo

입력 요구 사항¶

ALLOWED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Batch Size	서버에서 한 배치로 반환된 요소의 수입니다.
Mongo 컬렉션 이름	사용할 컬렉션의 이름
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 출력 형식이 표준 JSON 으로 설정된 경우에만 적용됩니다.
mongo-query-attribute	설정하면 쿼리가 출력 flowfile의 지정된 특성에 기록됩니다.
results-per-flowfile	한 번에 얼마나 많은 결과를 flowfile에 넣을지 결정합니다. 본문 전체가 JSON 결과 배열로 처리됩니다.

관계¶

이름	설명
실패	쿼리가 실패하면 입력 flowfile은 이 관계로 전송됩니다.
원본	쿼리가 성공하면 입력 flowfile은 이 관계로 전송됩니다.
결과	집계 결과 세트가 이 관계로 전송됩니다.