如何动态地向Celery（celerybeat）添加/删除周期性任务
如果我有一个定义如下的函数：def add(x,y): return x+y 有没有一种方法可以在运行时将此函数作为celery周期性任务动态添加并启动它？我希望能够像这样做（伪代码）：some_unique_task_id = celery.beat.schedule_task(add,...
构建Docker镜像时出现错误：level=error msg="无法关闭tar写入器：管道已关闭的读/写操作"
time="2017-10-27T07:39:20Z" level=error msg="Can't add file /var/app/current/app/content_classifier/forest.pickle to tar: io: read/write on closed ...
禁用Celerybeat的PID文件
celeryd不需要pidfile，但是celerybeat似乎需要。有没有办法禁用它？我正在使用Upstart来管理进程，因此使用pidfile是多余的。
在Celery 3.1中，如何创建Django的定期任务？
Django发生了太多变化，所以我不能使用3.1版本。我需要一些帮助。 我阅读了在Django中创建任务，并阅读了定期任务文档。但是我不知道如何在Django中创建定期任务。我认为这是因为我的英语水平较低... 在旧版Celery中，我导入了djcelery和crontab，在setti...
Celery如何停止一个任务链的执行
我有一个定期执行的check_orders任务。它会创建一组任务，以便我可以计时执行任务所需的时间，并在所有任务完成后执行某些操作（这是res.join [1]和grouped_subs的目的）。被分组的任务是成对的链接任务。 我的要求是，当第一个任务不满足条件（失败）时，不要执行链中的第二...
在Django中连接新的Celery定期任务
这不是一个问题，而是帮助那些发现在Django中集成celery 4.0.1文档中描述的定期任务声明很困难的人： http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html#entries 复制粘贴celery配...
在同一个容器中运行celery worker和beat
我的Flask应用由四个容器组成：Web应用程序、PostgreSQL、RabbitMQ和Celery。因为我有定期运行的Celery任务，所以我正在使用Celery Beat。我已经像这样配置了我的docker-compose文件：version: '2' services: rabbi...
检查 Celery Beat 是否正在运行
在我的Django项目中，我使用Celery和Rabbitmq在后台运行任务。 我使用celery beat调度程序来运行周期性任务。 如何以编程方式检查celery beat是否正在运行？
Celery：在特定时间间隔后执行任务
我希望在用户注册后精确48小时发送电子邮件。如何使用celery实现？如果我创建一个定期任务来发送电子邮件，我将不得不决定执行该任务的特定时间段。我不想每秒运行celery任务来检查是否需要发送电子邮件。
Celery beat没有执行定期任务
我正在尝试使用celery，但是我的任务无法运行。我已经安装了django-celery-beat和celery4。 我的设置文件。 已安装的应用程序（带有celery包） ... 'django_celery_beat', 'django_celery_results' Cele...