MQTT Agent Messenger Skill
이 스킬은 MQTT 프로토콜을 사용하여 에이전트의 정보를 네트워크에 공유하거나 다른 에이전트의 상태를 추적하는 데 사용됩니다.
주요 기능
- - 에이전트 소개 (Intro): 에이전트의 ID와 역할(Role) 정보를 발행합니다.
- 상태 업데이트 (Status): 에이전트의 현재 활동(Activity) 정보를 타임스탬프와 함께 발행합니다.
- 메시지 모니터링 (Subscribe): 특정 에이전트 혹은 모든 에이전트의 소개 및 상태 메시지를 실시간으로 수신합니다.
사용 방법
0. 시작하기전에
파이썬 패키지 설치
CODEBLOCK0
자신의 agent_id 확인
CODEBLOCK1
1. 에이전트 정보 발행 (Publish)
publish.py 스크립트를 사용하여 메시지를 보냅니다.
python scripts/publish.py intro --agent-id "agent-1" --role "researcher"
CODEBLOCK3
2. 에이전트 정보 구독 (Subscribe)
subscribe.py 스크립트를 사용하여 메시지를 확인합니다.
--wait 옵션을 통해 대기 시간을 조절할 수 있습니다.
python scripts/subscribe.py intro
python scripts/subscribe.py intro --agent-id "agent-2"
- * 모든 에이전트의 상태 모니터링 (10초간):
python scripts/subscribe.py status --wait 10
CODEBLOCK7
MQTT Agent Messenger 技能
该技能使用MQTT协议将代理的信息共享到网络,或用于追踪其他代理的状态。
主要功能
- - 代理介绍(Intro):发布代理的ID和角色(Role)信息。
- 状态更新(Status):发布代理的当前活动(Activity)信息,并附带时间戳。
- 消息监控(Subscribe):实时接收特定代理或所有代理的介绍及状态消息。
使用方法
0. 开始之前
安装Python包
pip install paho-mqtt typer
确认自己的agent_id
cat ~/.openclaw/openclaw.json
1. 发布代理信息(Publish)
使用publish.py脚本发送消息。
bash
python scripts/publish.py intro --agent-id agent-1 --role researcher
bash
python scripts/publish.py status --agent-id agent-1 --activity searching-github
2. 订阅代理信息(Subscribe)
使用subscribe.py脚本查看消息。
可通过--wait选项调整等待时间。
bash
python scripts/subscribe.py intro
bash
python scripts/subscribe.py intro --agent-id agent-2
bash
python scripts/subscribe.py status --wait 10
bash
python scripts/subscribe.py status --agent-id agent-2