我在 Django 项目中将 Carrot 用于消息队列并按照教程进行操作,并且效果很好。但是该示例在控制台中运行,我想知道如何在 Django 中应用它。我从models.py 中的一个模型调用的发布者类,所以没关系。但我不知道把消费类放在哪里。
由于它只是与 .wait() 一起坐在那里,我不知道在什么时候或在哪里需要实例化它,以便它始终运行并侦听消息!
谢谢!
在您从教程中引用的示例中,使用者只是一个长时间运行的脚本。它从队列中弹出一条消息,执行某些操作,然后调用 wait 并基本上进入睡眠状态,直到另一条消息进来。
该脚本可以在您的帐户下的控制台上运行,也可以配置为 unix 守护程序或 win32 服务。在生产中,您需要确保如果它死了,它可以重新启动,等等(守护进程或服务在这里更合适)。
或者您可以取出等待调用并在 Windows 调度程序下运行它或作为 cron 作业运行。因此它每 n 分钟或某事处理一次队列并退出。这实际上取决于您的应用程序要求,队列填满的速度等。
这有意义还是我完全错过了你的要求?
如果你正在做的是处理任务,请查看 celery:http: //github.com/ask/celery/