5.2 Kiểm tra dữ liệu trong Kinesis Data Stream

Kiểm tra dữ liệu trong Kinesis Data Stream

  1. Quay trở lại terminal kết nối với EC2 Instance tại bước 2.3 Tạo EC2 Instance.
  2. Chạy lệnh sau để mô tả luồng Kinesis Data Stream:
aws kinesis describe-stream --stream-name fashion-ds

alt

  1. Chạy lệnh sau để lấy iterator của shard trong luồng Kinesis Data Stream:
aws kinesis get-shard-iterator --stream-name fashion-ds --shard-id shardId-000000000000 --shard-iterator-type TRIM_HORIZON

alt

  1. Copy ShardIterator trong kết quả trả về của lệnh trên và chạy lệnh sau để lấy dữ liệu trong luồng Kinesis Data Stream:
aws kinesis get-records --shard-iterator <YOUR_SHARD_ITERATOR>

alt

  1. Trong phần Records:

    • PartitionKey là user ID
    • Data là những dữ liệu JSON được encode trong luồng

  2. Kiểm tra dữ liệu, copy một Data bên trong Records. Vào trang Base64 Decode để decode dữ liệu vừa copy.

    • Decode UTF-8

alt