PutKinesisStream 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-aws-nar
설명¶
지정된 Amazon Kinesis로 내용을 전송합니다. Kinesis로 데이터를 전송하려면 스트림 이름을 지정해야 합니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
AWS 자격 증명 공급자 서비스 |
AWS 자격 증명 공급자를 획득하는 데 사용되는 컨트롤러 서비스 |
통신 시간 제한 |
|
Endpoint Override URL |
스키마, 호스트, 포트, 경로 등 기본값인 AWS 대신 사용할 엔드포인트 URL 을 설정합니다. AWS 라이브러리는 AWS 리전을 기반으로 엔드포인트 URL 을 선택하지만, 이 속성은 선택한 엔드포인트 URL 을 재정의하여 다른 S3 호환 엔드포인트와 함께 사용할 수 있도록 합니다. |
리전 |
|
amazon-kinesis-stream-partition-key |
파티션 키 특성입니다. 설정되지 않은 경우 임의의 값이 사용됩니다 |
kinesis-stream-name |
Kinesis Stream의 이름 |
최대 메시지 버퍼 크기 |
최대 메시지 버퍼 크기(메가바이트 단위) |
메시지 배치 크기 |
메시지의 배치 크기(1~500). |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFiles 은 실패 관계로 라우팅됩니다 |
성공 |
FlowFiles 은 성공 관계로 라우팅됩니다 |
Writes 특성¶
이름 |
설명 |
|---|---|
aws.kinesis.error.message |
AWS Kinesis에 메시지를 게시할 때 오류 메시지 발생 |
aws.kinesis.error.code |
AWS Kinesis에 게시할 때 메시지에 대한 오류 코드 |
aws.kinesis.sequence.number |
AWS Kinesis에 게시할 때 메시지의 시퀀스 번호 |
aws.kinesis.shard.id |
AWS Kinesis에 게시된 메시지의 Shard ID |