我可以在 Django 中运行后台进程而不启动并行进程吗?

Phi*_*ski 3 python django parallel-processing celery

这是一个非常幼稚的问题,但我觉得我不了解有关 django 和 python 中异步/后台任务的一些基本知识。

我尝试复制 django-background-tasks ( https://github.com/collinmutembei/django-background-tasks-example )提供的一个简单示例,以使 django 在实际运行 60 秒后执行后台任务. 但我想这同样适用于任何其他后台任务管理器,例如 Celery 或 Huey

这个例子非常简单——一旦用户访问了 url,一个简单的打印消息的函数就会被执行而不会阻塞主 django 进程,60 秒后

  from background_task import background
  from logging import getLogger

  logger = getLogger(__name__)

  @background(schedule=60)
  def demo_task(message):
      logger.debug('demo_task. message={0}'.format(message))
Run Code Online (Sandbox Code Playgroud)

问题是我真的不了解基础知识。除非我启动一个单独的(或分离的)进程,否则它不会运行python manage.py process_tasks。我应该总是这样做以使后台任务工作,还是有一种方法可以在不启动并行进程的情况下做到这一点?

如果我应该启动一个并行进程,我可以从 django 代码内部进行吗?就像是:

    import subprocess

    process = subprocess.Popen(['python', 'manage.py','process_tasks'], stdout=subprocess.PIPE, stderr=subprocess.PIPE)
Run Code Online (Sandbox Code Playgroud)

aas*_*ash 6

运行一个单独的进程来在后台运行任务不是必需的,但很好而且很有帮助。

当您运行服务器时,会创建一个进程 - 运行ps aux | grep runserver- 负责为 Web 请求提供服务。当你说你想在后台运行某些任务时,它隐含地意味着你想要一个单独的进程来执行这些任务。这就是像 celery 这样的异步任务工具的用武之地。

您也可以自己生成一个单独的进程 - 正如您所说 - 通过执行以下操作:

import subprocess

process = subprocess.Popen(['python', 'manage.py','process_tasks'], stdout=subprocess.PIPE, stderr=subprocess.PIPE
Run Code Online (Sandbox Code Playgroud)

如果您只想并行运行一两个小任务,此方法也完全没问题。但是,当您在后台运行大量复杂的任务时,您会希望正确管理它们。此外,如果出现问题,您需要能够调试这些任务。稍后,您将需要更多地了解所有后台任务中发生的事情、它们的状态等。这就是 celery 可以帮助您的地方。它将为您提供装饰方法,这些方法将为您处理所有这些事情。然后你只需要担心你的业务逻辑