手把手教你实现自己的“Manus”：构建基于容器的多用户Agent应用【下】

...
def execute_code_docker(
    code: str,
    language: str,
    user_id: str  ,
    task_id: str
) -> str:
    """
    在Docker容器中执行代码的函数
    
    Args:
        code: 要执行的代码
        language: 代码语言 ("python", "bash", "sh")
        user_id: 用户ID，区分不同用户
        task_id: 任务ID，如果不提供则创建新任务
        
    Returns:
        字符串结果，包含输出或错误信息
    """
    .........此处省略.......
    return json.dumps(result_data)

def create_code_executor_docker_tool():
    """创建docker代码执行工具"""
    return FunctionTool.from_defaults(
        name="docker_code_executor",
        description="在Docker容器中执行Python代码或Shell脚本。对于Python代码，使用language='python'；对于Shell脚本，使用language='bash'或'sh'。需要提供user_id区分不同用户，可以指定task_id继续在特定任务上下文中执行，不指定则创建新任务。",
        fn=execute_code_docker,
    )

...
# 初始化浏览器
browser = Browser(config=browser_config)
    
# 创建代理，输入task即可，比如“上youtube看当前热点”
agent = Agent(
            task=task,
            llm=llm,
            use_vision=use_vision,
            max_failures=max_failures,
            max_actions_per_step=max_actions,
            browser=browser
)

result = await agent.run()

def execute_browser_task(
    task_description: str, 
    user_id: str = "default", 
    task_id: Optional[str] = None
) -> str:
    """
    执行浏览器任务并返回结果
    
    Args:
        task_description: 浏览器工作任务描述文本
        user_id: 用户ID，区分不同用户
        task_id: 任务ID，如果不提供则创建新任务
        
    Returns:
        str: JSON格式的任务执行结果
    """
    shell_code = f'python /app/agent_browser.py -t "{task_description}"'
   
    ...此处省略...

    result = container.execute(shell_code, "bash")

    ...

...
prompt = f"""{CODE_GENERATION_PROMPT}
任务描述：{task_description}
额外上下文：{additional_context}

请直接返回代码，无需其他解释。
"""

...
 # 创建用户专属的工具实例
        tool_code_executor_docker = create_code_executor_docker_tool()
        tool_browser_docker = create_browser_docker_tool()
        tool_code_generator = create_code_generator_tool()
        tool_webpage_crawler = create_webpage_crawler_tool() # 新增网页采集工具
        
        # 创建用户专属的Agent
        _agents[user_id] = ReActAgent.from_tools(
            max_iterations=20,
            tools=[
                tool_code_generator,
                tool_code_executor_docker,
                tool_browser_docker,
                tool_webpage_crawler # 添加到工具列表
            ],
            llm=llm,
            verbose=True,
            context=REACT_AGENT_CONTEXT
        )
...