在生产中运行 Django-Celery
我构建了一个 Django Web 应用程序和一些 Django-Piston 服务。用户使用 Web 界面提交一些数据,这些数据被 POST 到 Web 服务,而该 Web 服务又使用 D…
Django Celery 实现 - OSError:[Errno 38] 函数未实现
我安装了 django-celery 并尝试启动工作服务器,但收到一个 OSError 消息,表明函数未实现。我在 VPS 上运行 CentOS 版本 5.4(最终版): . broker -…
Celery - 获取当前任务的任务ID
如何从任务中获取任务的 task_id 值?这是我的代码: from celery.decorators import task from django.core.cache import cache @task def do_job(pa…
celery-django 找不到设置
我有一个 Django 项目,它使用 Celery 来运行异步任务。我正在 Windows XP 计算机上进行开发。 启动我的 Django 服务器 (python manage.py runserver …
运行 celeryd 时出错
我发布这个问题(和答案),这样如果其他人将来遇到这个问题,你就可以用谷歌搜索它。 如果您尝试在 Django 中运行 celeryd,如下所示: python manag…
Celery 中的PeriodicTask run() 方法拥有自己的参数
我正在编写一个小型 Django 应用程序,我应该能够创建 对于每个模型对象,其定期任务将被执行 一定的间隔。我使用 Celery 应用程序,但我无法理解一件…
如何布局队列/工作人员结构以支持多个环境的大型任务?
对于基于 Python/Django/Celery 的部署工具,我们有以下设置: 我们当前使用默认的 Celery 设置。 (一个队列+交换称为“celery”。) 队列上的每个任…
Django 中所有 Celery 工作线程/内存缓存的全局可访问对象
我有相当标准的 Django+Rabbitmq+Celery 设置,有 1 个 Celery 任务和 5 个工作人员。 任务将相同(我简化了一点)大文件(~100MB)异步上传到许多远…
异步消息队列和处理,如 django 中的 Amazon Simple Queue 服务
应用程序上有许多活动需要执行以下操作: 发布到 twitter 发送电子邮件、将图像 缩略图、分成多种大小调用 cron 来查找连接关系 完成这些任务的一个好…
Rabbitmq 或 Gearman - 选择作业队列
在工作中,我们需要构建一个作业服务器,用于发送电子邮件、构建 PDF、处理一些数据等。显然,我们希望构建某种通用排队系统。我对 Gearman 很熟悉,…
celery 是否可以在启动时自动运行?
我有基于 django 和 celery 的 python 服务器。 每次计算机重新启动时,apache2 都会启动,因此我的服务器正在工作,但我必须手动重新启动 celery(转…
RabbitMQ / Celery with Django 在延迟/就绪/等情况下挂起 - 没有有用的日志信息
所以我只是设置了celery和rabbitmq,创建了我的用户,设置了虚拟主机,将用户映射到虚拟主机,并成功运行了celery守护进程(或者我假设) (queuetest)…
如何设置 Celery 在运行任务之前调用自定义初始化函数?
我有一个 Django 项目,我正在尝试使用 Celery 提交任务进行后台处理( http:// /ask.github.com/celery/introduction.html )。 Celery 与 Django 集…