python

关注公众号 jb51net

关闭
首页 > 脚本专栏 > python > Django调用外部Python程序

Django调用外部Python程序的完整项目实战

作者:飞Link

Django是一个强大的Python Web框架,它的设计理念简洁优雅,这篇文章主要介绍了Django调用外部Python程序的完整项目实战,文中通过代码介绍的非常详细,需要的朋友可以参考下

一、为什么 Django 需要调用外部 Python 程序

Django 是 Web 框架,但它经常需要与外部脚本互动,例如:

你的 AIOps 场景就是典型需求:
点击前端按钮 → 启动 CPU 压力脚本 → 持续采集数据

二、三种常见的调用方式

方式 1:直接 import 调用(轻量级)

写一个外部脚本:

# scripts/calc.py
def calc():
    return 1 + 1

Django 中调用:

from scripts.calc import calc

def index(request):
    result = calc()
    return HttpResponse(result)

这种方式最简单,但缺点也明显:

不能用于启动长期运行的脚本(比如你的压力脚本),因为会阻塞 Django。

方式 2:subprocess 启动外部进程(最常用)

适用于:

示例:

import subprocess

def run_script():
    subprocess.Popen(["python", "scripts/load_cpu.py"])

它会启动一个完全独立的 Python 进程,不会阻塞 Django。

方式 3:Django 异步任务(高级版)

使用 Celery、Django-Q、Huey 等任务队列:

大型公司一般采用这种方式。但对入门来说略复杂。

三、完整项目实战:用 Django 按钮启动 CPU 负载脚本

假设你想用 Django 前端按钮启动下面这个脚本负载 CPU:

# scripts/cpu_stress.py
import time

def stress():
    while True:
        x = 0
        for i in range(10_000_000):
            x += i  # 消耗 CPU
        time.sleep(0.1)

不要让 Django import 运行,而是让它跑在独立进程:

Step 1:将脚本放入项目目录

project/
  scripts/
      cpu_stress.py
  app/
      views.py

Step 2:创建启动脚本的 view

# app/views.py
import subprocess
from django.http import JsonResponse
import os, sys

PROCESS = None

def start_stress(request):
    global PROCESS
    if PROCESS and PROCESS.poll() is None:
        return JsonResponse({"msg": "已在运行中"})

    script = os.path.join(os.getcwd(), "scripts", "cpu_stress.py")
    PROCESS = subprocess.Popen([sys.executable, script])

    return JsonResponse({"msg": "启动成功"})


def stop_stress(request):
    global PROCESS
    if PROCESS:
        PROCESS.terminate()
        PROCESS = None
        return JsonResponse({"msg": "已停止"})
    return JsonResponse({"msg": "没有正在运行的任务"})

Step 3:前端按钮示例

<button onclick="fetch('/start_stress').then(r=>r.json()).then(alert)">启动负载</button>
<button onclick="fetch('/stop_stress').then(r=>r.json()).then(alert)">停止负载</button>

前端只需发起请求,Django 随即启动或终止压力脚本。

四、常见错误示例与调试技巧

错误 1:使用 import 直接运行死循环

错误写法:

from scripts.cpu_stress import stress

def start(request):
    stress()  # ❌ 会把 Django 线程卡死

原因:

压力脚本死循环 → Django 视图无法返回 → 网站挂掉。

错误 2:subprocess 没写绝对路径

错误写法:

subprocess.Popen(["python", "cpu_stress.py"])  # ❌ 找不到脚本

正确写法:

script = os.path.join(os.getcwd(), "scripts", "cpu_stress.py")
subprocess.Popen([sys.executable, script])

错误 3:Windows 进程无法 terminate

在 Windows 上,某些子进程会继续挂着,可以改为:

PROCESS.kill()

调试技巧:查看子进程是否启动

Linux / WSL:

ps aux | grep cpu_stress

Windows:

tasklist | findstr python

这类调试技巧在 AIOps 项目中非常常用。

五、生产环境高级技巧

1. 使用日志记录子进程输出

subprocess.Popen(
    [sys.executable, script],
    stdout=open("out.log", "w"),
    stderr=open("err.log", "w")
)

方便你排查模型脚本/压力脚本的问题。

2. 给脚本加锁,避免重复启动

if PROCESS and PROCESS.poll() is None:
    # 已经在运行中

防止用户疯狂点击按钮导致重复启动多个压力脚本。

3. 使用 Redis / 数据库存储子进程 PID

生产环境推荐:

4. 避免 SQLite 作为生产数据库

你的前端压力脚本会导致 SQLite 锁表问题。
生产中建议使用:

SQLite 不适合频繁写入+多进程并发。

六、背后原理与机制拓展

Django 本身不能跑长任务

Django 是典型的:

所以它天生不适合:

这类任务应该由:

来完成。

为什么 subprocess 是最常用方案?

因为:

它是 AIOps 平台后台运行脚本的最基础工具。

总结

文章介绍了 Django 调用外部 Python 脚本的三种方法,并通过完整的项目案例展示如何用 Django 前端按钮启动与停止 CPU 压力脚本,同时补充了常见错误、调试技巧、高级实践和背后原理。

到此这篇关于Django调用外部Python程序的文章就介绍到这了,更多相关Django调用外部Python程序内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文