River - Hàng đợi tác vụ nhanh và vững chắc cho Go + Postgres

• Khuyến nghị dùng cùng một cơ sở dữ liệu (Postgres) cho dữ liệu ứng dụng và hàng đợi tác vụ, nhằm giảm thiểu phụ thuộc
• Có thể đưa tác vụ vào hàng đợi theo cách giao dịch cùng với các thay đổi cơ sở dữ liệu khác, nhờ đó tránh được cả một lớp vấn đề của hệ thống phân tán
• Transactional enqueueing: tác vụ sẽ vào hàng đợi khi giao dịch được commit, bị xóa nếu giao dịch rollback, và được bảo đảm không hiển thị cho tới khi commit
• Tận dụng tính năng NOTIFY của Postgres để hàng đợi tác vụ có thể đánh thức worker và bắt đầu xử lý ngay khi tác vụ sẵn sàng, giúp giảm độ trễ trung bình trước khi bắt đầu tác vụ xuống mức mili giây
• Sử dụng giao thức nhị phân của Postgres và giảm thiểu số lần round trip với cơ sở dữ liệu để tăng hiệu quả
  • Bulk Job Insert được thực hiện hiệu quả bằng COPY FROM