psutil(Python system and process utilities)\u662f\u4e00\u4e2a\u8de8\u5e73\u53f0\u7684Python\u5e93，\u5b83\u5141\u8bb8\u5f00\u53d1\u4eba\u5458\u8f7b\u677e\u83b7\u53d6\u7cfb\u7edf\u8fd0\u884c\u65f6\u7684\u5404\u79cd\u4fe1\u606f\u3002\u8fd9\u4e2a\u5e93\u6700\u521d\u7531Giampaolo Rodola\u57282009\u5e74\u521b\u5efa，\u73b0\u5728\u5df2\u7ecf\u6210\u4e3aPython\u751f\u6001\u7cfb\u7edf\u4e2d\u7cfb\u7edf\u76d1\u63a7\u9886\u57df\u7684\u6807\u51c6\u5de5\u5177\u4e4b\u4e00\u3002psutil\u63d0\u4f9b\u4e86\u4e00\u79cd\u7b80\u5355\u800c\u7edf\u4e00\u7684\u65b9\u5f0f\u6765\u83b7\u53d6\u7cfb\u7edf\u5229\u7528\u7387\u4fe1\u606f(CPU\u3001\u5185\u5b58\u3001\u78c1\u76d8\u3001\u7f51\u7edc)\u548c\u8fdb\u7a0b\u7ba1\u7406\u529f\u80fd，\u4e0d\u9700\u8981\u4f9d\u8d56\u7cfb\u7edf\u7279\u5b9a\u7684\u547d\u4ee4\u884c\u5de5\u5177\u3002<\/p>\n
\u5728\u7cfb\u7edf\u76d1\u63a7\u548c\u8d44\u6e90\u7ba1\u7406\u9886\u57df，psutil\u626e\u6f14\u7740\u81f3\u5173\u91cd\u8981\u7684\u89d2\u8272\u3002\u5b83\u53ef\u4ee5\u5e2e\u52a9\u5f00\u53d1\u4eba\u5458：<\/p>\n
psutil\u53ef\u4ee5\u901a\u8fc7Python\u7684\u5305\u7ba1\u7406\u5de5\u5177pip\u8f7b\u677e\u5b89\u88c5：<\/p>\n
pip install psutil<\/p>\n
\u5bf9\u4e8e\u7279\u5b9a\u7248\u672c\u7684\u9700\u6c42，\u53ef\u4ee5\u6307\u5b9a\u7248\u672c\u53f7\u5b89\u88c5：<\/p>\n
pip install psutil==5.9.0<\/p>\n
psutil\u5177\u6709\u51fa\u8272\u7684\u8de8\u5e73\u53f0\u517c\u5bb9\u6027，\u652f\u6301\u4ee5\u4e0b\u64cd\u4f5c\u7cfb\u7edf：<\/p>\n
\u652f\u6301\u7684Python\u7248\u672c\u5305\u62ec：<\/p>\n
psutil\u63d0\u4f9b\u4e86\u591a\u79cdCPU\u76d1\u63a7\u529f\u80fd：<\/p>\n
import psutil<\/p>\n
# \u83b7\u53d6CPU\u903b\u8f91\u6838\u5fc3\u6570
\nprint(f"\u903b\u8f91CPU\u6838\u5fc3\u6570: {psutil.cpu_count()}")<\/p>\n
# \u83b7\u53d6CPU\u7269\u7406\u6838\u5fc3\u6570(\u4e0d\u5305\u62ec\u8d85\u7ebf\u7a0b)
\nprint(f"\u7269\u7406CPU\u6838\u5fc3\u6570: {psutil.cpu_count(logical=False)}")<\/p>\n
# \u83b7\u53d6CPU\u4f7f\u7528\u7387(\u963b\u585e1\u79d2)
\nprint(f"CPU\u4f7f\u7528\u7387: {psutil.cpu_percent(interval=1)}%")<\/p>\n
# \u83b7\u53d6\u6bcf\u4e2aCPU\u6838\u5fc3\u7684\u4f7f\u7528\u7387
\nprint(f"\u5404\u6838\u5fc3\u4f7f\u7528\u7387: {psutil.cpu_percent(interval=1, percpu=True)}")<\/p>\n
# \u83b7\u53d6CPU\u9891\u7387\u4fe1\u606f
\ncpu_freq = psutil.cpu_freq()
\nprint(f"\u5f53\u524d\u9891\u7387: {cpu_freq.current}MHz")
\nprint(f"\u6700\u5c0f\u9891\u7387: {cpu_freq.min}MHz")
\nprint(f"\u6700\u5927\u9891\u7387: {cpu_freq.max}MHz")<\/p>\n
# \u83b7\u53d6CPU\u7edf\u8ba1\u4fe1\u606f(\u4e0a\u4e0b\u6587\u5207\u6362\u3001\u4e2d\u65ad\u7b49)
\nprint(f"CPU\u7edf\u8ba1: {psutil.cpu_stats()}")<\/p>\n
psutil\u53ef\u4ee5\u8be6\u7ec6\u76d1\u63a7\u7cfb\u7edf\u5185\u5b58\u4f7f\u7528\u60c5\u51b5：<\/p>\n
# \u83b7\u53d6\u7269\u7406\u5185\u5b58\u4fe1\u606f
\nmem = psutil.virtual_memory()
\nprint(f"\u603b\u5185\u5b58: {mem.total\/1024\/1024:.2f} MB")
\nprint(f"\u53ef\u7528\u5185\u5b58: {mem.available\/1024\/1024:.2f} MB")
\nprint(f"\u5df2\u7528\u5185\u5b58: {mem.used\/1024\/1024:.2f} MB")
\nprint(f"\u5185\u5b58\u4f7f\u7528\u7387: {mem.percent}%")<\/p>\n
# \u83b7\u53d6\u4ea4\u6362\u5185\u5b58\u4fe1\u606f
\nswap = psutil.swap_memory()
\nprint(f"\u4ea4\u6362\u5185\u5b58\u603b\u91cf: {swap.total\/1024\/1024:.2f} MB")
\nprint(f"\u5df2\u7528\u4ea4\u6362\u5185\u5b58: {swap.used\/1024\/1024:.2f} MB")
\nprint(f"\u4ea4\u6362\u5185\u5b58\u4f7f\u7528\u7387: {swap.percent}%")<\/p>\n
\u78c1\u76d8\u76d1\u63a7\u529f\u80fd\u793a\u4f8b：<\/p>\n
# \u83b7\u53d6\u78c1\u76d8\u5206\u533a\u4fe1\u606f
\npartitions = psutil.disk_partitions()
\nfor partition in partitions:
\n print(f"\u8bbe\u5907: {partition.device}")
\n print(f"\u6302\u8f7d\u70b9: {partition.mountpoint}")
\n print(f"\u6587\u4ef6\u7cfb\u7edf\u7c7b\u578b: {partition.fstype}")<\/p>\n
# \u83b7\u53d6\u78c1\u76d8\u4f7f\u7528\u60c5\u51b5
\n usage = psutil.disk_usage(partition.mountpoint)
\n print(f"\u603b\u7a7a\u95f4: {usage.total\/1024\/1024:.2f} MB")
\n print(f"\u5df2\u7528\u7a7a\u95f4: {usage.used\/1024\/1024:.2f} MB")
\n print(f"\u53ef\u7528\u7a7a\u95f4: {usage.free\/1024\/1024:.2f} MB")
\n print(f"\u4f7f\u7528\u7387: {usage.percent}%")<\/p>\n
# \u83b7\u53d6\u78c1\u76d8IO\u7edf\u8ba1
\ndisk_io = psutil.disk_io_counters()
\nprint(f"\u8bfb\u53d6\u6b21\u6570: {disk_io.read_count}")
\nprint(f"\u5199\u5165\u6b21\u6570: {disk_io.write_count}")
\nprint(f"\u8bfb\u53d6\u5b57\u8282\u6570: {disk_io.read_bytes\/1024\/1024:.2f} MB")
\nprint(f"\u5199\u5165\u5b57\u8282\u6570: {disk_io.write_bytes\/1024\/1024:.2f} MB")<\/p>\n
\u7f51\u7edc\u76d1\u63a7\u529f\u80fd：<\/p>\n
# \u83b7\u53d6\u7f51\u7edc\u63a5\u53e3\u4fe1\u606f
\nnet_if = psutil.net_if_addrs()
\nfor interface, addrs in net_if.items():
\n print(f"\u63a5\u53e3: {interface}")
\n for addr in addrs:
\n print(f" IP\u5730\u5740: {addr.address}")
\n print(f" \u7f51\u7edc\u63a9\u7801: {addr.netmask}")
\n print(f" \u5e7f\u64ad\u5730\u5740: {addr.broadcast}")<\/p>\n
# \u83b7\u53d6\u7f51\u7edcIO\u7edf\u8ba1
\nnet_io = psutil.net_io_counters()
\nprint(f"\u53d1\u9001\u5b57\u8282\u6570: {net_io.bytes_sent\/1024:.2f} KB")
\nprint(f"\u63a5\u6536\u5b57\u8282\u6570: {net_io.bytes_recv\/1024:.2f} KB")
\nprint(f"\u53d1\u9001\u6570\u636e\u5305\u6570: {net_io.packets_sent}")
\nprint(f"\u63a5\u6536\u6570\u636e\u5305\u6570: {net_io.packets_recv}")<\/p>\n
# \u83b7\u53d6\u5f53\u524d\u7f51\u7edc\u8fde\u63a5
\nconnections = psutil.net_connections()
\nfor conn in connections:
\n print(f"\u534f\u8bae: {conn.type}")
\n print(f"\u672c\u5730\u5730\u5740: {conn.laddr}")
\n print(f"\u8fdc\u7a0b\u5730\u5740: {conn.raddr}")
\n print(f"\u72b6\u6001: {conn.status}")<\/p>\n
# \u83b7\u53d6\u6240\u6709\u8fdb\u7a0bID
\npids = psutil.pids()<\/p>\n
# \u904d\u5386\u6240\u6709\u8fdb\u7a0b
\nfor proc in psutil.process_iter(['pid', 'name', 'username']):
\n try:
\n # \u83b7\u53d6\u8fdb\u7a0b\u8be6\u60c5
\n pinfo = proc.as_dict(attrs=['pid', 'name', 'cpu_percent', 'memory_percent'])
\n print(pinfo)
\n except psutil.NoSuchProcess:
\n pass<\/p>\n
# \u901a\u8fc7PID\u83b7\u53d6\u8fdb\u7a0b\u5bf9\u8c61
\npid = 1234 # \u66ff\u6362\u4e3a\u5b9e\u9645PID
\ntry:
\n p = psutil.Process(pid)<\/p>\n
# \u83b7\u53d6\u8fdb\u7a0b\u57fa\u672c\u4fe1\u606f
\n print(f"\u8fdb\u7a0b\u540d: {p.name()}")
\n print(f"\u6267\u884c\u8def\u5f84: {p.exe()}")
\n print(f"\u5de5\u4f5c\u76ee\u5f55: {p.cwd()}")
\n print(f"\u542f\u52a8\u547d\u4ee4: {p.cmdline()}")
\n print(f"\u542f\u52a8\u65f6\u95f4: {p.create_time()}")
\n print(f"\u7528\u6237\u540d: {p.username()}")<\/p>\n
# \u83b7\u53d6\u8d44\u6e90\u4f7f\u7528\u60c5\u51b5
\n print(f"CPU\u4f7f\u7528\u7387: {p.cpu_percent(interval=1.0)}%")
\n print(f"\u5185\u5b58\u4f7f\u7528\u7387: {p.memory_percent()}%")
\n mem_info = p.memory_info()
\n print(f"\u5e38\u9a7b\u5185\u5b58: {mem_info.rss\/1024\/1024:.2f} MB")
\n print(f"\u865a\u62df\u5185\u5b58: {mem_info.vms\/1024\/1024:.2f} MB")<\/p>\n
# \u83b7\u53d6\u7ebf\u7a0b\u4fe1\u606f
\n print(f"\u7ebf\u7a0b\u6570: {p.num_threads()}")<\/p>\n
# \u83b7\u53d6\u6253\u5f00\u7684\u6587\u4ef6
\n print(f"\u6253\u5f00\u7684\u6587\u4ef6: {p.open_files()}")<\/p>\n
# \u83b7\u53d6\u7f51\u7edc\u8fde\u63a5
\n print(f"\u7f51\u7edc\u8fde\u63a5: {p.connections()}")<\/p>\n
except psutil.NoSuchProcess:
\n print(f"\u8fdb\u7a0b {pid} \u4e0d\u5b58\u5728")<\/p>\n
# \u542f\u52a8\u65b0\u8fdb\u7a0b
\nimport subprocess
\nproc = subprocess.Popen(["python", "script.py"])
\npsutil_proc = psutil.Process(proc.pid)<\/p>\n
# \u7ec8\u6b62\u8fdb\u7a0b
\npsutil_proc.terminate() # \u4f18\u96c5\u7ec8\u6b62
\npsutil_proc.kill() # \u5f3a\u5236\u7ec8\u6b62<\/p>\n
# \u6302\u8d77\u548c\u6062\u590d\u8fdb\u7a0b
\npsutil_proc.suspend()
\npsutil_proc.resume()<\/p>\n
# \u7b49\u5f85\u8fdb\u7a0b\u7ed3\u675f
\npsutil_proc.wait(timeout=10)<\/p>\n
import time<\/p>\n
def monitor_system(interval=1):
\n """\u5b9e\u65f6\u76d1\u63a7\u7cfb\u7edf\u8d44\u6e90"""
\n while True:
\n # CPU\u4f7f\u7528\u7387
\n cpu_percent = psutil.cpu_percent(interval=interval, percpu=True)<\/p>\n
# \u5185\u5b58\u4f7f\u7528\u60c5\u51b5
\n mem = psutil.virtual_memory()<\/p>\n
# \u78c1\u76d8\u4f7f\u7528\u60c5\u51b5
\n disk = psutil.disk_usage('\/')<\/p>\n
# \u7f51\u7edcIO
\n net_io = psutil.net_io_counters()<\/p>\n
# \u6253\u5370\u76d1\u63a7\u4fe1\u606f
\n print("\\\\n" + "="*50)
\n print(f"\u65f6\u95f4: {time.strftime('%Y-%m-%d %H:%M:%S')}")
\n print(f"CPU\u4f7f\u7528\u7387: {cpu_percent}")
\n print(f"\u5185\u5b58\u4f7f\u7528: {mem.percent}%")
\n print(f"\u78c1\u76d8\u4f7f\u7528: {disk.percent}%")
\n print(f"\u7f51\u7edc: \u4e0a\u4f20 {net_io.bytes_sent\/1024:.2f}KB, \u4e0b\u8f7d {net_io.bytes_recv\/1024:.2f}KB")<\/p>\n
time.sleep(interval)<\/p>\n
# monitor_system()<\/p>\n
def generate_report(duration=60, interval=5):
\n """\u751f\u6210\u7cfb\u7edf\u8d44\u6e90\u4f7f\u7528\u62a5\u544a"""
\n records = []
\n end_time = time.time() + duration<\/p>\n
while time.time() < end_time:
\n record = {
\n 'timestamp': time.time(),
\n 'cpu': psutil.cpu_percent(interval=interval),
\n 'memory': psutil.virtual_memory().percent,
\n 'disk': psutil.disk_usage('\/').percent,
\n 'network_sent': psutil.net_io_counters().bytes_sent,
\n 'network_recv': psutil.net_io_counters().bytes_recv
\n }
\n records.append(record)<\/p>\n
# \u8ba1\u7b97\u7edf\u8ba1\u6570\u636e
\n cpu_avg = sum(r['cpu'] for r in records) \/ len(records)
\n mem_avg = sum(r['memory'] for r in records) \/ len(records)<\/p>\n
report = {
\n 'duration': duration,
\n 'cpu_avg': cpu_avg,
\n 'mem_avg': mem_avg,
\n 'peak_cpu': max(r['cpu'] for r in records),
\n 'peak_mem': max(r['memory'] for r in records),
\n 'network_total': (records[-1]['network_sent'] – records[0]['network_sent'] +
\n records[-1]['network_recv'] – records[0]['network_recv']) \/ 1024
\n }<\/p>\n
return report<\/p>\n
# print(generate_report())<\/p>\n
import logging
\nfrom logging.handlers import TimedRotatingFileHandler<\/p>\n
def setup_monitoring_logger():
\n """\u8bbe\u7f6e\u76d1\u63a7\u65e5\u5fd7"""
\n logger = logging.getLogger('system_monitor')
\n logger.setLevel(logging.INFO)<\/p>\n
# \u6bcf\u5929\u8f6e\u6362\u65e5\u5fd7，\u4fdd\u75597\u5929
\n handler = TimedRotatingFileHandler(
\n 'system_monitor.log',
\n when='D',
\n interval=1,
\n backupCount=7
\n )
\n formatter = logging.Formatter('%(asctime)s – %(message)s')
\n handler.setFormatter(formatter)
\n logger.addHandler(handler)<\/p>\n
return logger<\/p>\n
def log_system_stats(logger, interval=300):
\n """\u5b9a\u671f\u8bb0\u5f55\u7cfb\u7edf\u72b6\u6001\u5230\u65e5\u5fd7"""
\n while True:
\n stats = {
\n 'cpu': psutil.cpu_percent(interval=1),
\n 'mem': psutil.virtual_memory().percent,
\n 'disk': psutil.disk_usage('\/').percent
\n }
\n logger.info(f"CPU: {stats['cpu']}% | MEM: {stats['mem']}% | DISK: {stats['disk']}%")
\n time.sleep(interval)<\/p>\n
# logger = setup_monitoring_logger()
\n# log_system_stats(logger)<\/p>\n
\u5728\u4f7f\u7528psutil\u8fdb\u884c\u8de8\u5e73\u53f0\u5f00\u53d1\u65f6，\u9700\u8981\u6ce8\u610f\u4ee5\u4e0b\u5dee\u5f02：<\/p>\n
\u8def\u5f84\u8868\u793a：<\/p>\n
\u8fdb\u7a0b\u5c5e\u6027\u5dee\u5f02：<\/p>\n
def get_process_info(pid):
\n try:
\n p = psutil.Process(pid)
\n info = {
\n 'pid': pid,
\n 'name': p.name(),
\n 'status': p.status(),
\n 'cpu': p.cpu_percent(interval=0.1),
\n 'memory': p.memory_info().rss
\n }<\/p>\n
# Windows\u7279\u6709\u5c5e\u6027
\n if hasattr(p, 'username'):
\n info['user'] = p.username()<\/p>\n
# Unix\u7279\u6709\u5c5e\u6027
\n if hasattr(p, 'terminal'):
\n info['terminal'] = p.terminal()<\/p>\n
return info
\n except psutil.NoSuchProcess:
\n return None<\/p>\n<\/li>\n
\u7f51\u7edc\u63a5\u53e3\u547d\u540d：<\/p>\n
\u78c1\u76d8\u5206\u533a\u8868\u793a：<\/p>\n
import pandas as pd<\/p>\n
def collect_system_data(samples=10, interval=1):
\n """\u6536\u96c6\u7cfb\u7edf\u6570\u636e\u5e76\u8fd4\u56deDataFrame"""
\n data = []
\n for _ in range(samples):
\n record = {
\n 'timestamp': pd.Timestamp.now(),
\n 'cpu': psutil.cpu_percent(interval=interval),
\n 'memory': psutil.virtual_memory().percent,
\n 'disk': psutil.disk_usage('\/').percent
\n }
\n data.append(record)
\n time.sleep(interval)<\/p>\n
return pd.DataFrame(data)<\/p>\n
# df = collect_system_data()
\n# print(df.describe())<\/p>\n
import matplotlib.pyplot as plt<\/p>\n
def plot_system_metrics(df):
\n """\u7ed8\u5236\u7cfb\u7edf\u6307\u6807\u56fe\u8868"""
\n fig, axes = plt.subplots(nrows=3, ncols=1, figsize=(10, 8))<\/p>\n
# CPU\u4f7f\u7528\u7387
\n df.plot(x='timestamp', y='cpu', ax=axes[0], title='CPU Usage (%)', legend=False)
\n axes[0].set_ylim(0, 100)<\/p>\n
# \u5185\u5b58\u4f7f\u7528\u7387
\n df.plot(x='timestamp', y='memory', ax=axes[1], title='Memory Usage (%)', legend=False)
\n axes[1].set_ylim(0, 100)<\/p>\n
# \u78c1\u76d8\u4f7f\u7528\u7387
\n df.plot(x='timestamp', y='disk', ax=axes[2], title='Disk Usage (%)', legend=False)
\n axes[2].set_ylim(0, 100)<\/p>\n
plt.tight_layout()
\n plt.show()<\/p>\n
# plot_system_metrics(df)<\/p>\n
def safe_process_info(pid):
\n """\u5b89\u5168\u83b7\u53d6\u8fdb\u7a0b\u4fe1\u606f，\u5904\u7406\u5404\u79cd\u5f02\u5e38"""
\n try:
\n p = psutil.Process(pid)
\n return {
\n 'pid': pid,
\n 'name': p.name(),
\n 'status': p.status(),
\n 'cpu': p.cpu_percent(interval=0.1),
\n 'memory': p.memory_percent(),
\n 'threads': p.num_threads()
\n }
\n except psutil.NoSuchProcess:
\n return {'error': 'Process not found'}
\n except psutil.AccessDenied:
\n return {'error': 'Access denied'}
\n except psutil.ZombieProcess:
\n return {'error': 'Zombie process'}
\n except Exception as e:
\n return {'error': str(e)}<\/p>\n
\u6279\u91cf\u83b7\u53d6\u5c5e\u6027：<\/p>\n
# \u4f4e\u6548\u65b9\u5f0f
\ncpu = p.cpu_percent()
\nmem = p.memory_percent()<\/p>\n
# \u9ad8\u6548\u65b9\u5f0f
\ninfo = p.as_dict(attrs=['cpu_percent', 'memory_percent'])<\/p>\n<\/li>\n
\u51cf\u5c11\u8fdb\u7a0b\u5217\u8868\u626b\u63cf\u9891\u7387：<\/p>\n
# \u7f13\u5b58\u8fdb\u7a0b\u5217\u8868
\ncached_pids = set(psutil.pids())<\/p>\n
# \u5b9a\u671f\u66f4\u65b0\u7f13\u5b58
\nif time.time() – last_update > 60:
\n cached_pids = set(psutil.pids())
\n last_update = time.time()<\/p>\n<\/li>\n
\u4f7f\u7528with\u8bed\u53e5\u7ba1\u7406\u8d44\u6e90：<\/p>\n
with psutil.Process(pid) as p:
\n print(p.name())
\n print(p.status())<\/p>\n<\/li>\n
#!\/usr\/bin\/env python3
\n"""
\n\u670d\u52a1\u5668\u8d44\u6e90\u76d1\u63a7\u811a\u672c
\n\u76d1\u63a7CPU\u3001\u5185\u5b58\u3001\u78c1\u76d8\u3001\u7f51\u7edc\u4f7f\u7528\u60c5\u51b5
\n\u5f53\u8d44\u6e90\u8d85\u8fc7\u9608\u503c\u65f6\u53d1\u9001\u544a\u8b66
\n"""<\/p>\n
import psutil
\nimport time
\nimport smtplib
\nfrom email.mime.text import MIMEText<\/p>\n
# \u914d\u7f6e\u53c2\u6570
\nTHRESHOLDS = {
\n 'cpu': 90, # CPU\u4f7f\u7528\u7387\u9608\u503c(%)
\n 'memory': 90, # \u5185\u5b58\u4f7f\u7528\u7387\u9608\u503c(%)
\n 'disk': 90, # \u78c1\u76d8\u4f7f\u7528\u7387\u9608\u503c(%)
\n}<\/p>\n
ALERT_INTERVAL = 3600 # \u544a\u8b66\u95f4\u9694(\u79d2)
\nMONITOR_INTERVAL = 5 # \u76d1\u63a7\u95f4\u9694(\u79d2)<\/p>\n
# \u90ae\u4ef6\u914d\u7f6e
\nSMTP_SERVER = 'smtp.example.com'
\nSMTP_PORT = 587
\nEMAIL_USER = 'monitor@example.com'
\nEMAIL_PASS = 'password'
\nEMAIL_TO = 'admin@example.com'<\/p>\n
last_alert_time = 0<\/p>\n
def check_thresholds():
\n """\u68c0\u67e5\u5404\u9879\u6307\u6807\u662f\u5426\u8d85\u8fc7\u9608\u503c"""
\n alerts = []<\/p>\n
# CPU\u68c0\u67e5
\n cpu_percent = psutil.cpu_percent(interval=1)
\n if cpu_percent > THRESHOLDS['cpu']:
\n alerts.append(f"CPU\u4f7f\u7528\u7387\u8fc7\u9ad8: {cpu_percent}%")<\/p>\n
# \u5185\u5b58\u68c0\u67e5
\n mem_percent = psutil.virtual_memory().percent
\n if mem_percent > THRESHOLDS['memory']:
\n alerts.append(f"\u5185\u5b58\u4f7f\u7528\u7387\u8fc7\u9ad8: {mem_percent}%")<\/p>\n
# \u78c1\u76d8\u68c0\u67e5
\n disk_percent = psutil.disk_usage('\/').percent
\n if disk_percent > THRESHOLDS['disk']:
\n alerts.append(f"\u78c1\u76d8\u4f7f\u7528\u7387\u8fc7\u9ad8: {disk_percent}%")<\/p>\n
return alerts<\/p>\n
def send_alert(alerts):
\n """\u53d1\u9001\u544a\u8b66\u90ae\u4ef6"""
\n global last_alert_time<\/p>\n
current_time = time.time()
\n if current_time – last_alert_time < ALERT_INTERVAL:
\n return<\/p>\n
subject = "\u670d\u52a1\u5668\u8d44\u6e90\u544a\u8b66"
\n body = "\\\\n".join(alerts)<\/p>\n
msg = MIMEText(body)
\n msg['Subject'] = subject
\n msg['From'] = EMAIL_USER
\n msg['To'] = EMAIL_TO<\/p>\n
try:
\n with smtplib.SMTP(SMTP_SERVER, SMTP_PORT) as server:
\n server.starttls()
\n server.login(EMAIL_USER, EMAIL_PASS)
\n server.send_message(msg)
\n last_alert_time = current_time
\n print(f"\u544a\u8b66\u5df2\u53d1\u9001: {alerts}")
\n except Exception as e:
\n print(f"\u53d1\u9001\u544a\u8b66\u5931\u8d25: {e}")<\/p>\n
def main():
\n """\u4e3b\u76d1\u63a7\u5faa\u73af"""
\n print("\u542f\u52a8\u670d\u52a1\u5668\u76d1\u63a7…")
\n while True:
\n alerts = check_thresholds()
\n if alerts:
\n send_alert(alerts)
\n time.sleep(MONITOR_INTERVAL)<\/p>\n
if __name__ == '__main__':
\n main()<\/p>\n
#!\/usr\/bin\/env python3
\n"""
\n\u81ea\u52a8\u5316\u8fd0\u7ef4\u811a\u672c
\n1. \u76d1\u63a7\u6307\u5b9a\u8fdb\u7a0b，\u5982\u679c\u5d29\u6e83\u5219\u81ea\u52a8\u91cd\u542f
\n2. \u6e05\u7406\u8fc7\u671f\u7684\u65e5\u5fd7\u6587\u4ef6
\n3. \u5b9a\u671f\u5907\u4efd\u91cd\u8981\u6570\u636e
\n"""<\/p>\n
import psutil
\nimport os
\nimport time
\nimport shutil
\nimport subprocess
\nfrom datetime import datetime, timedelta<\/p>\n
# \u914d\u7f6e\u53c2\u6570
\nPROCESS_NAME = "my_service" # \u8981\u76d1\u63a7\u7684\u8fdb\u7a0b\u540d
\nPROCESS_CMD = ["python", "service.py"] # \u8fdb\u7a0b\u542f\u52a8\u547d\u4ee4
\nLOG_DIR = "\/var\/log\/myapp" # \u65e5\u5fd7\u76ee\u5f55
\nBACKUP_DIR = "\/backups" # \u5907\u4efd\u76ee\u5f55
\nDATA_DIR = "\/data" # \u8981\u5907\u4efd\u7684\u6570\u636e\u76ee\u5f55
\nRETENTION_DAYS = 7 # \u65e5\u5fd7\u548c\u5907\u4efd\u4fdd\u7559\u5929\u6570
\nCHECK_INTERVAL = 60 # \u68c0\u67e5\u95f4\u9694(\u79d2)<\/p>\n
def find_process():
\n """\u67e5\u627e\u6307\u5b9a\u8fdb\u7a0b"""
\n for proc in psutil.process_iter(['name', 'cmdline']):
\n try:
\n if proc.info['name'] == PROCESS_NAME or \\\\
\n (proc.info['cmdline'] and proc.info['cmdline'][0] == PROCESS_CMD[0]):
\n return proc
\n except (psutil.NoSuchProcess, psutil.AccessDenied):
\n continue
\n return None<\/p>\n
def start_process():
\n """\u542f\u52a8\u8fdb\u7a0b"""
\n print(f"\u542f\u52a8\u8fdb\u7a0b: {' '.join(PROCESS_CMD)}")
\n subprocess.Popen(PROCESS_CMD)<\/p>\n
def cleanup_files(directory, pattern, days):
\n """\u6e05\u7406\u8fc7\u671f\u6587\u4ef6"""
\n now = datetime.now()
\n cutoff = now – timedelta(days=days)<\/p>\n
for filename in os.listdir(directory):
\n if filename.endswith(pattern):
\n filepath = os.path.join(directory, filename)
\n mtime = datetime.fromtimestamp(os.path.getmtime(filepath))
\n if mtime < cutoff:
\n print(f"\u5220\u9664\u8fc7\u671f\u6587\u4ef6: {filepath}")
\n os.remove(filepath)<\/p>\n
def create_backup():
\n """\u521b\u5efa\u6570\u636e\u5907\u4efd"""
\n timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
\n backup_name = f"backup_{timestamp}.tar.gz"
\n backup_path = os.path.join(BACKUP_DIR, backup_name)<\/p>\n
print(f"\u521b\u5efa\u5907\u4efd: {backup_path}")
\n shutil.make_archive(backup_path.replace('.tar.gz', ''), 'gztar', DATA_DIR)
\n return backup_path<\/p>\n
def main():
\n """\u4e3b\u5faa\u73af"""
\n print("\u542f\u52a8\u81ea\u52a8\u5316\u8fd0\u7ef4\u811a\u672c…")<\/p>\n
while True:
\n # \u68c0\u67e5\u8fdb\u7a0b
\n proc = find_process()
\n if proc is None:
\n print("\u8fdb\u7a0b\u672a\u8fd0\u884c，\u5c1d\u8bd5\u542f\u52a8…")
\n start_process()
\n else:
\n print(f"\u8fdb\u7a0b\u8fd0\u884c\u4e2d，PID: {proc.pid}")<\/p>\n
# \u6e05\u7406\u8fc7\u671f\u65e5\u5fd7
\n print("\u6e05\u7406\u8fc7\u671f\u65e5\u5fd7…")
\n cleanup_files(LOG_DIR, ".log", RETENTION_DAYS)<\/p>\n
# \u521b\u5efa\u5b9a\u671f\u5907\u4efd
\n if datetime.now().hour == 2: # \u6bcf\u5929\u51cc\u66682\u70b9\u5907\u4efd
\n print("\u6267\u884c\u6bcf\u65e5\u5907\u4efd…")
\n create_backup()
\n print("\u6e05\u7406\u8fc7\u671f\u5907\u4efd…")
\n cleanup_files(BACKUP_DIR, ".tar.gz", RETENTION_DAYS)<\/p>\n
time.sleep(CHECK_INTERVAL)<\/p>\n
if __name__ == '__main__':
\n main()<\/p>\n
NoSuchProcess\u9519\u8bef：<\/p>\n
try:
\n p = psutil.Process(pid)
\n print(p.name())
\nexcept psutil.NoSuchProcess:
\n print(f"\u8fdb\u7a0b {pid} \u5df2\u7ec8\u6b62")<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
AccessDenied\u9519\u8bef：<\/p>\n
try:
\n p = psutil.Process(pid)
\n print(p.environ())
\nexcept psutil.AccessDenied:
\n print("\u6743\u9650\u4e0d\u8db3，\u65e0\u6cd5\u8bbf\u95ee\u8fdb\u7a0b\u73af\u5883")<\/p>\n<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n<\/li>\n
ZombieProcess\u9519\u8bef：<\/p>\n
try:
\n p = psutil.Process(pid)
\n if p.status() == psutil.STATUS_ZOMBIE:
\n print("\u8fdb\u7a0b\u5904\u4e8e\u50f5\u5c38\u72b6\u6001")
\nexcept psutil.ZombieProcess:
\n print("\u65e0\u6cd5\u8bbf\u95ee\u50f5\u5c38\u8fdb\u7a0b")<\/p>\n<\/li>\n<\/ul>\n<\/li>\n
\u6027\u80fd\u95ee\u9898：<\/p>\n
\u8bc6\u522b\u9ad8CPU\u8fdb\u7a0b：<\/p>\n
def find_top_cpu_processes(n=5):
\n """\u67e5\u627eCPU\u5360\u7528\u6700\u9ad8\u7684n\u4e2a\u8fdb\u7a0b"""
\n procs = []
\n for p in psutil.process_iter(['pid', 'name', 'cpu_percent']):
\n try:
\n p.info['cpu_percent'] = p.info['cpu_percent'] or 0
\n procs.append(p.info)
\n except (psutil.NoSuchProcess, psutil.AccessDenied):
\n continue<\/p>\n
# \u6309CPU\u4f7f\u7528\u7387\u6392\u5e8f
\n return sorted(procs, key=lambda x: x['cpu_percent'], reverse=True)[:n]<\/p>\n<\/li>\n
\u8bc6\u522b\u5185\u5b58\u6cc4\u6f0f：<\/p>\n
def monitor_memory_leak(pid, interval=60, threshold=10):
\n """\u76d1\u63a7\u5185\u5b58\u6cc4\u6f0f"""
\n baseline = None
\n while True:
\n try:
\n p = psutil.Process(pid)
\n mem = p.memory_info().rss \/ 1024 \/ 1024 # MB<\/p>\n
if baseline is None:
\n baseline = mem
\n print(f"\u521d\u59cb\u5185\u5b58: {baseline:.2f} MB")
\n else:
\n increase = mem – baseline
\n if increase > threshold:
\n print(f"\u8b66\u544a: \u5185\u5b58\u589e\u52a0\u4e86 {increase:.2f} MB (\u5f53\u524d: {mem:.2f} MB)")<\/p>\n
time.sleep(interval)
\n except psutil.NoSuchProcess:
\n print("\u8fdb\u7a0b\u5df2\u7ec8\u6b62")
\n break<\/p>\n<\/li>\n
\u78c1\u76d8IO\u74f6\u9888\u5206\u6790：<\/p>\n
def analyze_disk_io():
\n """\u5206\u6790\u78c1\u76d8IO\u74f6\u9888"""
\n # \u83b7\u53d6\u78c1\u76d8IO\u7edf\u8ba1
\n disk_io = psutil.disk_io_counters()
\n print(f"\u8bfb\u53d6\u6b21\u6570: {disk_io.read_count}")
\n print(f"\u5199\u5165\u6b21\u6570: {disk_io.write_count}")<\/p>\n
# \u67e5\u627e\u9ad8IO\u8fdb\u7a0b
\n high_io_procs = []
\n for p in psutil.process_iter(['pid', 'name', 'io_counters']):
\n try:
\n io = p.info['io_counters']
\n if io and (io.read_bytes > 100*1024*1024 or io.write_bytes > 100*1024*1024): # 100MB
\n high_io_procs.append({
\n 'pid': p.info['pid'],
\n 'name': p.info['name'],
\n 'read': io.read_bytes \/ 1024 \/ 1024,
\n 'write': io.write_bytes \/ 1024 \/ 1024
\n })
\n except (psutil.NoSuchProcess, psutil.AccessDenied):
\n continue<\/p>\n
return high_io_procs<\/p>\n<\/li>\n
psutil\u4f5c\u4e3aPython\u7cfb\u7edf\u76d1\u63a7\u7684\u6807\u51c6\u5e93，\u5177\u6709\u4ee5\u4e0b\u663e\u8457\u4f18\u52bf：<\/p>\n
psutil\u975e\u5e38\u9002\u5408\u4ee5\u4e0b\u573a\u666f：<\/p>\n
psutil\u9879\u76ee\u6301\u7eed\u6d3b\u8dc3\u53d1\u5c55，\u672a\u6765\u53ef\u80fd\u7684\u65b9\u5411\u5305\u62ec：<\/p>\n
psutil\u62e5\u6709\u4e00\u4e2a\u6d3b\u8dc3\u7684\u5f00\u6e90\u793e\u533a，\u7528\u6237\u53ef\u4ee5\u901a\u8fc7\u4ee5\u4e0b\u65b9\u5f0f\u83b7\u53d6\u652f\u6301\u548c\u53c2\u4e0e\u8d21\u732e：<\/p>\n
\u901a\u8fc7psutil，Python\u5f00\u53d1\u8005\u53ef\u4ee5\u8f7b\u677e\u6784\u5efa\u5f3a\u5927\u7684\u7cfb\u7edf\u76d1\u63a7\u548c\u7ba1\u7406\u5de5\u5177，\u6781\u5927\u5730\u7b80\u5316\u4e86\u4e0e\u7cfb\u7edf\u8d44\u6e90\u4ea4\u4e92\u7684\u590d\u6742\u6027，\u662f\u6bcf\u4e2a\u7cfb\u7edf\u7ba1\u7406\u5458\u548cDevOps\u5de5\u7a0b\u5e08\u5de5\u5177\u7bb1\u4e2d\u4e0d\u53ef\u6216\u7f3a\u7684\u5229\u5668\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb661\u6b21\uff0c\u70b9\u8d5e30\u6b21\uff0c\u6536\u85cf7\u6b21\u3002psutil\u662f\u4e00\u4e2a\u5f3a\u5927\u7684\u8de8\u5e73\u53f0Python\u5e93\uff0c\u7528\u4e8e\u76d1\u63a7\u7cfb\u7edf\u8d44\u6e90\u548c\u8fdb\u7a0b\u7ba1\u7406\u3002\u5b83\u652f\u6301\u83b7\u53d6CPU\u3001\u5185\u5b58\u3001\u78c1\u76d8\u3001\u7f51\u7edc\u7b49\u7cfb\u7edf\u4fe1\u606f\uff0c\u5e76\u80fd\u8fdb\u884c\u8be6\u7ec6\u7684\u8fdb\u7a0b\u63a7\u5236\u3002psutil\u7684\u4e3b\u8981\u4f18\u52bf\u5305\u62ec\u7edf\u4e00\u7684\u8de8\u5e73\u53f0API\u3001\u5168\u9762\u7684\u76d1\u63a7\u529f\u80fd\u3001\u9ad8\u6548\u6027\u80fd\u548c\u6d3b\u8dc3\u7684\u793e\u533a\u652f\u6301\u3002\u8be5\u5e93\u9002\u7528\u4e8e\u670d\u52a1\u5668\u76d1\u63a7\u3001\u81ea\u52a8\u5316\u8fd0\u7ef4\u3001\u6027\u80fd\u5206\u6790\u7b49\u573a\u666f\uff0c\u53ef\u901a\u8fc7pip\u8f7b\u677e\u5b89\u88c5\u3002\u6587\u7ae0\u8be6\u7ec6\u4ecb\u7ecd\u4e86psutil\u7684\u6838\u5fc3\u529f\u80fd\u3001\u9ad8\u7ea7\u5e94\u7528\u6280\u5de7\u3001\u5e38\u89c1\u95ee\u9898\u89e3\u51b3\u65b9\u6848\uff0c\u5e76\u63d0\u4f9b\u4e86\u670d\u52a1\u5668\u76d1\u63a7\u811a\u672c\u548c\u81ea\u52a8\u5316\u8fd0\u7ef4\u4efb\u52a1\u7b49\u5b9e\u7528\u6848\u4f8b\uff0c\u662fPython\u5f00\u53d1\u8005\u8fdb\u884c\u7cfb\u7edf\u76d1\u63a7\u7684\u7406\u60f3\u5de5\u5177\u3002<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[81],"topic":[],"class_list":["post-49227","post","type-post","status-publish","format-standard","hentry","category-server","tag-python"],"yoast_head":"\n