Python Celery 将结果异步保存在数据库中
我使用 Python 与 Celery 和 RabbitMQ 来制作一个网络蜘蛛来计算页面上的链接数量。 MySQL等数据库可以异步写入吗？是否可以在添加每一行后提交更改，…
Celery 在重试任务时抛出 IOError
当我尝试重试失败的任务时，我会间歇性地（大约 20% 的时间）从 Celery 收到 IOError 异常。 这是我的任务： @task def update_data(pk_id): try: pk …
如何使 celery 任务从任务内部失败？
在某些情况下，我想让芹菜任务从该任务中失败。我尝试了以下操作： from celery.task import task from celery import states @task() def run_simula…
Celery 中的rate_limit 是如何执行的？
我正在运行一个 Django 网站，在其中使用 Celery 来实现预防性缓存 - 也就是说，我什至在用户请求结果之前就计算并缓存结果。 然而，在某些情况下，我…
celery 获取任务数
我正在使用 python celery+rabbitmq。我找不到一种方法来获取某个队列中的任务计数。 像这样的事情： celery.queue('myqueue').count() 是否可以从某…
Celery-Django：无法异步执行任务
我试图在用户浏览我的网站时在后台运行一些任务，但每当我使用 Celery 调用函数时，它似乎是同步执行的，而不是异步执行的。 例如，当我调用 function…
使用 django celery 并行化任务
我想加快我的 django 视图处理速度，在视图中我必须进行多次 Web 服务调用（在我的例子中是 facebook graph api），这确实需要相当长的时间来处理（仅…
Django/Celery：除非重新启动，否则 celeryd 不会从队列中检索新任务
我不明白为什么 celeryd 没有拉取添加到队列中的新任务。它只会在启动后检索任务，然后无法监视。我正在使用 Django ORM 作为消息代理，通过 django-c…
Celery 任务不会被撤销
我正在通过 django 的 celery （版本 2.3.2）将多个模拟作为任务运行。模拟由另一个任务设置： 在views.py中： result = setup_simulations.delay(par…
Django - Celery：@transaction 和 @task 不叠加
我想运行带有手动事务管理的 Django - Celery 任务，但注释似乎不堆叠。 例如 def ping(): print 'ping' pong.delay('arg') @task(ignore_result=True…
