tldr/pages.ko/common/aws-kinesis.md

aws kinesis

빅데이터를 스트리밍하는 실시간 처리를 위해 탄력적으로 확장되는 서비스인, Amazon Kinesis Data Streams와 상호작용함. 더 많은 정보: https://docs.aws.amazon.com/cli/latest/reference/kinesis/index.html#cli-aws-kinesis.

• 계정의 모든 스트림 표시:

aws kinesis list-streams

• Kinesis 스트림에 하나의 레코드 쓰기:

aws kinesis put-record --stream-name {{이름}} --partition-key {{키}} --data {{base64로_인코딩된_메시지}}

• 인라인 base64 인코딩을 사용하여 Kinesis 스트림에 레코드를 씀:

aws kinesis put-record --stream-name {{이름}} --partition-key {{키}} --data "$( echo "{{my raw message}}" | base64 )"

• 스트림에서 사용 가능한 shard를 나열:

aws kinesis list-shards --stream-name {{이름}}

• 스트림의 shard에서 가장 오래된 메시지를 읽기 위한 shard 반복자를 가져옴:

aws kinesis get-shard-iterator --shard-iterator-type TRIM_HORIZON --stream-name {{이름}} --shard-id {{아이디}}

• shard 반복자를 사용하여, shard에서 레코드를 읽음:

aws kinesis get-records --shard-iterator {{반복자}}