PutDynamoDBRecord 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-aws-nar
설명¶
레코드 지향 데이터를 기반으로 DynamoDB 에 항목을 삽입합니다. 레코드 필드는 파티션 및 정렬 키가 설정된 경우 이를 포함하여 DynamoDB 항목 필드에 매핑됩니다. 레코드의 수에 따라 프로세서는 DynamoDB 의 배치 쓰기 제한을 극복하기 위해 삽입을 여러 청크로 실행할 수 있습니다. 이로 인해 FlowFiles 이 부분적으로 처리될 수 있으며, 이 경우 FlowFile 은 이미 실행된 삽입을 중복하지 않고 나중에 재시도하기 위해 필요한 특성과 함께 “처리되지 않음” 관계로 전송됩니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
AWS 자격 증명 공급자 서비스 |
AWS 자격 증명 공급자를 획득하는 데 사용되는 컨트롤러 서비스 |
통신 시간 제한 |
|
Endpoint Override URL |
스키마, 호스트, 포트, 경로 등 기본값인 AWS 대신 사용할 엔드포인트 URL 을 설정합니다. AWS 라이브러리는 AWS 리전을 기반으로 엔드포인트 URL 을 선택하지만, 이 속성은 선택한 엔드포인트 URL 을 재정의하여 다른 S3 호환 엔드포인트와 함께 사용할 수 있도록 합니다. |
리전 |
|
SSL 컨텍스트 서비스 |
공급자가 제공하는 경우 연결을 만드는 데 사용할 선택적 SSL 컨텍스트 서비스를 지정합니다 |
테이블 이름 |
DynamoDB 테이블 이름 |
partition-key-attribute |
“Partition by attribute” 파티션 키 전략을 사용할 때 파티션 키의 값으로 사용할 FlowFile 특성을 지정합니다. |
partition-key-field |
DynamoDB 테이블에서 파티션 키 필드의 이름을 정의합니다. 파티션 키는 해시 키라고도 합니다. “Partition Key Strategy”에 따라 필드 값은 수신 레코드에서 가져오거나 생성된 레코드에서 가져올 수 있습니다. |
partition-key-strategy |
프로세서가 삽입된 항목에 파티션 키 값을 할당하는 데 사용하는 전략을 정의합니다. |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
record-reader |
수신 데이터를 구문 분석하고 데이터의 스키마를 결정하는 데 사용할 컨트롤러 서비스를 지정합니다. |
sort-key-field |
DynamoDB 테이블에서 정렬 키 필드의 이름을 정의합니다. 정렬 키는 범위 키라고도 합니다. |
sort-key-strategy |
프로세서가 삽입된 항목에 정렬 키를 할당하는 데 사용하는 전략을 정의합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFiles 은 실패 관계로 라우팅됩니다 |
성공 |
FlowFiles 은 성공 관계로 라우팅됩니다 |
처리되지 않음 |
FlowFiles 은 DynamoDB 가 요청의 모든 항목을 처리할 수 없는 경우 처리되지 않은 관계로 라우팅됩니다. 일반적인 이유는 테이블 처리량 용량 부족과 요청당 최대 바이트 초과입니다. 처리되지 않은 FlowFiles 은 새 요청으로 다시 시도할 수 있습니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
dynamodb.chunks.processed |
DynamoDB 에 성공적으로 삽입된 청크 수입니다. 설정하지 않으면 0으로 간주됩니다 |
dynamodb.key.error.unprocessed |
DynamoDB 처리되지 않은 키 |
dynmodb.range.key.value.error |
DynamoDB범위 키 오류 |
dynamodb.key.error.not.found |
DynamoDB 키를 찾을 수 없음 |
dynamodb.error.exception.message |
DynamoDB 예외 메시지 |
dynamodb.error.code |
DynamoDB 오류 코드 |
dynamodb.error.message |
DynamoDB 오류 메시지 |
dynamodb.error.service |
DynamoDB 오류 서비스 |
dynamodb.error.retryable |
DynamoDB 오류는 재시도 가능 |
dynamodb.error.request.id |
DynamoDB 오류 요청 ID |
dynamodb.error.status.code |
DynamoDB 오류 상태 코드 |
dynamodb.item.io.error |
항목 생성 시 IO 예외 메시지 |