PicoMQ est un serveur Rust conçu pour les flux durables, construit directement sur le stockage d'objets. Il offre des capacités de flux peu coûteuses, adressables par URL et granulaires, incluant la création, l'ajout, la lecture, le long-polling et les événements envoyés par le serveur (SSE). Le système utilise soit le protocole Pico soit le protocole de flux durables comme couche facade.

Au cœur du système, S3Stream sert de primitive fondamentale de stockage de flux. Ce composant est notablement utilisé dans AutoMQ et est disponible en tant que bibliothèque Rust autonome. En tirant parti de cette primitive, PicoMQ garantit une persistance et une récupération efficaces des données via des interfaces HTTP standard.

Pour les tâches de coordination, le système s'appuie sur un journal de commandes stocké dans Postgres. Cette architecture permet une gestion d'état et une synchronisation fiables entre les nœuds distribués sans nécessiter de services de coordination dédiés complexes. La combinaison du stockage d'objets pour les données et de Postgres pour le flux de contrôle fournit une solution robuste mais économique pour les besoins de streaming.

Le projet a été récemment partagé sur Hacker News, où il a obtenu 49 points et attiré 5 commentaires. La discussion met en évidence l'intérêt pour les solutions de messagerie légères basées sur le stockage d'objets qui simplifient les exigences d'infrastructure tout en maintenant la durabilité.

Entités clés : Entreprises : AutoMQ

FAQ : Quel est le mécanisme de stockage sous-jacent pour PicoMQ ?

PicoMQ utilise le stockage d'objets avec S3Stream comme primitive, coordonné par un journal de commandes Postgres.