PutKinesisStream 프로세서
PutKinesisStream 프로세서
PutKinesisStream은 지정한 Amazon Kinesis로 내용을 보내는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-aws-nar
설명
지정한 Amazon Kinesis로 내용을 보내요. Kinesis로 데이터를 보내려면 스트림 이름을 지정해야 해요.
Tags amazon, aws, kinesis, put, stream
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| AWS Credentials Provider service | AWS 자격 증명 공급자를 얻기 위해 사용하는 Controller Service예요. |
| Communications Timeout | AWS와 통신할 때의 타임아웃이에요. |
| Endpoint Override URL | scheme, host, port, path를 포함해 AWS 기본값 대신 사용할 Endpoint URL이에요. AWS 라이브러리는 AWS 리전을 기준으로 endpoint URL을 선택하지만, 이 속성은 선택된 endpoint URL을 덮어써서 다른 S3 호환 endpoint와 함께 사용할 수 있게 해줘요. |
| Max Message Buffer Size | 표준 데이터 크기 단위로 정의된 최대 메시지 버퍼 크기예요. |
| Message Batch Size | 메시지 배치 크기(1-500)예요. |
| Region | 연결할 AWS 리전이에요. |
| Stream Name | Kinesis 스트림 이름이에요. |
| Stream Partition Key | 파티션 키 속성이에요. 설정되지 않으면 임의의 값이 사용돼요. |
| proxy-configuration-service | 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | FlowFile이 failure 관계로 라우팅돼요. |
| success | FlowFile이 success 관계로 라우팅돼요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| aws.kinesis.error.message | AWS Kinesis에 메시지를 보낼 때의 오류 메시지예요. |
| aws.kinesis.error.code | AWS Kinesis에 메시지를 보낼 때의 오류 코드예요. |
| aws.kinesis.sequence.number | AWS Kinesis에 메시지를 보낼 때의 시퀀스 번호예요. |
| aws.kinesis.shard.id | AWS Kinesis로 보낸 메시지의 샤드 ID예요. |