Bạn có thể bắt đầu bằng cách tải xuống các thư viện nguồn mở bao gồm AWS SDK, Apache Flink và bộ kết nối cho dịch vụ AWS.

Bạn viết mã ứng dụng Apache Flink bằng cách sử dụng luồng dữ liệu và toán tử luồng. Luồng dữ liệu ứng dụng là cấu trúc dữ liệu bạn thực hiện xử lý bằng cách sử dụng mã ứng dụng của bạn. Dữ liệu liên tục truyền từ nguồn vào luồng dữ liệu ứng dụng. Một hoặc nhiều toán tử luồng được sử dụng để xác định quá trình xử lý của bạn trên các luồng dữ liệu ứng dụng.

Sau khi xây dựng, hãy tải mã của bạn lên Dịch vụ được quản lý của HAQM dành cho Apache Flink. Dịch vụ này sẽ xử lý mọi thao tác cần thiết để chạy liên tục các ứng dụng theo thời gian thực, bao gồm tự động điều chỉnh quy mô để phù hợp với khối lượng và thông lượng dữ liệu đến của bạn. 

Bắt đầu từ bảng điều khiển Dịch vụ được quản lý của HAQM dành cho Apache Flink, HAQM MSK, hoặc Luồng dữ liệu HAQM Kinesis. Sử dụng các bộ kết nối tùy chỉnh để kết nối với bất kỳ nguồn dữ liệu nào khác.

Chạy các đoạn riêng lẻ trong sổ tay, xem kết quả trong ngữ cảnh và sử dụng công cụ trực quan hóa tích hợp sẵn của Apache Zeppelin để đẩy nhanh tốc độ phát triển. Bạn cũng có thể sử dụng các hàm do người dùng xác định trong mã của bạn. 

Triển khai mã của bạn dưới dạng ứng dụng xử lý luồng chạy liên tục chỉ trong vài bước. Ứng dụng được triển khai của bạn sẽ là một ứng dụng Dịch vụ được quản lý của HAQM dành cho Apache Flink với trạng thái bền vững và khả năng tự động điều chỉnh quy mô. Bạn cũng sẽ có thể thay đổi nguồn, đích đến, bản ghi và mức giám sát trước khi bạn đưa mã vào môi trường sản xuất.