Django-celery为Django提供Celery集成。
使用Amazon SQS的芹菜,消息在“消息Avaliable”
我对芹菜有问题。我正在使用Amazon SQS芹菜。我设置了有关芹菜和SQS的所有内容。 tasks.py中的函数毫无延迟()可以使用(),但不使用delay()。 我成功...
django/celery - celery 状态:错误:没有节点在时间限制内回复
我正在尝试在我的生产服务器中部署一个简单的 celery 示例,我已按照 celery 网站中有关将 celery 作为守护进程运行的教程进行操作:http://docs.celeryproject.org/en/latest/tuto。 ..
Celery - “WorkerLostError:工作人员过早退出:信号 11 (SIGSEGV)”
我正在本地开发一个 Django 应用程序,需要将 CSV 文件作为输入并对文件运行一些分析。 我在本地运行 Celery、RabbitMQ 和 Web 服务器。 当我导入文件时,我看到...
我遇到此错误 Rediss:// URL 必须具有参数 ssl_cert_reqs 并且必须将其设置为 CERT_REQUIRED、CERT_OPTIONAL 或 CERT_NONE 设置 CELERY_BROKER_URL = os.environ.get('REDIS_URL', "...
DJANGO_CELERY_BEAT从shared_task访问PeriodicTask
在我的项目中,我使用django celerybeat包来执行计划任务。它运作良好,但我有一个无法处理的情况。 所有任务都有一个PeriodicTack 来安排它们。 所以接下来...
我们使用 django、rabbitmq、celery 和 ffmpeg 的组合来读取相机流并将其分解为图像以存储到文件系统中。此设置可 24x7 运行。现在,对于每个摄像机流...
我有一个邮政模型。有一个字段publish_date。如果帖子具有计划状态,那么我需要在publish_date上执行发布功能。我该怎么做? 模型.py: 班级帖子(mo...
我正在构建一个将任务注册到 Celery 的 API,我想根据任务结果实现一个条件工作流程。具体来说,如果任务 A 返回证书,我需要执行任务 B...
Django Celery socket.error [Errno 61] 连接被拒绝
我正在运行 Redis、Celery 4.0 和 Django 1.10,但在从 shell 运行任务“test”时收到 [Errrno 61] 连接拒绝错误。这是我的项目结构: 我的项目 │ ├── 应用程序1 ├── __init...
在我的应用程序中,我想在创建对象后的一定时间间隔后运行某个函数。 django-celery-beat 是执行此操作的正确工具吗?
我正在尝试执行一项并行处理多个订单的任务。我用了一个和弦,给前端发了一个和弦id,定期检查任务进度,但是我发的id是ac...
当管理员发布从 Django 管理员创建的博客文章时,我使用 Django 信号触发任务(使用 django celery 包向订阅者发送大量电子邮件)。但信号没有触发...
我在 Heroku 上使用 Django 和 celery 以及 Redis。 我有两个队列,称为“celery”和“letters” 我在 Heroku 上有两种工作类型 工作人员(具有大量 RAM 的 Dyno)。它可以从两个队列运行任务...
billiard.exceptions.WorkerLostError:Worker 过早退出:没有 Docker 的信号 9 (SIGKILL)
[2021-10-27 02:05:09,365:错误/MainProcess]进程“ForkPoolWorker-5”pid:12871退出并显示“信号9(SIGKILL)” [2021-10-27 02:05:09,412:错误/MainProcess] 任务处理程序引发错误:WorkerLost...
无法让 Redis 在 Windows 上与 Django 一起使用
我正在开发一个 Django Channels 项目,需要 Redis 作为通道层。然而,我发现 Windows 本身不支持 Redis,因为它主要是为 Linux 设计的
我正在尝试在 Celery 中设置一个每 3 秒运行一次的虚拟任务,但到目前为止收效甚微。这是我得到的输出: 我已按如下方式设置芹菜: 在设置.py中: 从数据来看...
django-celery:bind=True 失败,需要 2 个位置参数,但给出了 3 个
如果失败,我正在尝试重试芹菜任务。这是我的任务, @shared_task(queue='es',bind=True,max_retries=3) def update_station_es_index(doc_id, doc_body): ”“” 芹菜食用方法...
如何在 Celery 中仅在组中的最后一个工作进程上运行 on_success?
我已经为此挠头好几天了。我有一个后台运行任务,大约需要 1 小时。我正在处理 5000 张图像。我创建了一组 celery 任务和每个任务
我已经使用它们的守护进程指令设置了 celery 来与我的 django 应用程序一起使用(http://docs.celeryproject.org/en/latest/tutorials/daemonizing.html#daemonizing) 这是我的测试任务...