AgentBus

Шина событий и панель управления на базе SQLite для гетерогенных роев агентов через MCP.

Когда Cursor, Claude, Antigravity и терминальные агенты (например, Hermes) работают в одном рабочем пространстве, они обычно координируются через хрупкие файлы с дополнением (log.md). Это работает до тех пор, пока вам не понадобятся таймауты SLA, перехваты Human-in-the-Loop (HITL), строгая валидация схем или криптографический RBAC.

AgentBus заменяет «испорченный телефон» на локальный сайдкар: Python MCP-сервер на базе SQLite. Никакой привязки к оркестратору. Никакого тяжёлого облачного дашборда. Просто сверхбыстрая локальная модель pub/sub, созданная для первоклассной оркестрации ИИ.

v0.18.0 (август 2026): миграция на MCP Python SDK v2, после headless-раннера, асинхронных suspend/resume, wake-plane и устойчивой доставки, выпущенных в v0.12–v0.16. Подробности в журнале изменений.

Примечание: устанавливается как okf-agentbus (команда CLI остаётся agentbus). Дополнительные опции: [obs,devex,jupyter,sdk].

⚡ Момент «Эврика»: интеграция без перезапуска

Уже запущены Aider, OpenHands или собственные агенты в tmux-панелях? Не убивайте свои сессии. AgentBus имеет двухинтерфейсную архитектуру (MCP + CLI). Вам не нужно настраивать JSON-конфиги, чтобы протестировать его сегодня. Просто дайте команду вашему работающему агенту:

«Используй свой терминал, чтобы выполнить agentbus publish --topic okf/handoff --payload '{\"from\":\"grok\",\"to\":\"hermes\",\"summary\":\"Write tests\"}'»

SQLite-шина мгновенно захватит это сообщение, даже без MCP-сервера. Как только вы убедитесь в возможностях TUI Mission Control, вы сможете подключить строго типизированный MCP-сервер при следующей загрузке.

Related MCP server: Hivemind

Почему AgentBus?

Арсенал функций (v0.3 – v0.18)

• MCP Python SDK v2 (v0.18): миграция stdio MCP-сервера с сохранением существующего контракта хранилища событий.

• Устойчивая доставка (v0.16.4): ограниченные повторные попытки с джиттером, dead-letter после исчерпания повторов и сброс в файл при конфликтах SQLite.

• Асинхронные suspend/resume (v0.16): долговременные ожидания и коррелированные wake-события позволяют headless-агентам уступать без активного опроса.

• Headless-раннеры (v0.15): опциональные адаптеры для гетерогенных CLI-агентов с ограниченным поведением цепочек и структурированными подтверждениями.

• Wake-plane и Go-хелперы (v0.12–v0.13): упакованные в платформу воркеры, ролевые аренды, wake-вход и доставка вебхуков.

• Jupyter async-клиент (v0.11): from agentbus.jupyter import AsyncAgentBus + %agentbus start — неблокирующие опросы, уступающие циклу событий ноутбука.

• TypeScript-клиент (v0.11): packages/js/agentbus-client — Node EventEmitter + MCP stdio spawn (@agentbus/agentbus-client, пока установка по пути).

• God View Mesh (v0.9): пассивная ОС + MCP-наблюдаемость, чтобы молчаливые агенты всё равно оставляли следы на шине (system/mcp, system/fs, system/shell, system/monologue).

• TUI Mission Control (v0.8+): богатый управляемый с клавиатуры дашборд на Textual (agentbus monitor). Водопад трассировки, HITL, панель Wiretap, предупреждения о тёмных агентах.

• Подключаемые Pydantic-схемы (v0.7): декларативные декораторы @bus.topic для строгой проверки JSON-схем на уровне вставки.

• Распределённый контекст (v0.6): передача больших контекстов (например, git-диффов) через --attach. Жёсткий лимит в 1 МБ предотвращает раздувание контекстного окна.

• Агентная наблюдаемость (v0.5): нативная трассировка в стиле OpenTelemetry с trace_id и parent_span_id.

• Таймауты SLA и Dead-Letter (v0.4): предотвращение фантомных взаимоблокировок. Если агент «исчезает» из роя, таймеры SLA направляют полезную нагрузку в okf/dead-letter.

• Swarm RBAC и Droid Proofs (v0.3): криптографические JWT/UUID-токены гарантируют, что только авторизованные агенты могут публиковать в ограниченные топики.

• HITL-перехваты (v0.3): перехват опасных полезных нагрузок (например, DROP TABLE) и помещение их в PENDING_APPROVAL для проверки человеком через TUI.

Установка

Самый быстрый способ (установка и автоматическая настройка ваших IDE за один шаг):

curl -sSL https://raw.githubusercontent.com/onicarps/agentbus/main/install.sh | bash

Или вручную через pip:

pip install -U "okf-agentbus[devex,sdk]"
agentbus init --apply --producer-id my-agent

Jupyter-ноутбуки:

pip install -U "okf-agentbus[jupyter]"

%load_ext agentbus.jupyter
%agentbus start
# or
from agentbus.jupyter import AsyncAgentBus
bus = AsyncAgentBus()  # AGENTBUS_WORKSPACE or cwd
bus.on_event(print)
await bus.start_background(interval=1.0)

TypeScript (из монорепозитория):

cd packages/js/agentbus-client && npm install && npm test
# set AGENTBUS_WORKSPACE + agentbus on PATH, then use createStdioMcpClient / AgentBus

Быстрый старт и примеры

Лучший способ понять AgentBus — прочитать наши примеры, которые можно скопировать и вставить.

Смотрите каталог examples/ — там 7 безупречных изолированных Python-скриптов, покрывающих все функции: от базового Pub/Sub до Pydantic-схем и таймаутов SLA.

# Terminal A — Launch the Mission Control TUI
agentbus monitor

# Terminal B — Publish a handoff
agentbus publish \
  --topic okf/handoff \
  --payload '{"from":"cursor","to":"hermes","summary":"Write tests"}'

God View Observability (v0.9.0):

Отслеживайте молчаливых агентов, прослушивая их операции:

# Intercept MCP tool calls
mcp-serve --wiretap

# Watch file edits and command executions
agentbus watch

# Tail internal agent reasoning logs
agentbus tail

События будут поступать в панель Wiretap TUI как топики system/mcp, system/fs, system/shell и system/monologue.

📦 Изоляция рабочего пространства (каталог .agentbus)

AgentBus работает на принципе изоляции рабочего пространства (аналогично тому, как git использует .git или Docker — docker-compose.yml).

Шина и её события физически ограничены каталогом, в котором вы её запускаете. Это предотвращает отслеживание всей операционной системы или перекрёстное загрязнение разных проектов.

Когда вы переходите в конкретную папку проекта и выполняете agentbus init или agentbus up, создаётся локальная база данных SQLite .agentbus/events.db именно для этого каталога.

Оркестрация роя в один клик (v0.10.0)

Вместо ручного открытия 5 tmux-панелей для запуска агентов и демонов наблюдаемости используйте новый оркестратор:

cd /path/to/my-project

# 1. Generate a boilerplate .agentbus/swarm.yaml
agentbus up --init

# 2. Boot the swarm (Watchers, Agents, and TUI) in one click
agentbus up

# 3. View running background agents
agentbus ps

# 4. Safely kill the entire swarm
agentbus down

Документация

Полная архитектурная документация находится в каталоге docs/.

• Дорожная карта

• План продукта v0.19 и межмашинный handoff роя

• Схема MCP

• Процесс релиза

Лицензия

MIT — см. LICENSE.