celery 相关问题

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

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

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

sql-server django celery multi-tenant

回答 1 投票 0

在生产中多次重复 Celery 任务

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

python django redis celery

回答 3 投票 0

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

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

celery

回答 1 投票 0

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

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

python django celery django-celery

回答 1 投票 0

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

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

python celery blender bpy

回答 1 投票 0

Celery 未运行和弦回调

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

python ubuntu celery

回答 4 投票 0

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

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

scheduled-tasks celery celeryd

回答 4 投票 0

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

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

python sqlite python-requests celery

回答 1 投票 0

Mongoengine 连接失败

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

python mongodb celery mongoengine celerybeat

回答 1 投票 0

如何使用可通过 AWS Elastic Beanstalk 扩展的 Django 应用程序运行 celery Worker？

如何将 Django 与 AWS Elastic Beanstalk 结合使用，并且仅在主节点上通过 celery 运行任务？

django amazon-web-services celery amazon-elastic-beanstalk django-celery

回答 4 投票 0

是否可以在 Celery Task 中运行 VACUUM 命令？

我有芹菜周期性任务，需要在每次运行后运行postgres VACUUM查询，否则这个任务会占用大量HDD空间。我尝试最后在任务内运行 VACUUM，但出现错误：

django postgresql transactions celery vacuum

回答 2 投票 0

结合使用 Celery 和 Django 来访问速率受限的 RESTful API

只是想知道我的想法是否不必要地复杂以及是否有更简单/更好的方法。我计划使用 Celery 发送请求并从速率受限的 RESTful API 检索数据（10

django api rest celery rate-limiting

回答 1 投票 0

Celery无法使用redis

尝试第一次启动 Celery 但出现如下错误，我已经安装了 redis 并且它启动正常，但是 django 似乎仍然有问题，文件“ 尝试第一次启动 Celery 但出现如下错误，我已经安装了 redis 并且它启动正常，但是 django 似乎仍然有问题， File "<frozen importlib._bootstrap_external>", line 848, in exec_module File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed File "/home/atif/Documents/celery_test/celery-env/lib/python3.8/site-packages/kombu/transport/redis.py", line 263, in <module> class PrefixedStrictRedis(GlobalKeyPrefixMixin, redis.Redis): AttributeError: 'NoneType' object has no attribute 'Redis' 芹菜.py from django.conf import settings os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'celery_test.settings') app = Celery('celery_test',) app.config_from_object('django.conf:settings') # Load task modules from all registered Django apps. app.autodiscover_tasks(lambda: settings.INSTALLED_APPS) @app.task(bind=True) def debug_task(self): print(f'Request: {self.request!r}') 设置 #celery stuff --------------- BROKER_URL = 'redis://localhost:6379' CELERY_RESULT_BACKEND = 'redis://localhost:6379' CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' CELERY_TIMEZONE = 'Asia/Kolkata' celery_module/tasks.py from celery import Celery app = Celery('tasks',) @app.task def add(x, y): return x + y 尝试在虚拟环境中安装Redis： pip install Redis 使用全局安装redis pip install redis 或（如果您使用pipenv）我的情况出现错误是因为运行时未使用环境中的redis包 python -m celery -A *django_app* worker 如果你使用pipenv来管理你的Python环境，你可以运行上面的命令： pipenv run python -m celery -A *django_app* worker 如果你使用 Docker Compose，我帮助将reduce 添加到requirements.txt

django redis celery message-queue django-celery

回答 3 投票 0

在 Django 中使用 Celery 渲染电子邮件时TemplateDoesNotExist

我正在为论坛网站开发一个 API，并且有一个基于分类的视图，该视图向用户发送电子邮件以确认他的电子邮件。我有一个 celery 任务，发送电子邮件并在...

python django docker django-rest-framework celery

回答 1 投票 0

Pydantic 2.4 中的值未转换为模型

我正在使用 Fastapi、Celery 和 Pydantic(2.4)。我遇到的问题是，当我尝试从字典创建模型实例 (args = Model(**args)) 时，设置值不是

python celery fastapi pydantic

回答 1 投票 0

获取 Celery 以使用 Django 测试数据库

我正在尝试为 Django 应用程序中的一些 celery 任务编写一些单元测试。这些任务将模型 ID 作为参数，执行一些操作并更新模型。当运行 devserver 和 celery 时...