Bỏ qua tới nội dung
CloudDojo
SAA-C03 Lớp 6 · Integration, Monitoring & Operations Kinesis + MSK

Kinesis + MSK: xử lý luồng dữ liệu liên tụcKinesis + MSK: processing continuous data streams

Mỗi giây, hệ thống MFTECH phát sinh hàng nghìn sự kiện click, lượt xem, giao dịch và vị trí shipper. Bài học trình bày cách đưa luồng dữ liệu này vào Kinesis để nhiều ứng dụng cùng đọc theo đúng thứ tự, duy trì thông lượng của stream khi tải tăng đột biến, và kết nối stream tới các dịch vụ phân tích, tìm kiếm và lưu trữ.Every second, the MFTECH system produces thousands of clicks, views, transactions and courier locations. This lesson shows how to bring this data stream into Kinesis so that several applications can read it in order, how to keep the stream's throughput up when load spikes, and how to connect the stream to analytics, search and storage services.

Mức độ
Bổ trợ Áp dụng cho các yêu cầu chuyên biệt
Kiến thức tiên quyết
SQS + SNS + EventBridge + Step FunctionsLambda + API Gateway
Thời lượng
~24 phút, 4 phần học có mô phỏng
Bối cảnh hệ thống

Bài Messaging sử dụng SQS để phân phối tác vụ cho worker: mỗi đơn hàng chỉ cần một worker xử lý. Dữ liệu click và giao dịch của MFTECH có yêu cầu khác: bảng xếp hạng, gợi ý sản phẩm và phát hiện gian lận đều cần đọc cùng một luồng sự kiện, đúng thứ tự, với độ trễ gần như tức thời. Đây là phạm vi của stream.

Bối cảnh hệ thống

The Messaging lesson used SQS to distribute tasks to workers: each order needs only one worker to process it. MFTECH’s click and transaction data has different requirements: the leaderboard, product recommendations and fraud detection all need to read the same event stream, in order, with near-instant latency. This is the domain of streams.

Các phần của bài học

Tiếp theo

Các bài tiếp theo trong lộ trình học

Bài học tiếp theo

Luyện tập

Tài liệu AWS

Xem thêm 20 tài liệu
Xem thêm 20 tài liệu