我正在编写一个允许用户在文件中上传数据的应用程序；该应用程序将处理这些数据，并将结果通过电子邮件发送给用户。处理可能需要一些时间，所以我想在 Python 脚本中单独处理，而不是在视图中等待它完成。 Python 脚本和视图不需要通信，因为脚本将从视图写入的文件中获取数据。该视图只会显示一条消息，例如“感谢上传您的数据 - 结果将通过电子邮件发送给您”
在 Django 中最好的方法是什么？产生一个单独的进程？把东西放在队列上？
我们将不胜感激一些示例代码。谢谢。
【问题讨论】：
最简单的解决方案是编写一个自定义的commands，它会搜索所有未处理的文件，对其进行处理，然后通过电子邮件发送给用户。管理命令在 Django 框架内运行，因此它们可以访问所有模型、数据库连接等，但您可以从任何地方调用它们，例如 crontab。
如果您关心文件上传和处理开始之间的时间范围，您可以使用像 Celery 这样的框架，它基本上是一个帮助库，用于使用消息队列和运行在队列上监听的工作人员。这将是相当低的延迟，但另一方面，简单性对您来说可能更重要。
我强烈建议不要在您的视图中启动线程或生成进程，因为线程将在 django 进程中运行并且可能会破坏您的网络服务器（取决于您的配置）。子进程将继承 Django 进程的所有内容，这可能是您不想要的。最好把这些东西分开。
【讨论】：
我目前有一个要求类似的项目（只是更复杂^^）。
永远不要从您的 Django 视图中生成子进程或线程。您无法控制 Django 进程，它可能会在任务结束之前被杀死、暂停等。它由网络服务器控制（例如通过 WSGI 的 apache）。
我要做的是一个外部脚本，它将在一个单独的进程中运行。我认为您有两种解决方案：
现在您可能需要访问 Django 模型中的信息以最终向用户发送电子邮件。这里有几个解决方案：
我会使用外部进程并导入模块或 POST 请求。这种方式更加灵活。例如，您可以使用 multiprocessing 模块同时处理多个文件（从而有效地使用多核机器）。
一个基本的工作流程是：
我的项目包含真正需要 CPU 的处理。我目前使用一个外部进程，它将处理作业提供给一个工作进程池（这基本上是 Celery 可以为你做的），并通过 POST 请求将进度和结果报告给 Django 应用程序。它工作得非常好并且相对可扩展，但我很快会将它更改为在集群上使用 Celery。
【讨论】：
您可以生成 thread 来进行处理。它与 Django 并没有太大关系。视图函数需要启动工作线程，仅此而已。
如果你真的想要一个单独的进程，你需要subprocess 模块。但是您真的需要重定向标准 I/O 或允许外部进程控制吗？
例子：
from threading import Thread
from MySlowThing import SlowProcessingFunction # or whatever you call it
# ...
Thread(target=SlowProcessingFunction, args=(), kwargs={}).start()
我还没有完成一个不想跟踪线程进度的程序，所以如果不将Thread 对象存储在某处，我不知道这是否可行。如果你需要这样做，这很简单：
allThreads = []
# ...
global allThreads
thread = Thread(target=SlowProcessingFunction, args=(), kwargs={})
thread.start()
allThreads.append(thread)
当thread.is_alive() 返回False 时，您可以从列表中删除线程：
def cull_threads():
global allThreads
allThreads = [thread for thread in allThreads if thread.is_alive()]
【讨论】：
您可以使用多处理。 http://docs.python.org/library/multiprocessing.html
基本上，
def _pony_express(objs, action, user, foo=None):
# unleash the beasts
def bulk_action(request, t):
...
objs = model.objects.filter(pk__in=pks)
if request.method == 'POST':
objs.update(is_processing=True)
from multiprocessing import Process
p = Process(target=_pony_express, args=(objs, action, request.user), kwargs={'foo': foo})
p.start()
return HttpResponseRedirect(next_url)
context = {'t': t, 'action': action, 'objs': objs, 'model': model}
return render_to_response(...)
【讨论】：