GetMongoRecord 2025.5.31.15

번들

org.apache.nifi | nifi-mongodb-nar

설명

Record Writer를 사용하여 MongoDB 결과 세트를 작성하는 GetMongo 의 레코드 기반 버전입니다.

태그

fetch, get, json, mongo, mongodb, record

입력 요구 사항

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

결과의 출처가 되는 컬렉션입니다.