PutMongo 프로세서
PutMongo 프로세서
PutMongo는 FlowFile의 내용을 MongoDB에 기록하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-mongodb-nar
설명
FlowFile의 내용을 MongoDB에 기록해요.
Tags insert, mongodb, put, update, write
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Character Set | 데이터가 인코딩된 문자 집합이에요. |
| Mode | 프로세서가 내용을 삽입할지 업데이트할지를 나타내요. |
| Mongo Collection Name | 사용할 컬렉션 이름이에요. |
| Mongo Database Name | 사용할 데이터베이스 이름이에요. |
| Update Method | updateOne이나 updateMany 같은 컬렉션 업데이트 연산을 실행하는 MongoDB 메서드예요. |
| Update Query Key | updateOne이나 updateMany 같은 업데이트 쿼리 조건을 만드는 데 사용되는 쉼표로 구분된 문서 키 이름(예: _id)이에요. |
| Upsert | true면 업데이트 쿼리 조건과 일치하는 문서가 없을 때 문서를 삽입해요. 이 속성은 update 모드에서만 유효하며 그 외에는 무시돼요. |
| mongo-client-service | 설정하면 연결 풀링에 할당된 클라이언트 서비스를 사용해요. |
| put-mongo-update-mode | 업데이트 모드를 선택해요. 직접 교체로 사용할 JSON 문서를 제공하거나 $set, $unset, $inc 같은 업데이트 연산자를 포함한 문서를 지정할 수 있어요. Operators 모드가 활성화되면 flowfile 내용은 연산자 부분(예: {$set:{"key": "value"},$inc:{"count":1234}})이어야 하고, 업데이트 쿼리는 설정된 Update Query 속성에서 나와요. |
| putmongo-update-query | 업데이트/업서트를 위한 조회 쿼리로 사용할 전체 MongoDB 쿼리를 지정해요. 참고: 'Update Query Key' 값이 비어 있지 않으면 이 필드는 무시돼요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | MongoDB에 기록할 수 없는 모든 FlowFile이 이 관계로 라우팅돼요. |
| success | MongoDB에 기록된 모든 FlowFile이 이 관계로 라우팅돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| mongo.put.update.match.count | 업데이트/업서트가 수행되면 결과의 match 수이고, 그렇지 않으면 설정되지 않아요. |
| mongo.put.update.modify.count | 업데이트/업서트가 수행되면 결과의 modify 수이고, 그렇지 않으면 설정되지 않아요. |
| mongo.put.upsert.id | 업서트가 수행되면 '_id' hex 값이고, 그렇지 않으면 설정되지 않아요. |