Django 和 Celery 的示例:定期任务
我已经与 Django/Celery 文档作斗争一段时间了,需要一些帮助。 我希望能够使用 django-celery 运行定期任务。我在互联网(和文档)上看到了几种不同…
Django-celery 弃用错误?
我刚刚启动 django-celery 并收到此警告: DeprecationWarning: The `celery.decorators` module and the magic keyword arguments are pending depre…
对使用 Celery 感兴趣的相对较新的程序员,这是正确的方法吗
本质上,我有一个大型交易数据库,我正在编写一个脚本,该脚本将获取一些个人信息并将一个人与他们过去的所有交易相匹配。 因此,我为脚本提供一个名…
Tornado celery 集成黑客
由于没有人为这篇文章提供解决方案,加上我迫切需要一种解决方法,这是我的情况和一些抽象的解决方案/辩论想法。 我的堆栈: Tornado Celery MongoDB …
如何使用 celery 和 django 来运行rabbitmq队列中已有的任务?
至此我已经阅读了大部分rabbitmq文档和celery文档,并且google了很多遍。基本上我无法在任何地方找到我需要的信息。 我有一个扭曲的网络服务器读取传…
停止/清除 Django-Celery 中的定期任务
我已经通过子类化PeriodicTask 设法让定期任务在django-celery 中工作。我尝试创建一个测试任务并将其设置为执行一些无用的操作。有用。 现在我无法阻…
通知 celery 任务worker 关闭
我使用 celery 2.4.1 和 python 2.6、rabbitmq 后端和 django。我希望如果工作人员关闭,我的任务能够正确清理。据我所知,您无法提供任务析构函数,…
Python 线程:“sys._current_frames()”与“threading.enumerate()”相比
我有一个程序可以分叉许多子进程(为此,它使用了 Celery Workers)。我正在尝试转储每个进程中所有正在运行的线程的堆栈跟踪。我使用 sys._current_f…
使用 Celery 作为 Twisted 应用程序的控制通道
我正在尝试使用 Celery 作为 Twisted 应用程序的控制通道。我的 Twisted 应用程序是一个抽象层,为各种本地运行的进程(通过 ProcessProtocol)提供标…
Django - 通过模型中的 celery 执行任务
在我的 models.py 中: from django.db import models from core import tasks class Image(models.Model): image = models.ImageField(upload_to='im…
Windows 下使用 django/celery 时出现 WorkerLostError、Python.exe APPCRASH
我在 Windows(Win2008 Server R2、IIS 7.5、MS SQL)下设置了 Django。我正在尝试实现 celery 2.4.1(使用 RabbitMQ)来进行任务处理,但遇到了一个…
芹菜与亚马逊 SQS
我想使用 Amazon SQS 作为 芹菜。 Celery 依赖于 Kombu 的 SQS 传输实现。但是没有足够的文档来使用它,所以我找不到如何在 Celery 上配置 SQS。有人…
让可重用任务在具有一台 celery 服务器和 3k+ 的设置中工作django 站点,每个站点都有自己的数据库
问题是:我有一台 celery 服务器和 3k+ django 站点,每个站点都有自己的数据库。可以动态添加新站点(和数据库)。 我正在编写需要通过公共 celery …