DevOps \u2014 \u4e00\u7ad9\u5f0f\u81ea\u52a8\u5316\u8fd0\u7ef4\u4e0e\u57fa\u7840\u8bbe\u65bd\u7ba1\u7406\u5e73\u53f0 | \u5bb9\u5668\u7f16\u6392\u30fbCI\/CD \u6d41\u6c34\u7ebf\u30fb\u4e3b\u673a\u76d1\u63a7\u30fb\u914d\u7f6e\u7ba1\u7406\u30fb\u591a\u4e91\u534f\u540c\u30fb\u5168\u94fe\u8def\u81ea\u52a8\u5316\u8fd0\u7ef4\u5de5\u4f5c\u53f0<\/strong><\/p>\n\n\n\n \u96c6\u4e3b\u673a\u7ba1\u7406\u3001\u5bb9\u5668\u670d\u52a1\u3001CI\/CD \u6d41\u6c34\u7ebf\u3001\u914d\u7f6e\u4e2d\u5fc3\u3001\u65e5\u5fd7\u5ba1\u8ba1\u3001\u76d1\u63a7\u544a\u8b66\u3001\u591a\u4e91\u8d44\u6e90\u7f16\u6392<\/strong>\u4e8e\u4e00\u4f53\u7684\u5168\u6808 DevOps \u5e73\u53f0\uff0c\u9762\u5411\u7814\u53d1\u3001\u8fd0\u7ef4\u3001\u6d4b\u8bd5\u56e2\u961f\uff0c\u6253\u901a\u300c\u4ee3\u7801\u63d0\u4ea4\u2192\u6784\u5efa\u2192\u6d4b\u8bd5\u2192\u955c\u50cf\u6253\u5305\u2192\u90e8\u7f72\u2192\u76d1\u63a7\u2192\u8fd0\u7ef4\u300d\u5168\u6d41\u7a0b\u3002\u6df1\u5ea6\u9002\u914d\u524d\u6587 OpenClaw \u5de5\u5177\u751f\u6001\uff0c\u652f\u6301\u811a\u672c\u8054\u52a8\u3001\u4efb\u52a1\u7f16\u6392\u3001\u6279\u91cf\u8c03\u5ea6\uff0c\u517c\u987e\u4f20\u7edf\u865a\u62df\u673a\u3001Docker\u3001K8s\u3001\u516c\u6709\u4e91 \/ \u79c1\u6709\u4e91\u6df7\u5408\u67b6\u6784\uff0c\u5b9e\u73b0\u8fd0\u7ef4\u81ea\u52a8\u5316\u3001\u6d41\u7a0b\u6807\u51c6\u5316\u3001\u6545\u969c\u53ef\u89c6\u5316\u3001\u8d44\u6e90\u96c6\u7ea6\u5316<\/strong>\u3002<\/p>\n\n\n\n plaintext<\/p>\n\n\n\n txt<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n python<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n bash<\/p>\n\n\n\n \u8fd0\u884c<\/p>\n\n\n\n plaintext<\/p>\n\n\n\n \u4e00\u3001\u72ec\u7acb\u6807\u9898 & \u5dee\u5f02\u5316\u5b9a\u4f4d DevOps \u2014 \u4e00\u7ad9\u5f0f\u81ea\u52a8\u5316\u8fd0\u7ef4\u4e0e\u57fa\u7840\u8bbe\u65bd\u7ba1\u7406\u5e73\u53f0 | \u5bb9\u5668\u7f16\u6392\u30fbCI […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[20],"tags":[],"class_list":["post-307","post","type-post","status-publish","format-standard","hentry","category-mianfeiercikaifalongxiaskill"],"_links":{"self":[{"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/posts\/307","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/comments?post=307"}],"version-history":[{"count":1,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/posts\/307\/revisions"}],"predecessor-version":[{"id":308,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/posts\/307\/revisions\/308"}],"wp:attachment":[{"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/media?parent=307"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/categories?post=307"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.longxiapro.com\/index.php\/wp-json\/wp\/v2\/tags?post=307"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\u6838\u5fc3\u5b9a\u4f4d<\/h3>\n\n\n\n
\u72ec\u5bb6\u6539\u9020\u7279\u8272\uff08\u533a\u522b\u666e\u901a\u8fd0\u7ef4\u5de5\u5177\uff09<\/h3>\n\n\n\n
\n
Remotion<\/code> \u751f\u6210\u8fd0\u7ef4\u62a5\u8868\u89c6\u9891\u3001Wechat Article Search<\/code>\/WeChat MP CN<\/code> \u63a8\u9001\u8fd0\u7ef4\u544a\u8b66\u3001Financial Calculator Pro<\/code> \u8ba1\u7b97\u8d44\u6e90\u6210\u672c\u3001Backtest Expert<\/code> \u8054\u52a8\u670d\u52a1\u542f\u505c\u4efb\u52a1\u3002<\/li>\n\n\n\n\u4e8c\u3001\u4f20\u7edf\u8fd0\u7ef4\u5de5\u5177\u75db\u70b9<\/h3>\n\n\n\n
\n
\u4e09\u3001\u6838\u5fc3\u529f\u80fd\u6a21\u5757<\/h3>\n\n\n\n
1. \u8d44\u6e90\u7eb3\u7ba1\u6a21\u5757<\/h3>\n\n\n\n
\n
2. CI\/CD \u6d41\u6c34\u7ebf\u6a21\u5757<\/h3>\n\n\n\n
\n
3. \u6279\u91cf\u8fd0\u7ef4 & \u811a\u672c\u4e2d\u5fc3<\/h3>\n\n\n\n
\n
4. \u7edf\u4e00\u914d\u7f6e\u4e2d\u5fc3<\/h3>\n\n\n\n
\n
5. \u5168\u7ef4\u5ea6\u76d1\u63a7\u544a\u8b66<\/h3>\n\n\n\n
\n
6. \u5b89\u5168\u4e0e\u5ba1\u8ba1<\/h3>\n\n\n\n
\n
7. \u751f\u6001\u5bf9\u63a5\u6a21\u5757<\/h3>\n\n\n\n
\n
\u56db\u3001\u9879\u76ee\u76ee\u5f55\u7ed3\u6784<\/h3>\n\n\n\n
devops\/\n\u251c\u2500\u2500 config\/ # \u5168\u5c40\u914d\u7f6e\u3001\u96c6\u7fa4\u3001\u6743\u9650\u3001\u544a\u8b66\u89c4\u5219\u3001\u8fde\u63a5\u53c2\u6570\n\u251c\u2500\u2500 core\/ # \u5e95\u5c42\u5185\u6838\uff1a\u8fdc\u7a0b\u8fde\u63a5\u3001\u5bb9\u5668\u4ea4\u4e92\u3001\u4efb\u52a1\u5f15\u64ce\u3001\u52a0\u5bc6\u6a21\u5757\n\u251c\u2500\u2500 resource\/ # \u8d44\u6e90\u7ba1\u7406\uff1a\u4e3b\u673a\u3001Docker\u3001K8s\u3001\u591a\u4e91\u8d44\u6e90\n\u251c\u2500\u2500 cicd\/ # CI\/CD\u6d41\u6c34\u7ebf\u3001\u4ee3\u7801\u62c9\u53d6\u3001\u6784\u5efa\u3001\u53d1\u5e03\u3001\u56de\u6eda\n\u251c\u2500\u2500 script\/ # \u811a\u672c\u4e2d\u5fc3\u3001\u6279\u91cf\u547d\u4ee4\u3001\u6587\u4ef6\u5206\u53d1\u3001\u5b9a\u65f6\u4efb\u52a1\n\u251c\u2500\u2500 config_center\/ # \u914d\u7f6e\u4e2d\u5fc3\u3001\u73af\u5883\u7ba1\u7406\u3001\u5bc6\u94a5\u3001\u914d\u7f6e\u4e0b\u53d1\n\u251c\u2500\u2500 monitor\/ # \u76d1\u63a7\u91c7\u96c6\u3001\u6307\u6807\u8ba1\u7b97\u3001\u65e5\u5fd7\u68c0\u7d22\u3001\u544a\u8b66\u5f15\u64ce\n\u251c\u2500\u2500 audit\/ # \u6743\u9650\u3001\u5ba1\u8ba1\u65e5\u5fd7\u3001\u5b89\u5168\u62e6\u622a\n\u251c\u2500\u2500 api\/ # FastAPI\u63a5\u53e3\u3001\u5916\u90e8\u8054\u52a8\u3001OpenClaw\u5bf9\u63a5\n\u251c\u2500\u2500 web\/ # \u524d\u7aef\u7ba1\u7406\u754c\u9762\u3001\u53ef\u89c6\u5316\u770b\u677f\u3001\u62d6\u62fd\u6d41\u6c34\u7ebf\n\u251c\u2500\u2500 utils\/ # \u5de5\u5177\u51fd\u6570\u3001\u65e5\u5fd7\u3001\u52a0\u5bc6\u3001\u65f6\u95f4\u3001\u683c\u5f0f\u5904\u7406\n\u251c\u2500\u2500 requirements.txt # \u9879\u76ee\u4f9d\u8d56\n\u2514\u2500\u2500 main.py # \u9879\u76ee\u5165\u53e3\n<\/code><\/pre>\n\n\n\n\u4e94\u3001\u5b8c\u6574\u4e8c\u6b21\u5f00\u53d1\u4ee3\u7801<\/h3>\n\n\n\n
1. requirements.txt<\/h3>\n\n\n\n
# \u57fa\u7840\u6846\u67b6\nfastapi>=0.104.0\nuvicorn>=0.24.0\nstreamlit>=1.28.0\n\n# \u8fdc\u7a0b\u8fde\u63a5 & \u4e3b\u673a\u7ba1\u7406\nparamiko>=3.3.1\nnetmiko>=4.2.0\nfabric>=2.7.0\n\n# Docker & K8s\ndocker>=6.1.3\nkubernetes>=28.1.0\n\n# \u6570\u636e\u5b58\u50a8 & \u7f13\u5b58\nredis>=5.0.0\nsqlalchemy>=2.0.0\n\n# \u76d1\u63a7 & \u6570\u636e\u91c7\u96c6\npsutil>=5.9.6\nprometheus-client>=0.18.0\n\n# \u5b9a\u65f6\u4efb\u52a1\napscheduler>=3.10.0\n\n# \u5de5\u5177\nloguru>=0.7.2\npython-dotenv>=1.0.0\ncryptography>=41.0.0\n<\/code><\/pre>\n\n\n\n2. config\/settings.py<\/h3>\n\n\n\n
import os\nfrom dotenv import load_dotenv\nload_dotenv()\n\n# \u670d\u52a1\u7aef\u53e3\nAPI_HOST = \"0.0.0.0\"\nAPI_PORT = 8130\n\n# \u6570\u636e\u5e93\nDB_URL = os.getenv(\"DB_URL\", \"sqlite:\/\/\/.\/devops.db\")\n\n# Redis \u7f13\u5b58\nREDIS_HOST = os.getenv(\"REDIS_HOST\", \"127.0.0.1\")\nREDIS_PORT = int(os.getenv(\"REDIS_PORT\", 6379))\n\n# \u8fdc\u7a0b\u8fde\u63a5\u9ed8\u8ba4\u8d85\u65f6\nSSH_TIMEOUT = 10\n\n# \u4efb\u52a1\u6267\u884c\u6700\u5927\u5e76\u53d1\nMAX_CONCURRENT_TASK = 20\n\n# \u544a\u8b66\u63a8\u9001Webhook\nALERT_WEBHOOK = os.getenv(\"ALERT_WEBHOOK\", \"\")\n\n# \u65e5\u5fd7\u4fdd\u7559\u5929\u6570\nLOG_RETAIN_DAYS = 30\n<\/code><\/pre>\n\n\n\n3. utils\/logger.py<\/h3>\n\n\n\n
from loguru import logger\nimport os\nfrom config.settings import LOG_RETAIN_DAYS\n\nlog_path = \".\/logs\/devops_run.log\"\n\nlogger.add(\n log_path,\n rotation=\"500 MB\",\n retention=f\"{LOG_RETAIN_DAYS} days\",\n level=\"INFO\",\n encoding=\"utf-8\",\n enqueue=True\n)\n\ndef get_logger():\n return logger\n<\/code><\/pre>\n\n\n\n4. core\/ssh_client.py\uff08SSH \u8fdc\u7a0b\u8fde\u63a5\u5185\u6838\uff09<\/h3>\n\n\n\n
import paramiko\nfrom paramiko.ssh_exception import SSHException, NoValidConnectionsError\nfrom config.settings import SSH_TIMEOUT\nfrom utils.logger import get_logger\n\nlogger = get_logger()\n\nclass SSHClient:\n def __init__(self, host, port=22, username=\"root\", password=None, key_file=None):\n self.host = host\n self.port = port\n self.username = username\n self.password = password\n self.key_file = key_file\n self.client = None\n\n def connect(self):\n \"\"\"\u5efa\u7acbSSH\u8fde\u63a5\"\"\"\n try:\n self.client = paramiko.SSHClient()\n self.client.set_missing_host_key_policy(paramiko.AutoAddPolicy())\n if self.key_file:\n private_key = paramiko.RSAKey.from_private_key_file(self.key_file)\n self.client.connect(\n hostname=self.host,\n port=self.port,\n username=self.username,\n pkey=private_key,\n timeout=SSH_TIMEOUT\n )\n else:\n self.client.connect(\n hostname=self.host,\n port=self.port,\n username=self.username,\n password=self.password,\n timeout=SSH_TIMEOUT,\n look_for_keys=False,\n allow_agent=False\n )\n logger.info(f\"\u4e3b\u673a {self.host} \u8fde\u63a5\u6210\u529f\")\n return True\n except (SSHException, NoValidConnectionsError) as e:\n logger.error(f\"\u4e3b\u673a {self.host} \u8fde\u63a5\u5931\u8d25: {str(e)}\")\n return False\n\n def exec_command(self, cmd):\n \"\"\"\u6267\u884c\u8fdc\u7a0b\u547d\u4ee4\"\"\"\n if not self.client:\n if not self.connect():\n return \"\", \"\u8fde\u63a5\u5931\u8d25\"\n try:\n stdin, stdout, stderr = self.client.exec_command(cmd)\n out = stdout.read().decode(\"utf-8\", errors=\"ignore\")\n err = stderr.read().decode(\"utf-8\", errors=\"ignore\")\n return out, err\n except Exception as e:\n logger.error(f\"\u6267\u884c\u547d\u4ee4\u5f02\u5e38 {self.host}: {str(e)}\")\n return \"\", str(e)\n\n def close(self):\n \"\"\"\u5173\u95ed\u8fde\u63a5\"\"\"\n if self.client:\n self.client.close()\n logger.info(f\"\u4e3b\u673a {self.host} \u8fde\u63a5\u5df2\u5173\u95ed\")\n\n# \u6279\u91cf\u4e3b\u673a\u6267\u884c\u5c01\u88c5\ndef batch_exec(host_list, cmd):\n result = {}\n for host_info in host_list:\n cli = SSHClient(\n host=host_info[\"host\"],\n port=host_info.get(\"port\",22),\n username=host_info[\"user\"],\n password=host_info.get(\"pwd\")\n )\n out, err = cli.exec_command(cmd)\n result[host_info[\"host\"]] = {\"stdout\": out, \"stderr\": err}\n cli.close()\n return result\n<\/code><\/pre>\n\n\n\n5. core\/docker_client.py\uff08Docker \u5bb9\u5668\u7ba1\u7406\uff09<\/h3>\n\n\n\n
import docker\nfrom utils.logger import get_logger\n\nlogger = get_logger()\n\nclass DockerClient:\n def __init__(self, base_url=\"unix:\/\/\/var\/run\/docker.sock\"):\n try:\n self.client = docker.DockerClient(base_url=base_url)\n except Exception as e:\n logger.error(f\"Docker \u8fde\u63a5\u5931\u8d25: {str(e)}\")\n self.client = None\n\n def list_containers(self, all_containers=False):\n \"\"\"\u5217\u51fa\u5bb9\u5668\"\"\"\n if not self.client:\n return []\n containers = self.client.containers.list(all=all_containers)\n res = []\n for c in containers:\n res.append({\n \"id\": c.short_id,\n \"name\": c.name,\n \"status\": c.status,\n \"image\": c.image.tags[0] if c.image.tags else \"\"\n })\n return res\n\n def start_container(self, container_name):\n \"\"\"\u542f\u52a8\u5bb9\u5668\"\"\"\n if not self.client:\n return False\n try:\n container = self.client.containers.get(container_name)\n container.start()\n logger.info(f\"\u5bb9\u5668 {container_name} \u542f\u52a8\u6210\u529f\")\n return True\n except Exception as e:\n logger.error(f\"\u542f\u52a8\u5bb9\u5668\u5931\u8d25 {container_name}: {str(e)}\")\n return False\n\n def stop_container(self, container_name):\n \"\"\"\u505c\u6b62\u5bb9\u5668\"\"\"\n if not self.client:\n return False\n try:\n container = self.client.containers.get(container_name)\n container.stop()\n logger.info(f\"\u5bb9\u5668 {container_name} \u505c\u6b62\u6210\u529f\")\n return True\n except Exception as e:\n logger.error(f\"\u505c\u6b62\u5bb9\u5668\u5931\u8d25 {container_name}: {str(e)}\")\n return False\n\ndocker_cli = DockerClient()\n<\/code><\/pre>\n\n\n\n6. monitor\/host_monitor.py\uff08\u4e3b\u673a\u6307\u6807\u76d1\u63a7\uff09<\/h3>\n\n\n\n
import psutil\nimport time\nfrom utils.logger import get_logger\n\nlogger = get_logger()\n\nclass HostMonitor:\n @staticmethod\n def get_cpu_info():\n \"\"\"CPU\u4f7f\u7528\u7387\"\"\"\n return psutil.cpu_percent(interval=1)\n\n @staticmethod\n def get_memory_info():\n \"\"\"\u5185\u5b58\u4fe1\u606f\"\"\"\n mem = psutil.virtual_memory()\n return {\n \"total\": round(mem.total \/ 1024 \/ 1024 \/ 1024, 2),\n \"used\": round(mem.used \/ 1024 \/ 1024 \/ 1024, 2),\n \"percent\": mem.percent\n }\n\n @staticmethod\n def get_disk_info():\n \"\"\"\u78c1\u76d8\u4fe1\u606f\"\"\"\n disk = psutil.disk_usage(\"\/\")\n return {\n \"total\": round(disk.total \/ 1024 \/ 1024 \/ 1024, 2),\n \"used\": round(disk.used \/ 1024 \/ 1024 \/ 1024, 2),\n \"percent\": disk.percent\n }\n\n @staticmethod\n def get_all_metrics():\n \"\"\"\u83b7\u53d6\u5168\u91cf\u4e3b\u673a\u6307\u6807\"\"\"\n return {\n \"cpu_percent\": HostMonitor.get_cpu_info(),\n \"memory\": HostMonitor.get_memory_info(),\n \"disk\": HostMonitor.get_disk_info(),\n \"timestamp\": int(time.time())\n }\n\nhost_monitor = HostMonitor()\n<\/code><\/pre>\n\n\n\n7. cicd\/pipeline.py\uff08\u7b80\u6613 CI\/CD \u6d41\u6c34\u7ebf\uff09<\/h3>\n\n\n\n
from utils.logger import get_logger\nfrom core.ssh_client import SSHClient\n\nlogger = get_logger()\n\nclass Pipeline:\n def __init__(self, name):\n self.name = name\n self.stages = []\n\n def add_stage(self, stage_name, cmd_list):\n \"\"\"\u6dfb\u52a0\u6d41\u6c34\u7ebf\u9636\u6bb5\"\"\"\n self.stages.append({\n \"stage_name\": stage_name,\n \"commands\": cmd_list\n })\n\n def run(self, host_info):\n \"\"\"\u6267\u884c\u6d41\u6c34\u7ebf\"\"\"\n logger.info(f\"\u5f00\u59cb\u6267\u884c\u6d41\u6c34\u7ebf: {self.name}\")\n cli = SSHClient(\n host=host_info[\"host\"],\n port=host_info.get(\"port\",22),\n username=host_info[\"user\"],\n password=host_info.get(\"pwd\")\n )\n if not cli.connect():\n return {\"status\": \"fail\", \"msg\": \"\u4e3b\u673a\u8fde\u63a5\u5931\u8d25\"}\n\n result_log = []\n for stage in self.stages:\n logger.info(f\"\u6267\u884c\u9636\u6bb5: {stage['stage_name']}\")\n for cmd in stage[\"commands\"]:\n out, err = cli.exec_command(cmd)\n result_log.append({\n \"stage\": stage[\"stage_name\"],\n \"cmd\": cmd,\n \"stdout\": out,\n \"stderr\": err\n })\n cli.close()\n logger.info(f\"\u6d41\u6c34\u7ebf {self.name} \u6267\u884c\u5b8c\u6210\")\n return {\"status\": \"success\", \"pipeline\": self.name, \"details\": result_log}\n<\/code><\/pre>\n\n\n\n8. api\/route.py\uff08FastAPI \u63a5\u53e3 + OpenClaw \u5bf9\u63a5\uff09<\/h3>\n\n\n\n
from fastapi import FastAPI, Query, Body\nfrom core.ssh_client import SSHClient, batch_exec\nfrom core.docker_client import docker_cli\nfrom monitor.host_monitor import host_monitor\nfrom cicd.pipeline import Pipeline\nfrom utils.logger import get_logger\n\napp = FastAPI(title=\"DevOps \u2014 \u81ea\u52a8\u5316\u90e8\u7f72\u4e0e\u57fa\u7840\u8bbe\u65bd\u7ba1\u7406\")\nlogger = get_logger()\n\n# \u4e3b\u673a\u76d1\u63a7\n@app.get(\"\/monitor\/host\")\ndef get_host_metric():\n \"\"\"\u83b7\u53d6\u672c\u673a\u76d1\u63a7\u6307\u6807\"\"\"\n return host_monitor.get_all_metrics()\n\n# \u5355\u4e3b\u673a\u6267\u884c\u547d\u4ee4\n@app.post(\"\/ssh\/exec\")\ndef ssh_exec(\n host: str = Body(...),\n user: str = Body(...),\n pwd: str = Body(None),\n cmd: str = Body(...)\n):\n cli = SSHClient(host=host, username=user, password=pwd)\n out, err = cli.exec_command(cmd)\n cli.close()\n return {\"stdout\": out, \"stderr\": err}\n\n# \u6279\u91cf\u4e3b\u673a\u6267\u884c\n@app.post(\"\/ssh\/batch\")\ndef ssh_batch(\n host_list: list = Body(...),\n cmd: str = Body(...)\n):\n res = batch_exec(host_list, cmd)\n return res\n\n# Docker \u5bb9\u5668\u5217\u8868\n@app.get(\"\/docker\/containers\")\ndef list_container(all: bool = Query(False)):\n return {\"containers\": docker_cli.list_containers(all)}\n\n# \u5bb9\u5668\u542f\u505c\n@app.get(\"\/docker\/start\")\ndef docker_start(name: str = Query(...)):\n return {\"result\": docker_cli.start_container(name)}\n\n@app.get(\"\/docker\/stop\")\ndef docker_stop(name: str = Query(...)):\n return {\"result\": docker_cli.stop_container(name)}\n\n# CI\/CD \u6d41\u6c34\u7ebf\u6267\u884c\n@app.post(\"\/cicd\/run\")\ndef run_pipeline(\n pipeline_name: str = Body(...),\n host_info: dict = Body(...),\n stages: list = Body(...)\n):\n pipe = Pipeline(pipeline_name)\n for s in stages:\n pipe.add_stage(s[\"name\"], s[\"commands\"])\n return pipe.run(host_info)\n\n@app.get(\"\/health\")\ndef health():\n return {\"service\": \"DevOps \u81ea\u52a8\u5316\u8fd0\u7ef4\u5e73\u53f0\", \"status\": \"running\"}\n<\/code><\/pre>\n\n\n\n9. web\/app.py\uff08Streamlit \u7b80\u6613\u7ba1\u7406\u540e\u53f0\uff09<\/h3>\n\n\n\n
import streamlit as st\nfrom core.ssh_client import SSHClient\nfrom core.docker_client import docker_cli\nfrom monitor.host_monitor import host_monitor\n\nst.set_page_config(page_title=\"DevOps \u8fd0\u7ef4\u5e73\u53f0\", layout=\"wide\")\nst.title(\"\u2699\ufe0f DevOps \u2014 \u81ea\u52a8\u5316\u90e8\u7f72\u4e0e\u57fa\u7840\u8bbe\u65bd\u7ba1\u7406\")\n\ntab1, tab2, tab3, tab4 = st.tabs([\"\u4e3b\u673a\u76d1\u63a7\",\"\u8fdc\u7a0b\u547d\u4ee4\",\"\u5bb9\u5668\u7ba1\u7406\",\"\u4efb\u52a1\u6d41\u6c34\u7ebf\"])\n\n# \u4e3b\u673a\u76d1\u63a7\nwith tab1:\n st.subheader(\"\u672c\u673a\u8d44\u6e90\u76d1\u63a7\")\n metric = host_monitor.get_all_metrics()\n st.metric(\"CPU\u4f7f\u7528\u7387\", f\"{metric['cpu_percent']} %\")\n st.metric(\"\u5185\u5b58\u4f7f\u7528\u7387\", f\"{metric['memory']['percent']} %\")\n st.metric(\"\u78c1\u76d8\u4f7f\u7528\u7387\", f\"{metric['disk']['percent']} %\")\n\n# \u8fdc\u7a0b\u547d\u4ee4\nwith tab2:\n st.subheader(\"\u8fdc\u7a0b\u4e3b\u673a\u6267\u884c\u547d\u4ee4\")\n host = st.text_input(\"\u4e3b\u673aIP\")\n user = st.text_input(\"\u7528\u6237\u540d\", value=\"root\")\n pwd = st.text_input(\"\u5bc6\u7801\", type=\"password\")\n cmd = st.text_area(\"\u6267\u884c\u547d\u4ee4\")\n if st.button(\"\u6267\u884c\"):\n cli = SSHClient(host=host, username=user, password=pwd)\n out, err = cli.exec_command(cmd)\n st.code(out, language=\"shell\")\n if err:\n st.error(err)\n cli.close()\n\n# \u5bb9\u5668\u7ba1\u7406\nwith tab3:\n st.subheader(\"Docker \u5bb9\u5668\u5217\u8868\")\n if st.button(\"\u5237\u65b0\u5bb9\u5668\"):\n containers = docker_cli.list_containers(all=True)\n st.dataframe(containers)\n\n# \u6d41\u6c34\u7ebf\nwith tab4:\n st.subheader(\"CI\/CD \u7b80\u6613\u6d41\u6c34\u7ebf\")\n st.info(\"\u53ef\u914d\u7f6e\u7f16\u8bd1\u3001\u6253\u5305\u3001\u90e8\u7f72\u591a\u9636\u6bb5\u547d\u4ee4\u5e76\u6267\u884c\")\n<\/code><\/pre>\n\n\n\n10. main.py\uff08\u9879\u76ee\u5165\u53e3\uff09<\/h3>\n\n\n\n
import uvicorn\nfrom api.route import app\nfrom config.settings import API_HOST, API_PORT\nfrom utils.logger import get_logger\n\nlogger = get_logger()\n\nif __name__ == \"__main__\":\n logger.info(\"DevOps \u81ea\u52a8\u5316\u90e8\u7f72\u4e0e\u57fa\u7840\u8bbe\u65bd\u7ba1\u7406\u5e73\u53f0 \u542f\u52a8\u6210\u529f\")\n uvicorn.run(app, host=API_HOST, port=API_PORT)\n<\/code><\/pre>\n\n\n\n\u516d\u3001\u7279\u8272\u6539\u9020\u843d\u5730\u8bf4\u660e<\/h3>\n\n\n\n
\n
\u4e03\u3001\u4f7f\u7528\u793a\u4f8b<\/h3>\n\n\n\n
1. \u542f\u52a8\u670d\u52a1<\/h3>\n\n\n\n
python main.py\n# Web \u754c\u9762\uff1ahttp:\/\/127.0.0.1:8501\n# API \u63a5\u53e3\uff1ahttp:\/\/127.0.0.1:8130\n<\/code><\/pre>\n\n\n\n2. \u5e38\u7528 API \u8c03\u7528<\/h3>\n\n\n\n
# \u83b7\u53d6\u672c\u673a\u76d1\u63a7\u6307\u6807\nhttp://127.0.0.1:8130\/monitor\/host\n\n# \u67e5\u770bDocker\u5bb9\u5668\nhttp:\/\/127.0.0.1:8130\/docker\/containers\n\n# \u542f\u52a8\u5bb9\u5668\nhttp:\/\/127.0.0.1:8130\/docker\/start?name=nginx\n<\/code><\/pre>\n\n\n\n3. Web \u540e\u53f0\u64cd\u4f5c<\/h3>\n\n\n\n
\n
\u516b\u3001\u4e8c\u6b21\u5f00\u53d1\u62d3\u5c55\u65b9\u5411<\/h3>\n\n\n\n
\n