celery 相关问题

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

如何将基于类的任务传递到 CELERY_BEAT_SCHEDULE

如文档中所示,基于类的任务是表达复杂逻辑的公平方法。 但是,文档没有指定如何将新创建的基于类的任务添加到 CELERY_BEAT_SCHEDULE 中(u...

回答 1 投票 0

Celery 检查取消 10 项限制

我需要使用 python 和 Celery 获取工作队列大小。该代码运行良好,但结果仅限于 10 项。有什么方法可以获取排队任务的完整列表吗?我得到了 100 多件物品,但只有......

回答 1 投票 0

多处理:分叉的缺点?

我们在使用 Python Celery(使用多处理)时遇到了一个问题,其中大型定期(计划)任务会在短时间内消耗大量内存,但因为工作线程

回答 1 投票 0

Celery:如何避免将同一任务多次放入队列?

我编写了一个非常简单的 FastAPI/Celery/Redis/Flower 程序来开始了解它们的工作原理。如果你想看的话,仓库是 https://github.com/rjalexa/fastapi-redis 。 FastAPI 路线将寻找

回答 1 投票 0

在 Python Celery 中链接任务而不传递先前的结果

我想创建一个异步事件链,一个接一个地执行,但我对将前一个事件的结果传递给下一个事件不感兴趣,只需在链中执行它们即可。我有

回答 1 投票 0

使用参数从 django 运行 python manage.py 命令

我有命令: ./manage.py dbbackup --clean --compress 由 django-dbbackup 应用程序提供,该应用程序将我的 PostgreSQL 数据库备份到 Amazon S3。我正在尝试运行此命令...

回答 2 投票 0

调试永远挂起的 Celery 任务调用 OptaPy

我尝试使用 Redis 作为代理在 Django 应用程序中的 Celery 任务中运行 OptaPy。该任务由 Celery 工作线程接收,但永远保持 PENDING 状态并且不返回任何结果。 如果我设置

回答 1 投票 0

Celery 作为服务 - PermissionError: [Errno 13] 权限被拒绝: '/var/run/celery'

我正在尝试创建一个运行 celery 的服务,但遇到了权限问题。我在许多教程中看到 pidfile 路径是 /var/run/celery/%n.pid 但似乎我的用户没有装备...

回答 4 投票 0

为什么有些Celery工人可以在没有任何失败证据的情况下停止?

我的应用程序的一部分有一个事件驱动的架构,它是在 Celery 工作线程中实现的。这是机器学习模型的训练,因此该过程通常会有所延迟(大约......

回答 1 投票 0

Celery Chord 在 Python 中如何工作?

我有以下代码: def create_pipeline( 真实:数据框, 预测名称:str, energy_asset_id:int, 家庭:str, 预测范围:日期范围, 方法论:L...

回答 1 投票 0

使用 SQLAlchemy 创建数据库表并运行 Celery 任务会引发“状态为 PGRES_TUPLES_OK 的错误,并且没有来自 libpq 的消息”

我有一个每分钟运行 2 个任务的应用程序。除了它们所通信的 API 端点(见下文)之外,它们都具有几乎相同的代码。运行任务时,我得到以下信息

回答 1 投票 0

使用 SQL Server 作为数据库的多租户 Django 应用程序

我正在尝试使用 SQL Server 创建多租户 Django 应用程序,它应该支持每租户数据库隔离。对于 PostgreSQL,有 django-multitenant 和 django-tenant-sc 等软件包...

回答 1 投票 0

在生产中多次重复 Celery 任务

我是 Celery 新手,我创建了一个简单的应用程序,它连接到 Web 套接字服务器以接收任务并使用 Celery 安排它们。我的 Celery 队列根据消息类型显示任务(t...

回答 3 投票 0

如何根据 celery 中的用户 ID 映射任务?

我有一个要求,我想让用户控制他们的待处理任务以及在我的应用程序上失败的任务。因此,我想创建一些类似任务应该映射到...

回答 1 投票 0

Celery Beat 无法在 Django 项目中调度任务

我正在开发一个 Django 项目,其中使用 Celery 进行任务调度。我有一个应该每分钟运行一次的定期任务,但 Celery Beat 似乎没有执行此任务。这是我的...

回答 1 投票 0

使用 celery 任务通过 bpy 渲染图像挂起

我正在尝试在 celery Worker 中使用 bpy python 包渲染图像。 设置如下 celery_app.py 从芹菜进口芹菜 app = Celery('任务',broker='pyamqp://guest@localh...

回答 1 投票 0

Celery 未运行和弦回调

在看了很多关于和弦回调不执行的文章并尝试了他们的解决方案之后,我仍然无法让它工作。事实上,chord_unlock 方法也没有被执行...

回答 4 投票 0

从多个队列中消费的 Celery Worker 如何决定先消费哪一个?

我正在使用 Celery 执行异步后台任务,以 Redis 作为后端。我对 Celery 工作人员在以下情况下的行为感兴趣: 我正在以 dae 的身份运行一个工人...

回答 4 投票 0

在 Celery Worker 中使用 requests_cache(带有 sqlite 后端)时出现内存错误

我在 M1 MacBook 上安装了 requests-cache==1.1.0 和 celery==5.3.4。 两者的配置都没有什么特别的,但在这里发布只是为了以防万一它有帮助 芹菜配置: 经纪人_url =“...

回答 1 投票 0

Mongoengine 连接失败

我正在尝试为我的项目运行 celerybeat,但它给了我以下错误。 芹菜工人运行良好。 我正在使用Python 3.9 使用 MongoDB:6.0.11 引发连接失败(呃...

回答 1 投票 0

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