Bắt đầu sử dụng Dịch vụ được quản lý của Amazon dành cho Apache Flink
Tại sao nên chọn Dịch vụ được quản lý dành cho Apache Flink?
Với Dịch vụ được quản lý của Amazon dành cho Apache Flink, bạn có thể chuyển đổi và phân tích dữ liệu truyền liên tục theo thời gian thực bằng Apache Flink. Dịch vụ được quản lý của Amazon dành cho Apache Flink đơn giản hóa việc xây dựng và quản lý khối lượng công việc Apache Flink cũng như cho phép bạn tích hợp ứng dụng với các dịch vụ AWS khác.
Xây dựng ứng dụng truyền liên tục với Apache Flink và Apache Beam
Bước 1: Tải xuống thư viện nguồn mở vào IDE yêu thích của bạn
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ước 2: Tạo một ứng dụng mẫu bằng Apache Flink hoặc Apache Beam
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.
Bước 3: Tải mã của bạn lên Dịch vụ được quản lý của Amazon dành cho Apache Flink
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 Amazon 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.
Sử dụng Studio Dịch vụ được quản lý của Amazon dành cho Apache Flink một cách trực quan
Bước 1: Tạo một ứng dụng Studio Dịch vụ được quản lý của Amazon dành cho Apache Flink
Bắt đầu từ bảng điều khiển Dịch vụ được quản lý của Amazon dành cho Apache Flink, Amazon MSK, hoặc Luồng dữ liệu Amazon 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.
Bước 2: Viết mã trong sổ tay phi máy chủ bằng SQL, Python và Scala, cũng như phát triển các ứng dụng Apache Flink
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.
Bước 3: Xây dựng và triển khai dưới dạng một ứng dụng truyền liên tục Dịch vụ được quản lý của Amazon dành cho Apache Flink
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 Amazon 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.