- Nền tảng xử lý dữ liệu giúp nâng cao kiến trúc dựa trên sự kiện thời gian thực bằng cách đơn giản hóa việc phát hiện các sự kiện quan trọng và phản hồi ngay lập tức
- Cung cấp giải pháp toàn diện theo dõi log hệ thống và nguồn cấp thay đổi của các sự kiện cụ thể, đánh giá chúng và tự động khởi chạy phản ứng phù hợp
- Đơn giản hóa toàn bộ quy trình bằng cách tích hợp nhiều nguồn dữ liệu, liên tục giám sát các thay đổi liên quan và kích hoạt các phản hồi thông minh, tự động hóa
- Không cần xây dựng hệ thống phức tạp để phát hiện thay đổi, quản lý các data lake quy mô lớn hoặc tích hợp phần mềm phát hiện hiện đại vào hệ sinh thái hiện có
- Có thể ứng dụng trong nhiều kịch bản hướng sự kiện như tích hợp IoT, cải thiện giao thức bảo mật và quản lý ứng dụng tinh vi
- Tổng quan
- Cung cấp insight có thể hành động theo thời gian thực mà không phải gánh nặng của các phương pháp xử lý dữ liệu truyền thống.
- Theo dõi các thay đổi và sự kiện trong hệ thống mà không cần sao chép dữ liệu vào data lake hoặc truy vấn lặp đi lặp lại các nguồn dữ liệu
- Liên tục đánh giá các thay đổi dữ liệu đi vào bằng truy vấn
- Khi các thay đổi khớp với tiêu chí và điều kiện được chỉ định trong truy vấn, tập kết quả của truy vấn sẽ được cập nhật
- Các cập nhật này sẽ kích hoạt những phản ứng nhận biết ngữ cảnh, được điều chỉnh theo các yêu cầu cụ thể
- Drasi hoạt động với ba thành phần:
- Sources: Kết nối tới các kho dữ liệu trong hệ thống phần mềm để giám sát log và feed, đồng thời theo dõi các thay đổi dữ liệu.
- Continuous Queries: Áp dụng các tiêu chí và điều kiện được định nghĩa trước lên những thay đổi được giám sát để xác định và đánh giá các thay đổi quan trọng. Trong Drasi, Continuous Query được viết bằng Cypher Query Language.
- Reactions: Thực thi các phản ứng tự động dựa trên các cập nhật của tập kết quả từ Continuous Query
- Lấy ví dụ về hệ thống giao hàng của một dịch vụ đặt hàng trực tuyến để giải thích cách Drasi diễn giải sự kiện và kích hoạt phản ứng phù hợp
- Cấu hình một source cho hệ thống quản lý đơn hàng để giám sát thay đổi trạng thái đơn hàng, và cấu hình source thứ hai để phát hiện khi tài xế sẵn sàng giao hàng
- Tạo một Continuous Query kết hợp dữ liệu từ hai source để ghép các đơn hàng đã sẵn sàng lấy với các tài xế đang khả dụng
- Định nghĩa một reaction gửi thông báo cho tài xế để báo họ di chuyển tới khu vực lấy hàng
- Thiết lập được tinh gọn này giúp tài xế nhanh chóng nhận thông tin và tối ưu hóa quy trình giao hàng
Tóm tắt của GN⁺
- Drasi là nền tảng đơn giản hóa việc phát hiện thay đổi dữ liệu và hành động tức thì, nâng cao hiệu quả thông qua tích hợp dữ liệu thời gian thực và các phản ứng tự động.
- Sử dụng Cypher Query Language để viết Continuous Query, đồng thời giám sát log hệ thống và sự kiện để xác định các thay đổi quan trọng.
- Là bản phát hành ban đầu để cộng đồng có thể học hỏi và thử nghiệm nền tảng, đồng thời khuyến khích đóng góp và phản hồi.
- Một dự án có chức năng tương tự là nền tảng streaming dữ liệu thời gian thực như Apache Kafka.
Chưa có bình luận nào.