GetDynamoDB 프로세서
GetDynamoDB 프로세서
Openflow의 GetDynamoDB 프로세서는 해시 키와 범위 키를 기준으로 DynamoDB에서 문서를 가져오는 프로세서예요. 키는 문자열 또는 숫자일 수 있어요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-aws-nar
설명 (Description)
해시 키와 범위 키를 기준으로 DynamoDB에서 문서를 가져와요. 키는 문자열 또는 숫자일 수 있어요. 모든 get 요청에는 모든 기본 키가 필요해요(테이블 키에 따라 해시 또는 해시와 범위). DynamoDB 항목의 Json Document('Map') 속성이 FlowFile의 콘텐츠로 읽혀져요.
태그 (Tags)
AWS, Amazon, DynamoDB, Fetch, Get
입력 요구 사항 (Input Requirement)
필수 (REQUIRED)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| AWS Credentials Provider service | AWS 자격 증명 제공자를 얻는 데 사용하는 컨트롤러 서비스예요. |
| Batch items for each request (between 1 and 50) | 한 배치에서 가져올 항목이에요. |
| Communications Timeout | |
| Endpoint Override URL | scheme, host, port, path를 포함해 AWS 기본값 대신 사용할 엔드포인트 URL이에요. AWS 라이브러리는 AWS 리전을 기준으로 엔드포인트 URL을 선택하지만, 이 속성이 선택된 엔드포인트 URL을 덮어써서 다른 S3 호환 엔드포인트와 함께 사용할 수 있게 해줘요. |
| Hash Key Name | 항목의 해시 키 이름이에요. |
| Hash Key Value | 항목의 해시 키 값이에요. |
| Hash Key Value Type | 항목의 해시 키 값 유형이에요. |
| Json Document attribute | dynamodb 항목에서 가져올 Json 문서(스키마의 's' 유형)예요. |
| Range Key Name | 항목의 범위 키 이름이에요. |
| Range Key Value | |
| Range Key Value Type | 항목의 범위 키 값 유형이에요. |
| Region | |
| SSL Context Service | 제공되면 연결을 만드는 데 사용할 선택적 SSL Context Service를 지정해요. |
| Table Name | DynamoDB 테이블 이름이에요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration 컨트롤러 서비스를 지정해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | FlowFile이 failure 관계로 보내져요. |
| not found | 테이블에서 키를 찾지 못하면 FlowFile이 not found 관계로 보내져요. |
| success | FlowFile이 success 관계로 보내져요. |
| unprocessed | DynamoDB가 요청의 모든 항목을 처리하지 못할 때 FlowFile이 unprocessed 관계로 보내져요. 일반적인 이유는 테이블 처리량 용량 부족과 요청당 최대 바이트 초과예요. 처리되지 않은 FlowFile은 새 요청으로 재시도할 수 있어요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
| 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 상태 코드예요. |