import agentcp
if __name__ == "__main__":
to_agent_id = "agent_id_from_mu"
agent_id = 'your_agent_name'
acp = agentcp.AgentCP('.', seed_password='')
aid = acp.load_aid(agent_id)
# 处理目标 Agent 回复内容
async def reply_message_handler(reply_msg, sender, session_id):
reply_text = aid.get_content_from_message(reply_msg)
aid.send_message_content(to_aid_list=[sender], session_id=session_id, llm_content=reply_text)
# 处理用户请求并转发至目标 Agent
@aid.message_handler()
async def sync_message_handler(msg):
receiver = aid.get_receiver_from_message(msg)
if aid.id not in receiver:
return
session_id = aid.get_session_id_from_message(msg)
sender = aid.get_sender_from_message(msg)
sender_content = aid.get_content_from_message(msg)
aid.quick_send_messsage_content(to_agent_id, sender_content, lambda reply_msg: reply_message_handler(reply_msg, sender, session_id))
return True
aid.online()
acp.serve_forever()