PutMongoRecord 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-mongodb-nar

설명¶

이 프로세서는 MongoDB 에 데이터를 삽입/업서트하기 위한 레코드 인식 프로세서입니다. 구성된 Record Reader와 스키마를 사용하여 flowfile 본문에서 수신 레코드 세트를 읽은 다음, 해당 레코드 배치를 구성된 MongoDB 컬렉션에 삽입/업서트합니다. 이 프로세서는 삭제를 지원하지 않습니다. 한 번에 삽입/업서트할 문서의 수는 “Batch Size” 구성 속성으로 제어됩니다. 이 값은 MongoDB 에 한 번에 너무 많은 작업으로 오버로드가 발생하지 않도록 적당한 크기로 설정해야 합니다.

태그¶

insert, mongodb, put, record, update, upsert

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
Mongo 컬렉션 이름	사용할 컬렉션의 이름
Mongo 데이터베이스 이름	사용할 데이터베이스의 이름입니다
바이패스 유효성 검사	삽입 또는 업데이트 작업 중 문서 스키마 유효성 검사 건너뛰기를 사용하거나 사용하지 않도록 설정합니다. 문서 유효성 검사를 우회하는 작업은 MongoDB 의 권한 기반 작업입니다. 이 속성을 활성화하면 권한이 제한된 사용자에게 승인 오류가 발생할 수 있습니다.
insert_count	MongoDB 에 대한 단일 삽입/업서트 작업을 위해 함께 그룹화할 레코드 수입니다.
mongo-client-service	이 속성을 구성하면 연결 풀링에 할당된 클라이언트 서비스를 사용합니다.
순서 지정됨	정렬 또는 정렬되지 않은 작업 수행
record-reader	수신 데이터를 구문 분석하고 데이터의 스키마를 결정하는 데 사용할 컨트롤러 서비스를 지정합니다
update-key-fields	업데이트가 필요한 문서를 식별할 수 있는 필드를 쉼표로 구분한 목록입니다. 이 속성이 설정되어 있으면 NiFi 모든 문서에 대해 업서트 작업을 시도합니다. 이 속성을 설정하지 않으면 모든 문서가 삽입됩니다.
update-mode	단일 문서 업데이트 또는 수신 레코드당 여러 문서 업데이트 중에서 선택합니다.

관계¶

이름	설명
실패	MongoDB 로 쓸 수 없는 모든 FlowFiles 은 이 관계로 라우팅됩니다
성공	MongoDB 로 작성된 모든 FlowFiles 은 이 관계로 라우팅됩니다