用 Agently 来实现 Agent

GitHub: https://github.com/auliwenjiang/agentcp/tree/master/samples/wrapper_agently_to_agent

使用指南

1. 环境要求

• Python 3.8+
• AgentCP SDK
• Agently SDK

2. 安装依赖

确保安装以下必要库，建议使用 python-dotenv 来加载 .env 文件管理密钥和配置。

pip install agentcp agently python-dotenv

3. 创建身份 ID

请参考 创建身份，读写公有私有数据

4. 修改 main.py 文件

将 seed_password、agent_id 修改为上一步创建的身份信息

5. 配置文件

创建 .env 文件并添加以下配置：

{
    "OPENAI_API_KEY": "your_api_key",
    "BASE_URL": "https://api.example.com/v1",
    "MODEL": "qwen-72b-chat"
}

6. 执行 main.py 代码

python main.py

功能简介

该 Agent 结合了 agentcp 和 agently 两个库，具备以下核心能力：

• 接收并处理外部消息请求
• 调用大语言模型生成自然语言响应
• 异步发送处理结果给消息发送者
• 适用于快速构建具备智能问答能力的服务型 Agent

完整示例代码

import agentcp
import Agently
import os
from dotenv import load_dotenv
load_dotenv()

if __name__ == "__main__":
    agent_id = 'your_agent_id'
    acp = agentcp.AgentCP('.', seed_password='')
    aid = acp.load_aid(agent_id)
    openai_api_key = os.getenv("OPENAI_API_KEY")
    model_url = os.getenv("BASE_URL")
    model_name = os.getenv("MODEL")
    agent = (
        Agently.create_agent()
            .set_settings("current_model", "OAIClient")
            .set_settings("model.OAIClient.auth", {'api_key': openai_api_key})
            .set_settings("model.OAIClient.url", model_url)
            .set_settings("model.OAIClient.options", {'model': model_name})
    )

    @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)
        result = (
            agent
                .general("输出规定", "必须使用中文进行输出")
                .role({
                    "姓名": "ACP小助手",
                    "任务": "使用自己的知识为用户解答常见问题",
                })
                .input(sender_content)
                .instruct(["你需要根据用户的问题提供相关的回答", "你可以适当的有点幽默"])
                .start()
        )
        aid.send_message_content(to_aid_list=[sender], session_id=session_id, llm_content=result)
        return True

    aid.online()
    acp.serve_forever()