RunMongoAggregation 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-mongodb-nar

설명¶

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

태그¶

aggregate, aggregation, mongo

입력 요구 사항¶

ALLOWED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Batch Size	서버에서 한 배치로 반환된 요소의 수입니다.
Mongo 컬렉션 이름	사용할 컬렉션의 이름
Mongo 데이터베이스 이름	사용할 데이터베이스의 이름입니다
allow-disk-use	대규모 데이터 세트를 처리할 때 스테이징된 집계 파이프라인이 최대 메모리 사용 제한을 초과하지 않도록 임시 파일에 데이터를 쓸 수 있게 하려면 이 옵션을 true로 설정합니다.
json-type	기본적으로 MongoDB 의 Java 드라이버는 “확장 JSON”을 반환합니다. 이 JSON 베리언트의 일부 기능은 표준 JSON 유형 및 규칙만 기대하는 다른 JSON 구문 분석기에 문제를 일으킬 수 있습니다. 이 구성 설정은 확장 JSON 을 사용할지 아니면 표준 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은 이 관계로 전송됩니다.
결과	집계 결과 세트가 이 관계로 전송됩니다.