RunMongoAggregation
RunMongoAggregation
FlowFile이 수신될 때마다 집계 쿼리를 실행하는 MongoDB 프로세서예요. 집계 결과를 results 관계로 보내고, 성공/실패 여부에 따라 원본 FlowFile도 라우팅해요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-mongodb-nar
설명 (Description)
flowfile이 수신될 때마다 집계 쿼리를 실행하는 프로세서입니다.
태그 (Tags)
aggregate, aggregation, mongo
입력 요구사항 (Input Requirement)
ALLOWED
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Batch Size | 서버에서 한 배치에 반환되는 요소 수입니다. |
| Mongo Collection Name | 사용할 컬렉션의 이름입니다. |
| Mongo Database Name | 사용할 데이터베이스의 이름입니다. |
| allow-disk-use | 대용량 데이터 집합을 처리할 때 집계 파이프라인 단계에서 최대 메모리 사용 제한을 초과하지 않도록 임시 파일에 데이터를 쓰는 것을 활성화하려면 true로 설정합니다. |
| json-type | 기본적으로 MongoDB의 Java 드라이버는 "extended JSON"을 반환합니다. 이 JSON 변형의 일부 기능은 표준 JSON 타입과 규칙만 기대하는 다른 JSON 파서에 문제를 일으킬 수 있습니다. 이 구성 설정은 extended JSON을 사용할지, 표준 JSON을 따르는 깔끔한 뷰를 제공할지를 제어합니다. |
| mongo-agg-query | 실행할 집계 쿼리입니다. |
| mongo-charset | 문서 데이터의 문자 집합을 지정합니다. |
| mongo-client-service | 구성되면 이 속성은 연결 풀링을 위해 할당된 client service를 사용합니다. |
| mongo-date-format | Mongo에서 반환된 Date 필드의 형식을 지정하는 데 사용할 날짜 형식 문자열입니다. JSON 출력 형식이 Standard JSON으로 설정된 경우에만 적용됩니다. |
| mongo-query-attribute | 설정되면 쿼리가 출력 flowfile의 지정된 속성에 기록됩니다. |
| results-per-flowfile | 한 번에 flowfile에 넣을 결과 수입니다. 전체 본문은 결과의 JSON 배열로 처리됩니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | 쿼리가 실패하면 입력 flowfile이 이 관계로 보내집니다. |
| original | 쿼리가 성공하면 입력 flowfile이 이 관계로 보내집니다. |
| results | 집계의 결과 집합이 이 관계로 보내집니다. |