Skip to main content

MQTT 위에서 도는 커맨더-워커 A2A 오케스트레이션 에이전트

Project description

a2a-agent

a2a-agent는 MQTT 위에서 커맨더와 워커가 A2A 형식 메시지를 주고받기 위한 작은 명령줄 도구입니다.

현재 버전은 MQTT 브로커(기본값은 환경변수 A2A_BROKER_HOST, 미설정 시 localhost:1883), 기본 방 team, 6자리 페어링 코드, 역할별 run 루프, 커맨더 send, 워커 echo/opencode/cursor 실행기를 지원합니다.

0.1.7부터 워커 run은 실행 중에도 PyPI 최신 버전을 주기적으로 확인합니다. 배포 설치본에서 새 버전이 발견되면 업데이트 후 같은 명령으로 재시작합니다. 개발용 editable 설치는 자동 업데이트를 건너뜁니다.

설치

PyPI 배포 후에는 다음처럼 설치할 수 있습니다.

python -m pip install a2a-agent

개발 환경에서 소스 코드로 설치하려면 저장소 루트에서 실행합니다.

python -m venv .venv
source .venv/bin/activate
python -m pip install -e .

기본 사용

커맨더 설정을 만듭니다.

a2a-agent init --room team --device-name commander --broker-host <BROKER_HOST> --broker-port 1883 --no-tls

커맨더 실행 루프를 켭니다. 이 루프가 켜져 있어야 워커의 페어링 요청에 답할 수 있습니다.

a2a-agent run

다른 터미널에서 워커 6자리 페어링 코드를 발급합니다.

a2a-agent invite macbook-air

워커 기기에서는 코드만 입력해 참여합니다.

a2a-agent join ABC234

워커 실행 루프를 켭니다. 기본 실행기는 echo입니다.

A2A_EXECUTOR=echo a2a-agent run

자동 업데이트를 임시로 끄려면 A2A_AUTO_UPDATE=0을 붙입니다.

A2A_AUTO_UPDATE=0 A2A_EXECUTOR=echo a2a-agent run

워커의 실행 중 업데이트 확인 주기는 기본 3600초입니다. 필요하면 A2A_UPDATE_INTERVAL_SECONDS로 조정하고, 0으로 두면 실행 중 감시만 끕니다.

A2A_UPDATE_INTERVAL_SECONDS=1800 A2A_EXECUTOR=echo a2a-agent run

커맨더에서 워커에게 작업을 보냅니다.

a2a-agent send macbook-air "ping-테스트"

커맨더는 사람용 별칭도 저장할 수 있습니다. 별칭은 커맨더 config에만 저장되고, 워커의 실제 기기명은 바꾸지 않습니다.

a2a-agent set-alias "회사 PC" windows-cursor
a2a-agent send "회사 PC" "ping-테스트"

워커 실행기

  • echo: 받은 텍스트를 그대로 회신합니다. 연결 확인용 기본값입니다.
  • opencode: opencode run -m opencode/big-pickle "<프롬프트>"를 호출하고 표준출력을 회신합니다. 실패하거나 설치되어 있지 않으면 에러 메시지를 결과로 돌려보냅니다.
  • cursor: cursor-agent -p --yolo --trust "<프롬프트>"를 호출하고 표준출력을 회신합니다. 느릴 수 있으므로 커맨더 송신 시 A2A_SEND_TIMEOUT을 늘릴 수 있습니다.
  • grok: grok --always-approve -p "<프롬프트>"(일회용, -c 없음)를 호출하고 표준출력을 회신합니다.

실행기는 설정 파일의 executor 또는 환경변수 A2A_EXECUTOR로 선택합니다. 환경변수가 우선합니다.

토픽

페어링 토픽은 방과 무관한 전역 토픽입니다.

a2a/_pairing/request
a2a/_pairing/reply/{code}

작업 토픽은 방과 워커 이름을 기준으로 나뉩니다.

a2a/{room}/agents/{device}/card
a2a/{room}/agents/{device}/status
a2a/{room}/cmd/{device}/request
a2a/{room}/cmd/{device}/response
a2a/{room}/cmd/{device}/task-status

구조

a2a-agent/
├── pyproject.toml
├── README.md
├── LICENSE
├── install/install.sh
├── scripts/live_broker_roundtrip.py
├── src/a2a_agent/
│   ├── cli.py
│   ├── client.py
│   ├── config.py
│   ├── executor.py
│   ├── invite.py
│   ├── pairing.py
│   ├── protocol.py
│   ├── runtime.py
│   ├── updater.py
│   └── topics.py
└── tests/

라이선스

MIT 라이선스를 따릅니다.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

a2a_agent-0.1.9.tar.gz (22.8 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

a2a_agent-0.1.9-py3-none-any.whl (21.1 kB view details)

Uploaded Python 3

File details

Details for the file a2a_agent-0.1.9.tar.gz.

File metadata

  • Download URL: a2a_agent-0.1.9.tar.gz
  • Upload date:
  • Size: 22.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for a2a_agent-0.1.9.tar.gz
Algorithm Hash digest
SHA256 f1e632e4e183a32c586e431cfc90f283507b69c25886046c8ad92cf02fa29fd0
MD5 51f2d47710560085404531598d9f7524
BLAKE2b-256 b4d35ba10553fc9536aff3b8bc177c3e4f1b914b9f190de85d177736a67bc39e

See more details on using hashes here.

File details

Details for the file a2a_agent-0.1.9-py3-none-any.whl.

File metadata

  • Download URL: a2a_agent-0.1.9-py3-none-any.whl
  • Upload date:
  • Size: 21.1 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.3

File hashes

Hashes for a2a_agent-0.1.9-py3-none-any.whl
Algorithm Hash digest
SHA256 7954ab79884be160ba2d80cc9bd285d1690f6c75816746b8c47ebdd007bae5a2
MD5 a4a16dc8d75c6aa67eb4b330969b6cdd
BLAKE2b-256 d73fc9294469fd984125aa0b803e2cb563f117107c558a6c0e5e33c592ef056c

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page