PicoMQ — это сервер на Rust, предназначенный для надежных потоков, созданный непосредственно на базе объектного хранилища. Он предлагает дешевые, адресуемые по URL и детализированные возможности потоковой передачи, включая создание, добавление, чтение, длинный опрос и события, отправляемые сервером (SSE). Система использует либо протокол Pico, либо протокол надежных потоков в качестве своего фасадного слоя.

В своей основе S3Stream служит фундаментальной примитивной функцией хранения потоков. Этот компонент заметно используется в AutoMQ и доступен в виде отдельной библиотеки Rust. Используя эту примитивную функцию, PicoMQ обеспечивает эффективное сохранение и извлечение данных через стандартные интерфейсы HTTP.

Для задач координации система полагается на журнал команд, хранящийся в Postgres. Эта архитектура позволяет надежно управлять состоянием и синхронизировать данные между распределенными узлами без необходимости использования сложных выделенных служб координации. Комбинация объектного хранилища для данных и Postgres для потока управления обеспечивает надежное, но экономичное решение для потребностей потоковой передачи.

Проект недавно был опубликован на Hacker News, где он набрал 49 очков и привлек 5 комментариев. Обсуждение подчеркивает интерес к легковесным решениям для обмена сообщениями на базе объектного хранилища, которые упрощают требования к инфраструктуре, сохраняя при этом надежность.

Ключевые сущности: Компании: AutoMQ

Часто задаваемые вопросы: Какой механизм хранения лежит в основе PicoMQ?

PicoMQ использует объектное хранилище с S3Stream в качестве примитива, координируемое журналом команд Postgres.