Đây là ứng dụng Linux có tên Amazon Kinesis Flink Connectors có bản phát hành mới nhất có thể tải xuống dưới dạng v2.1.0.zip. Nó có thể được chạy trực tuyến trong nhà cung cấp dịch vụ lưu trữ miễn phí OnWorks cho máy trạm.
Tải xuống và chạy trực tuyến ứng dụng này có tên là Amazon Kinesis Flink Connectors with OnWorks miễn phí.
Làm theo các hướng dẫn sau để chạy ứng dụng này:
- 1. Đã tải ứng dụng này xuống PC của bạn.
- 2. Nhập vào trình quản lý tệp của chúng tôi https://www.onworks.net/myfiles.php?username=XXXXX với tên người dùng mà bạn muốn.
- 3. Tải lên ứng dụng này trong trình quản lý tệp như vậy.
- 4. Khởi động trình giả lập trực tuyến OnWorks Linux hoặc trình giả lập trực tuyến Windows hoặc trình mô phỏng trực tuyến MACOS từ trang web này.
- 5. Từ Hệ điều hành OnWorks Linux mà bạn vừa khởi động, hãy truy cập trình quản lý tệp của chúng tôi https://www.onworks.net/myfiles.php?username=XXXXX với tên người dùng mà bạn muốn.
- 6. Tải xuống ứng dụng, cài đặt và chạy nó.
MÀN HÌNH
Ad
Đầu nối Flink Amazon Kinesis
MÔ TẢ
Thư viện này chứa các trình kết nối Apache Flink khác nhau để kết nối với các nguồn dữ liệu AWS và phần chứa. Kho lưu trữ này chứa các trình kết nối Apache Flink khác nhau để kết nối với các nguồn dữ liệu AWS Kinesis và phần chứa. Flink duy trì khả năng tương thích ngược cho giao diện Sink được Nhà sản xuất Firehose sử dụng. Dự án này tương thích với Flink 1.x, không có gì đảm bảo nó sẽ hỗ trợ Flink 2.x nếu nó được phát hành trong tương lai. Ứng dụng Apache Flink là một ứng dụng Java hoặc Scala được tạo bằng khung công tác Apache Flink. Bạn là tác giả và xây dựng ứng dụng Apache Flink của mình cục bộ. Các ứng dụng chủ yếu sử dụng API DataStream hoặc API bảng. Các API Apache Flink khác cũng có sẵn để bạn sử dụng, nhưng chúng ít được sử dụng hơn trong việc xây dựng các ứng dụng phát trực tuyến. Mô hình lập trình Apache Flink DataStream API dựa trên hai thành phần.
Tính năng
- Ghi dữ liệu vào Kinesis Data Stream
- Xử lý dữ liệu phát trực tuyến bằng Kinesis Data Analytics
- Ghi kết quả vào Kinesis Firehose bằng FlinkKinesisFirehoseProducer
- Lưu trữ dữ liệu trong Bộ chứa S3
- Bạn sẽ cần cài đặt Java 1.8+ và Maven
- Xây dựng bằng Maven từ thư mục gốc của dự án
Ngôn ngữ lập trình
Java
Danh Mục
Đây là một ứng dụng cũng có thể được tìm nạp từ https://sourceforge.net/projects/amazon-kinesisflink-con.mirror/. Nó đã được lưu trữ trong OnWorks để có thể chạy trực tuyến theo cách dễ dàng nhất từ một trong các Hệ điều hành miễn phí của chúng tôi.
