PutAzureCosmosDBRecord 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-azure-nar

설명¶

이 프로세서는 Core SQL API 를 사용하여 Cosmos DB 에 데이터를 삽입하기 위한 레코드 인식 프로세서입니다. 구성된 Record Reader와 스키마를 사용하여 flowfile 본문에서 수신 레코드 세트를 읽은 다음, 구성된 Cosmos DB 컨테이너에 해당 레코드를 삽입합니다.

태그¶

azure, cosmos, insert, put, record

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
azure-cosmos-db-conflict-handling-strategy	삽입 중 충돌 오류 발생 시 무시 또는 업서트 여부 선택
azure-cosmos-db-connection-service	구성된 경우 컨트롤러 서비스는 연결 문자열 및 액세스 키를 가져오는 데 사용됩니다
azure-cosmos-db-consistency-level	일관성 스펙트럼에서 5가지 일관성 수준 중에서 선택하십시오. 차이점은 Cosmos DB 설명서를 참조하십시오
azure-cosmos-db-container-id	컨테이너의 고유 식별자
azure-cosmos-db-key	Cosmos DB Azure 포털에서 액세스 키(설정->키). 런타임에 데이터베이스 또는 컨테이너 생성을 활성화하려면 읽기-쓰기 키를 선택합니다
azure-cosmos-db-name	데이터베이스 이름 또는 ID입니다. 문서 컬렉션 또는 컨테이너의 네임스페이스로 사용됩니다
azure-cosmos-db-partition-key	서버 간에 데이터를 배포하는 데 사용되는 파티션 키입니다
azure-cosmos-db-uri	Cosmos DB URI, 일반적으로 https://{databaseaccount}.documents.azure.com:443/의 형식. 참고로 이 호스트 URL 은 Cosmos DB 와 Azure 포털(개요->URI)의 Core SQL API 를 위한 것입니다
insert-batch-size	Cosmos DB 에 대한 단일 삽입 작업을 위해 함께 그룹화할 레코드 수입니다.
record-reader	수신 데이터를 구문 분석하고 데이터의 스키마를 결정하는 데 사용할 컨트롤러 서비스를 지정합니다

관계¶

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