egeominotti/bunqueue

何を解決するか

Bunqueueは、RedisやMongoDBのような外部インフラを必要としないように設計された、高性能なジョブキューシステムです。最小限のセットアップで、バックグラウンドタスク、スケジュールされたジョブ（cron）、および複雑なマルチステップのワークフローを管理する信頼性の高い方法を提供し、AIエージェントや自動化タスクに特に適しています。

仕組み

システムは主に2つのモードで動作します：

• Embedded Mode: キューはアプリケーションプロセス内で直接実行され、インメモリ保存または永続化のための単一のSQLiteファイルを使用します。
• Server Mode: スタンドアロンサーバーがデプロイされ（DockerまたはBun経由）、複数のプロデューサーとワーカーがTCP経由で接続できます。スケーリングのために、PostgreSQL 15–18を使用したマルチブローカー構成をサポートしています。

BullMQ互換のAPIを備え、TypeScript、Python、PHP、Go、Rust、およびElixir用の公式SDKを提供しているため、ある言語で生成されたジョブを別の言語で処理することが可能です。

対象ユーザー

• AIエージェントを構築している開発者: 複雑なインフラを管理することなく、スケジューラとタスク管理を必要とする方。
• チーム: Redisの運用オーバーヘッドを避けたいチーム。
• 開発者: バックグラウンド処理を必要とするシングルプロセスアプリ、CLI、またはサーバーレス関数を作成している方。
• アーキテクチャチーム: saga compensation（補償トランザクション）とhuman-in-the-loopシグナルを備えた複雑なワークフローエンジンを必要とするチーム。

ハイライト

• インフラ不要のデフォルト設定: メモリまたはSQLiteで即座に動作します。
• AIネイティブ: 73個のツールを備えたネイティブなModel Context Protocol (MCP) サーバーが含まれており、AIエージェントがキューを直接制御できます。
• マルチ言語サポート: 6つの異なる言語のSDKによる統一されたワイヤプロトコル。
• ワークフローエンジン: マルチステップのオーケストレーション、saga compensation、およびhuman-in-the-loopインタラクションのための .waitFor() を内蔵サポートしています。
• 高性能: Embedded Modeでは、毎秒数十万件のジョブを処理する能力があります。
• BullMQ Pro互換: ジョブグループ、バッチ、および公平なラウンドロビン方式のクレームを、別途ライセンスなしでサポートしています。