GetMongoRecord 프로세서
GetMongoRecord 프로세서
Openflow의 GetMongoRecord 프로세서는 MongoDB 결과 집합을 기록(record) 기반으로 쓰는 GetMongo의 레코드 버전이에요.
출처: Snowflake 문서
본문
기능 — 일반 공급 (Generally Available)
Openflow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있어요. Openflow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있습니다.
Bundle
org.apache.nifi | nifi-mongodb-nar
설명
Record Writer를 사용해 MongoDB 결과 집합을 기록하는 GetMongo의 레코드 기반 버전입니다.
태그
fetch, get, json, mongo, mongodb, record
입력 요구사항
허용 (ALLOWED)
민감한 동적 속성 지원
false
속성
| 이름 | 설명 |
|---|---|
| Batch Size | 한 번의 배치로 서버에서 반환할 요소 수입니다. |
| Limit | 반환할 최대 요소 수입니다. |
| Mongo Collection Name | 사용할 컬렉션 이름입니다. |
| Mongo Database Name | 사용할 데이터베이스 이름입니다. |
| Projection | 결과 집합의 문서에서 반환할 필드로, 유효한 BSON 문서여야 합니다. |
| Query | 조회를 수행할 선택 기준입니다. 이 필드를 비워 두면 다른 프로세서의 인입 연결에서 유효한 JSON 문서 형식의 쿼리를 FlowFile 본문으로 제공받습니다. 필드가 비어 있고 인입 연결 대신 타이머가 활성화된 경우 "{}" 쿼리를 사용한 전체 컬렉션 조회가 수행됩니다. |
| Sort | 정렬할 필드로, 유효한 BSON 문서여야 합니다. |
| get-mongo-record-writer-factory | 결과 집합을 기록하는 데 사용할 Record Writer입니다. |
| mongo-client-service | 구성하면 지정된 클라이언트 서비스를 연결 풀링에 사용합니다. |
| mongo-query-attribute | 설정하면 쿼리가 출력 FlowFile의 지정된 속성에 기록됩니다. |
| mongodb-schema-name | 쿼리 결과에 사용할, 구성된 스키마 레지스트리의 스키마 이름입니다. |
관계
| 이름 | 설명 |
|---|---|
| failure | 실패한 쿼리 실행에 속한 모든 입력 FlowFile이 여기로 이동합니다. |
| original | 성공한 쿼리 실행에 속한 모든 입력 FlowFile이 여기로 이동합니다. |
| success | 성공한 쿼리 실행 결과를 담은 모든 FlowFile이 여기로 이동합니다. |
쓰기 속성
| 이름 | 설명 |
|---|---|
| mongo.database.name | 결과가 나온 데이터베이스입니다. |
| mongo.collection.name | 결과가 나온 컬렉션입니다. |