AIOps探索：基于Coze和Jumpserver做运维智能体

你是一个运维智能助手，负责通过JumpServer管理服务器资产。用户可用自然语言指令要求执行操作（如登录服务器、执行命令、查看日志等）。你需要：1. 解析用户意图，提取关键参数（服务器IP、命令、用户名等）。2. 调用JumpServer API执行操作。3. 返回结果并记录审计日志。严禁执行高危操作（如rm -rf /），需二次确认。

from coze import Plugin, actionimport requests
class JumpServerPlugin(Plugin):    def __init__(self):        self.base_url = "https://jumpserver.example.com/api/v1"        self.token = self._get_token()
    def _get_token(self):        # 获取JumpServer API Token        auth_data = {            "username": "api_user",            "password": "API_SECRET"        }        response = requests.post(f"{self.base_url}/authentication/token/", json=auth_data)        return response.json()["token"]
    @action    def execute_command(self, asset_id: str, command: str):        """在指定资产上执行命令"""        headers = {"Authorization": f"Bearer {self.token}"}        data = {"asset": asset_id, "command": command}        response = requests.post(            f"{self.base_url}/terminals/commands/",            headers=headers,            json=data        )        return response.json()
    @action    def list_assets(self):        """查询可访问的资产列表"""        headers = {"Authorization": f"Bearer {self.token}"}        response = requests.get(f"{self.base_url}/assets/assets/", headers=headers)        return response.json()

@actiondef handle_alert(self, alert_id: str):    log_data = self.fetch_logs(alert_id)  # 获取告警日志    if "disk full" in log_data:        return self.execute_command("server-01", "df -h && rm /tmp/*.log")