Celery是Python的分布式任务队列框架,用于异步和并行执行。
我有一个 celery 任务图,我想恢复图中的所有任务 ID 以用于我的应用程序中的其他目的。然而,在某些情况下这似乎是不可能的。 虽然一切...
Django Celery 结果表缺少periodictaskname 和taskname 字段
我已经用 Celery 设置了 Django,使用 django_celery_results 和 django_celery_beat 来安排任务并存储结果。任务运行成功,但我遇到了问题...
我正在寻找正确的 celery 配置来处理 django 中执行的长任务。 这些是案件的关键: 任务需要几分钟才能完成,但处理是在
Celery 错误:尽管凭证有效并且代理连接成功,但仍无法连接到 Redis 结果后端
我的 Celery 设置遇到问题,无法连接到 Redis 结果后端。尽管提供了有效的凭据并成功连接到经纪人,我还是收到了
在线程中创建的DatabaseWrapper对象只能在同一线程中使用。”当尝试使用celery插入数据库时
我正在使用 celery 从 csv 读取数据并将其上传到 Postgres。 celery 任务正在工作(我认为),但是 django 抛出错误。我正在获取一个文件,将其转换为 pandas,删除 2 个 co...
我正在尝试运行 YOLOv8 重新训练的对象检测测试,但我不断收到此错误。 回溯(最近一次调用最后一次): 文件“/Library/Frameworks/Python.framework/Versions/3.11/bin/yol...
如何将基于类的任务传递到 CELERY_BEAT_SCHEDULE
如文档中所示,基于类的任务是表达复杂逻辑的公平方法。 但是,文档没有指定如何将新创建的基于类的任务添加到 CELERY_BEAT_SCHEDULE 中(u...
我需要使用 python 和 Celery 获取工作队列大小。该代码运行良好,但结果仅限于 10 项。有什么方法可以获取排队任务的完整列表吗?我得到了 100 多件物品,但只有......
我们在使用 Python Celery(使用多处理)时遇到了一个问题,其中大型定期(计划)任务会在短时间内消耗大量内存,但因为工作线程
我编写了一个非常简单的 FastAPI/Celery/Redis/Flower 程序来开始了解它们的工作原理。如果你想看的话,仓库是 https://github.com/rjalexa/fastapi-redis 。 FastAPI 路线将寻找
在 Python Celery 中链接任务而不传递先前的结果
我想创建一个异步事件链,一个接一个地执行,但我对将前一个事件的结果传递给下一个事件不感兴趣,只需在链中执行它们即可。我有
使用参数从 django 运行 python manage.py 命令
我有命令: ./manage.py dbbackup --clean --compress 由 django-dbbackup 应用程序提供,该应用程序将我的 PostgreSQL 数据库备份到 Amazon S3。我正在尝试运行此命令...
我尝试使用 Redis 作为代理在 Django 应用程序中的 Celery 任务中运行 OptaPy。该任务由 Celery 工作线程接收,但永远保持 PENDING 状态并且不返回任何结果。 如果我设置
Celery 作为服务 - PermissionError: [Errno 13] 权限被拒绝: '/var/run/celery'
我正在尝试创建一个运行 celery 的服务,但遇到了权限问题。我在许多教程中看到 pidfile 路径是 /var/run/celery/%n.pid 但似乎我的用户没有装备...
为什么有些Celery工人可以在没有任何失败证据的情况下停止?
我的应用程序的一部分有一个事件驱动的架构,它是在 Celery 工作线程中实现的。这是机器学习模型的训练,因此该过程通常会有所延迟(大约......
我有以下代码: def create_pipeline( 真实:数据框, 预测名称:str, energy_asset_id:int, 家庭:str, 预测范围:日期范围, 方法论:L...
使用 SQLAlchemy 创建数据库表并运行 Celery 任务会引发“状态为 PGRES_TUPLES_OK 的错误,并且没有来自 libpq 的消息”
我有一个每分钟运行 2 个任务的应用程序。除了它们所通信的 API 端点(见下文)之外,它们都具有几乎相同的代码。运行任务时,我得到以下信息
使用 SQL Server 作为数据库的多租户 Django 应用程序
我正在尝试使用 SQL Server 创建多租户 Django 应用程序,它应该支持每租户数据库隔离。对于 PostgreSQL,有 django-multitenant 和 django-tenant-sc 等软件包...
我是 Celery 新手,我创建了一个简单的应用程序,它连接到 Web 套接字服务器以接收任务并使用 Celery 安排它们。我的 Celery 队列根据消息类型显示任务(t...
我有一个要求,我想让用户控制他们的待处理任务以及在我的应用程序上失败的任务。因此,我想创建一些类似任务应该映射到...