django-celery 相关问题

Django-celery为Django提供Celery集成。

我在 Celery 中有一个任务，如下所示： @app.task(name='task_one') def task_one(user_id, *args, **kwargs): # 长时间运行的任务每次用户提交任务时都会在视图中创建此任务...

django celery django-celery celery-task

回答 2 投票 0

如何管理Docker环境中redis-server内存消耗的增加？

我使用 redis-server 作为 Django 项目中 Docker 堆栈的一部分，该项目使用 Celery Beat 来执行计划任务。在使用 htop 命令监视进程时，我注意到内存......

python django docker redis django-celery

回答 1 投票 0

如何从字符串值设置（Django）celerybeat cron 计划

我正在使用 Django 和 celerybeat。我想通过 env var （cron 的字符串值）配置 cron 计划。我们目前正在使用 celery.schedules 设置这样的 cron 计划。

django celery django-celery celerybeat django-celery-beat

回答 1 投票 0

setting.py 中的 CELERY_BEAT_SCHEDULER 错误

设置.py ＃芹菜 CELERY_TIMEZONE = "UTC" CELERY_BROKER_URL = "redis://127.0.0.1:6379" CELERY_ACCEPT_CONTENT = [“应用程序/json”] CELERY_RESULT_SERIALIZER = "...

django django-rest-framework celery django-celery celerybeat

回答 1 投票 0

Celery 无法在 django python 中检测和注册任务

我面临一个问题，无法使用 Celery 在 django 框架中的应用程序中设置定期任务。我确实尝试了在互联网上找到的解决此问题的所有方法，反式...

celery django-celery celery-task periodic-task django-celery-beat

回答 1 投票 0

通过 Django Celery [sqs] 连接到 Amazon SQS 密钥 (SSE-SQS) 加密的 SQS 队列

连接到 SQS 加密队列时，我无法让我的 Celery 运行这是我的 django 项目的 settings.py SQS_AWS_ACCESS_KEY_ID = 'xxxx' SQS_AWS_SECRET_ACCESS_KEY = 'xxxx'

django amazon-web-services celery amazon-sqs django-celery

回答 1 投票 0

任何更改时 Celery 自动重新加载

当settings.py中的CELERY_IMPORTS中的模块发生更改时，我可以使celery自动重新加载。我试图让母模块来检测子模块上的变化，但它确实......

python celery django-celery

回答 9 投票 0

将 Celery Gevent Pool 与 asyncio (asgiref) 结合

我有很多用于 websocket 连接的异步代码。想法很简单：从 websocket 获取数据，计算一些数学并执行大量 io。数据 = 等待 websocket.recv() # 做一些数学计算一个...

celery python-asyncio django-celery gevent

回答 1 投票 0

当任务由不同的 celery 应用执行时，无法测试 celery 链

我的环境中有两个 celery 应用程序，它们是： app1 = Celery('app1', 经纪人=BROKER_URL1, 后端=BROKER_URL1) app2 = Celery('app2', 经纪人=BROKER_URL2, 后端=BROKER_URL2) 来自 Django 应用程序...

python django testing celery django-celery

回答 1 投票 0

没有结果的 Celery 任务写入结果后端

我有一些任务应该返回结果，而有些任务则不会。我想强制不应该返回结果的任务不在结果后端写入任何内容（例如无）。我怎样才能...

celery django-celery

回答 3 投票 0

AttributeError：“Logger”对象没有属性“warn”

我正在尝试通过 docker 将 celery 连接到我的 django 项目。但是当启动工作容器时，我收到以下错误 - 文件“/usr/local/lib/python3.13/site-packages/kombu/transport/...

django docker docker-compose celery django-celery

回答 1 投票 0

以指数回退重试 Celery 任务

对于这样的任务：从 celery.decorators 导入任务 @任务（） def 添加（x，y）：如果不是 x 或不是 y：引发异常（“测试错误”）返回 self.wait_until_server_responds( 如果是的话...

python celery django-celery

回答 3 投票 0

如何配置以SQS为后端的celery？

我正在尝试使用 celery 应用程序设置 SQS 代理，并在 django 项目中配置。这是我的设置：芹菜.py：导入操作系统从芹菜进口芹菜 os.environ.setdefault("DJANGO_SETTINGS_MOD...

django amazon-web-services celery amazon-sqs django-celery

回答 1 投票 0

Django Celery 结果表缺少periodictaskname 和taskname 字段

我已经用 Celery 设置了 Django，使用 django_celery_results 和 django_celery_beat 来安排任务并存储结果。任务运行成功，但我遇到了问题...

celery django-celery periodic-task django-celery-beat django-celery-results

回答 1 投票 0

Celery 检查取消 10 项限制

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

python django celery django-celery celery-task

回答 1 投票 0

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

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

python django celery django-celery

回答 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无法使用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

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

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

python django unit-testing celery django-celery

回答 5 投票 0

Django + Celery 中没有名为“project_name”的模块？

调试这个的第二天我必须转向 stackoverflow 我处于边缘。几个月前我使用 cookiecutter-django 生成我的项目。项目名配置/设置/... 源代码/ 应用程序_na...

django celery django-celery python-importlib cookiecutter-django

回答 2 投票 0

django-celery 相关问题

最新问题