AgentBus

Der SQLite-gestützte MCP-Ereignisbus und die Steueroberfläche für heterogene Agentenschwärme.

Wenn Cursor, Claude, Antigravity und Terminal-Agenten (wie Hermes) einen Arbeitsbereich teilen, koordinieren sie sich normalerweise über fragwürdige Nur-Anhängen-Dateien (log.md). Das funktioniert, bis du SLA-Timeouts, Human-in-the-Loop (HITL)-Abfangmechanismen, strenge Schema-Validierung oder kryptografische RBAC benötigst.

AgentBus ersetzt das „Stille Post"-Spiel durch einen Localhost-Sidecar: einen Python-MCP-Server mit SQLite im Hintergrund. Keine Orchestrator-Laufzeit-Bindung. Kein schweres Cloud-Dashboard. Nur ein hyper-schnelles lokales Pub/Sub, das für erstklassige KI-Orchestrierung entwickelt wurde.

v0.18.0 (August 2026): Migration auf das MCP Python SDK v2, nach den Arbeiten an Headless-Runner, asynchronem Suspend/Resume, Wake-Plane und robuster Zustellung in v0.12-v0.16. Weitere Details findest du im Änderungsprotokoll.

Hinweis: Installation als okf-agentbus (CLI-Befehl bleibt agentbus). Zusatzoptionen: [obs,devex,jupyter,sdk].

⚡ Der „Aha"-Moment: Integration ohne Neustart

Laufen bei dir bereits Aider, OpenHands oder benutzerdefinierte Agenten in tmux-Bereichen? Beende deine Sitzungen nicht. AgentBus verfügt über eine Dual-Interface-Architektur (MCP + CLI). Du musst keine JSON-Konfigurationen einrichten, um es heute zu testen. Bitte einfach deinen laufenden Agenten:

„Verwende dein Terminal, um agentbus publish --topic okf/handoff --payload '{\"from\":\"grok\",\"to\":\"hermes\",\"summary\":\"Write tests\"}' auszuführen"

Der SQLite-Bus erfasst es sofort, ohne dass der MCP-Server erforderlich ist. Sobald du von der Mission-Control-TUI überzeugt bist, kannst du den stark typisierten MCP-Server für deinen nächsten Start einrichten.

Related MCP server: Hivemind

Warum AgentBus?

Feature-Arsenal (v0.3 - v0.18)

• MCP Python SDK v2 (v0.18): Migration des stdio-MCP-Servers unter Beibehaltung des bestehenden Event-Store-Vertrags.

• Robuste Zustellung (v0.16.4): Begrenzte Wiederholungsversuche mit Jitter, Dead Letters nach Erschöpfung der Wiederholungen und Datei-Überlauf bei SQLite-Konflikten.

• Asynchrones Suspend/Resume (v0.16): Dauerhafte Wartezeiten und korrelierte Aufweckereignisse ermöglichen es Headless-Agenten, ohne Polling-Schleifen nachzugeben.

• Headless-Runner (v0.15): Optionale Adapter für heterogene CLI-Agenten mit begrenztem Kettenverhalten und strukturierten Bestätigungen.

• Wake-Ebene und Go-Helfer (v0.12-v0.13): Plattformgepackte Worker, Rollen-Leases, Wake-Ingress und Webhook-Zustellung.

• Jupyter-Async-Client (v0.11): from agentbus.jupyter import AsyncAgentBus + %agentbus start — nicht blockierende Abfragen, die an die Notebook-Ereignisschleife abgegeben werden.

• TypeScript-Client (v0.11): packages/js/agentbus-client — Node-EventEmitter + MCP-stdio-Spawn (@agentbus/agentbus-client, vorerst Pfadinstallation).

• God-View-Mesh (v0.9): Passives Betriebssystem + MCP-Beobachtbarkeit, damit stille Agenten dennoch Bus-Fußabdrücke hinterlassen (system/mcp, system/fs, system/shell, system/monologue).

• Mission-Control-TUI (v0.8+): Ein umfangreiches, tastaturgesteuertes Textual-Dashboard (agentbus monitor). Trace-Wasserfall, HITL, Wiretap-Bereich, Dark-Agent-Warnungen.

• Plug-in-Pydantic-Schemas (v0.7): Code-first-@bus.topic-Dekorateure zur Durchsetzung strenger JSON-Schemas auf Einfügeebene.

• Verteilter Kontext (v0.6): Übergib großen Kontext (wie Git-Diffs) über --attach. Harte 1-MB-Nutzlastgrenzen verhindern das Aufblähen des Kontextfensters.

• Agentische Beobachtbarkeit (v0.5): Native OpenTelemetry-ähnliche trace_id- und parent_span_id-Abstammung.

• SLA-Timeouts und Dead Letters (v0.4): Verhindert scheinbare Deadlocks. Wenn ein Agent den Schwarm verlässt, leiten SLA-Timer die Nutzlast an okf/dead-letter weiter.

• Swarm-RBAC und Droid-Proofs (v0.3): Kryptografische JWT/UUID-Tokens stellen sicher, dass nur autorisierte Agenten auf eingeschränkten Themen veröffentlichen können.

• HITL-Abfangmechanismen (v0.3): Erfasse gefährliche Nutzlasten (z. B. DROP TABLE) und versetze sie für die menschliche Überprüfung über die TUI in den Status PENDING_APPROVAL.

Installation

Der schnellste Weg (installiert und verdrahtet deine IDEs in einem Schritt):

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

Oder manuell über pip:

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

Jupyter-Notebooks:

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 (aus dem Monorepo-Checkout):

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

Schnellstart und Beispiele

Der beste Weg, AgentBus zu verstehen, ist, unsere Copy-Paste-fähigen Beispiele zu lesen.

Siehe das Verzeichnis examples/ für 7 einwandfreie, isolierte Python-Skripte, die jede Funktion von grundlegendem Pub/Sub bis zu Pydantic-Schemas und SLA-Timeouts abdecken.

# 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-Beobachtbarkeit (v0.9.0):

Verfolge stille Agenten, indem du ihre Vorgänge abhörst:

# Intercept MCP tool calls
mcp-serve --wiretap

# Watch file edits and command executions
agentbus watch

# Tail internal agent reasoning logs
agentbus tail

Ereignisse werden als system/mcp, system/fs, system/shell- und system/monologue-Themen in den Wiretap-Bereich der TUI gestreamt.

📦 Arbeitsbereichsisolation (das .agentbus-Verzeichnis)

AgentBus basiert auf dem Konzept der Arbeitsbereichsisolation (ähnlich wie git .git oder Docker docker-compose.yml verwendet).

Der Bus und seine Ereignisse sind physisch auf das Verzeichnis beschränkt, in dem du es ausführst. Dadurch wird verhindert, dass dein Schwarm dein gesamtes Betriebssystem verfolgt oder verschiedene Projekte sich gegenseitig kontaminieren.

Wenn du zu einem bestimmten Projektordner navigierst und agentbus init oder agentbus up ausführst, wird eine lokalisierte SQLite-Datenbank .agentbus/events.db speziell für dieses Verzeichnis erstellt.

1-Klick-Schwarm-Orchestrierung (v0.10.0)

Anstatt manuell 5 tmux-Bereiche zu öffnen, um deine Agenten und Beobachtbarkeits-Daemons zu starten, verwende den neuen Orchestrator:

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

Dokumentation

Die vollständige Architekturdokumentation findest du im Verzeichnis docs/.

• Fahrplan

• v0.19-Produktplan und maschinenübergreifende Schwarm-Übergabe

• MCP-Schema

• Freigabeprozess

Lizenz

MIT – siehe LICENSE.