celery 相关问题

Celery是Python的分布式任务队列框架,用于异步和并行执行。

Celery worker 在做本地开发时不同步

目前我有一个聊天机器人托管在 heroku 上,它使用 Redis+Celery+RabbitMQ。过去几天,当我决定在本地开发芹菜终端时,我注意到一个问题: [2023-04-13...

回答 0 投票 0

Celery 没有向 Docker Redis 发送任务消息,任务停留在“已接收”状态

目标 我正在尝试在 python/flask 中处理语音到文本的转录。我正在使用 Celery 包来执行异步任务,使用 Redis(在 docker 上)实例作为代理。我

回答 1 投票 0

暂停芹菜任务

我正在尝试根据用户按钮单击临时暂停 celery 任务。 我所做的是: 当用户点击按钮时;我发布了一个 AJAX 请求,将我的芹菜任务状态更新为“暂停” 的...

回答 2 投票 0

使用 Celery 的 AWS Redis 集群的正确方法

我在 AWS 中有一个 Redis 集群,我正在尝试将该 Redis 用作 Celery 的代理。 我的错误是: ValueError:无法导入'':无法将端口转换为...

回答 0 投票 0

如何将芹菜应用程序部署到谷歌云?

谷歌云迫切希望你使用 Cloud Tasks 进行分布式任务处理。这是一个非首发。它们无法提供在本地可靠地模拟任务执行的方法,因此违反了核心

回答 0 投票 0

在系统级别控制每个任务队列的并发性

问题 我想在系统级别(跨所有 celery worker)控制队列“foo”的最大并发性。我使用 Redis 作为代理,我所有的工人(包括 bea...

回答 0 投票 0

如何使用celery和dajngo发送带图片附件的邮件?

我想使用芹菜发送带有照片的电子邮件,但我收到“字节类型的对象不是 JSON 可序列化”错误。我只是不明白如何正确地做到这一点。至于...

回答 0 投票 0

Python Celery 获取任务状态

拥有此代码并使用 RabbitMQ 设置 Celery 任务被创建和执行。我得到任务 uuid,但不知何故无法检查任务状态 从 flask_oidc 导入 OpenIDConnect 从烧瓶导入烧瓶,js ...

回答 1 投票 0

在芹菜中获取任务状态

我需要在 celery 中获取任务状态,但由于某种原因我总是只能获得“PENDING”和“SUCCESS”状态,但是如果我通过 flower 查看,我还可以看到 &q...

回答 1 投票 0

amqp 被添加到 celery broker url

使用 redis://redis:6379/0 指定 broker_url 被覆盖为 amqp://guest:**@redis%2F%2Fredis%3A6379%2F0:5672/ 日志 无法连接到 amqp://guest:**@redis%2F%2Fredis%3A6379%2F0:5672//: [

回答 0 投票 0

无法在 ec2 上运行 selenium 驱动程序

我通过使用 chromedriver 的解析器收集评论,我在服务器上的 celery 任务中运行解析,我遇到了以下错误 (进程从chrome location /home/ubuntu/.../

回答 0 投票 0

芹菜,ModuleNotFoundError

命令'celery -A store worker -l INFO'(store是项目名称)后, 我有错误 ModuleNotFoundError: No module named 'proj.settings' ---------------------------------------------- -----...

回答 0 投票 0

Django:单击按钮时启动芹菜工人

我有一个将 PCAP 文件放入解析函数的按钮。单击“上传文件”按钮时,它会调用我的 form_upload 视图,我希望我的 celery 任务开始运行,以便显示...

回答 0 投票 0

将 celery 任务的结果链接到分布式组中

就像另一个问题一样,我想从 celery 任务返回的列表中创建一个 celery 组。这个想法是第一个任务将返回一个列表,第二个任务将爆炸...

回答 3 投票 0

Celery + Django - ModuleNotFoundError: No module named 'celery.backends.amqp'

我不知道为什么会出现此错误。我的“requirements.txt”文件包括: amqp==5.1.1 芹菜==5.2.7 我在这里遵循标准配置:任何想法可能是错误的?

回答 1 投票 0

如何让 celery 在完成单个任务后关闭而不返回队列?

我在 celery 中有一个任务只能运行一次,因为它每次运行时都需要从不同的文件夹导入我的模块和子模块的新副本。芹菜不能很好地处理这个,它...

回答 1 投票 0

如何在芹菜中禁用重试?

我每 15 分钟运行一次 celerybeat 调度程序,我需要从 API 获取数据(速率限制 = 300 个请求/分钟最大值)并将结果存储到数据库中。我想获取

回答 1 投票 0

Celery 任务之间复杂的依赖关系和关系

我正在通过 Classroom API 在基于 Django REST 的 LMS 和 Google Classroom 之间进行集成。 使用信号,当我的 LMS 中发生某些动作时,我会从 ...

回答 0 投票 0

在django celery beat中收到任务,但没有执行

我将 django 与 celery、celery beat 和 redis 一起使用来运行周期性任务。 我遇到的问题是在芹菜中注册的任务已收到但未执行。 还有,任务中途停止

回答 2 投票 0

如何在windows上运行celery?

如何在不创建 Windows 服务的情况下在 Windows 上运行 celery worker? $ celery -A your_application worker 有什么类比吗?

回答 13 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.