GetMongo 프로세서
GetMongo 프로세서
Openflow의 GetMongo 프로세서는 사용자가 지정한 쿼리로 MongoDB에서 로드한 문서로부터 FlowFile을 생성하는 프로세서예요.
출처: Snowflake 문서
본문
기능 — 일반 공급 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있습니다.
Bundle
org.apache.nifi | nifi-mongodb-nar
설명
사용자가 지정한 쿼리로 MongoDB에서 로드한 문서에서 FlowFile을 생성합니다.
태그
get, mongodb, read
입력 요구사항
허용 (ALLOWED)
민감한 동적 속성 지원
false
속성
| 이름 | 설명 |
|---|---|
| Batch Size | 한 번의 배치로 서버에서 반환할 요소 수입니다. |
| Limit | 반환할 최대 요소 수입니다. |
| Mongo Collection Name | 사용할 컬렉션 이름입니다. |
| Mongo Database Name | 사용할 데이터베이스 이름입니다. |
| Projection | 결과 집합의 문서에서 반환할 필드로, 유효한 BSON 문서여야 합니다. |
| Query | 조회를 수행할 선택 기준입니다. 이 필드를 비워 두면 다른 프로세서의 인입 연결에서 유효한 JSON 문서 형식의 쿼리를 FlowFile 본문으로 제공받습니다. 필드가 비어 있고 인입 연결 대신 타이머가 활성화된 경우 "{}" 쿼리를 사용한 전체 컬렉션 조회가 수행됩니다. |
| Sort | 정렬할 필드로, 유효한 BSON 문서여야 합니다. |
| get-mongo-send-empty | 쿼리가 성공적으로 실행되었지만 결과가 없는 경우, 결과가 없음을 나타내는 빈 JSON 문서를 보냅니다. |
| json-type | 기본적으로 MongoDB Java 드라이버는 '확장 JSON(extended JSON)'을 반환합니다. 이 JSON 변형의 일부 기능은 표준 JSON 타입과 규칙만 기대하는 다른 JSON 파서에 문제를 일으킬 수 있습니다. 이 구성 설정은 extended JSON을 사용할지, 표준 JSON을 따르는 깨끗한 뷰를 제공할지를 제어합니다. |
| mongo-charset | 문서 데이터의 문자 집합을 지정합니다. |
| mongo-client-service | 구성하면 지정된 클라이언트 서비스를 연결 풀링에 사용합니다. |
| mongo-date-format | Mongo에서 반환되는 Date 필드 형식 지정에 사용할 날짜 형식 문자열입니다. JSON 출력 형식이 Standard JSON으로 설정된 경우에만 적용됩니다. |
| mongo-query-attribute | 설정하면 쿼리가 출력 FlowFile의 지정된 속성에 기록됩니다. |
| results-per-flowfile | 한 번에 하나의 FlowFile에 넣을 결과 수입니다. 전체 본문은 결과의 JSON 배열로 처리됩니다. |
| use-pretty-printing | 쿼리 결과의 JSON을 예쁘게 출력(pretty print)할지 여부를 선택합니다. 'True'를 선택하면 JSON 문서의 복잡성에 따라 디스크 공간 요구량이 크게 늘어날 수 있습니다. |
관계
| 이름 | 설명 |
|---|---|
| failure | 실패한 쿼리 실행에 속한 모든 입력 FlowFile이 여기로 이동합니다. |
| original | 성공한 쿼리 실행에 속한 모든 입력 FlowFile이 여기로 이동합니다. |
| success | 성공한 쿼리 실행 결과를 담은 모든 FlowFile이 여기로 이동합니다. |
쓰기 속성
| 이름 | 설명 |
|---|---|
| mongo.database.name | 결과가 나온 데이터베이스입니다. |
| mongo.collection.name | 결과가 나온 컬렉션입니다. |