GetMongoRecord 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-mongodb-nar
설명¶
Record Writer를 사용하여 MongoDB 결과 세트를 작성하는 GetMongo 의 레코드 기반 버전입니다.
입력 요구 사항¶
ALLOWED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
---|---|
Batch Size |
서버에서 한 배치로 반환할 요소의 수입니다 |
Limit |
반환할 최대 요소 수 |
Mongo 컬렉션 이름 |
사용할 컬렉션의 이름 |
Mongo 데이터베이스 이름 |
사용할 데이터베이스의 이름입니다 |
프로젝션 |
결과 세트의 문서에서 반환할 필드는 유효한 BSON 문서여야 합니다 |
쿼리 |
조회를 수행하기 위한 선택 기준입니다. 필드를 비워두면 다른 프로세서에서 수신 연결에서 입력을 찾아 FlowFile 의 본문 안에 유효한 JSON 문서로 쿼리를 제공합니다. 이 필드를 비워두고 수신 연결 대신 타이머가 활성화되어 있으면 “{}” 쿼리를 사용하여 전체 컬렉션을 가져오게 됩니다. |
정렬 |
정렬할 필드로, 유효한 BSON 문서여야 합니다 |
get-mongo-record-writer-factory |
결과 세트를 작성하는 데 사용할 Record Writer입니다. |
mongo-client-service |
이 속성을 구성하면 연결 풀링에 할당된 클라이언트 서비스를 사용합니다. |
mongo-query-attribute |
설정하면 쿼리가 출력 flowfile의 지정된 특성에 기록됩니다. |
mongodb-스키마 이름 |
쿼리 결과에 사용할 구성된 Schema Registry의 스키마 이름입니다. |
관계¶
이름 |
설명 |
---|---|
실패 |
실패한 쿼리 실행의 일부인 모든 입력 FlowFiles 은 여기로 이동합니다. |
원본 |
성공적인 쿼리 실행의 일부인 모든 입력 FlowFiles 은 여기로 이동합니다. |
성공 |
성공적인 쿼리 실행 결과가 있는 모든 FlowFiles 은 여기로 이동합니다. |
Writes 특성¶
이름 |
설명 |
---|---|
mongo.database.name |
결과의 출처가 되는 데이터베이스입니다. |
mongo.collection.name |
결과의 출처가 되는 컬렉션입니다. |