Django-celery为Django提供Celery集成。
我有一些任务应该返回结果，而有些任务则不会。 我想强制不应该返回结果的任务不在结果后端写入任何内容（例如无）。我怎样才能...
AttributeError：“Logger”对象没有属性“warn”
我正在尝试通过 docker 将 celery 连接到我的 django 项目。 但是当启动工作容器时，我收到以下错误 - 文件“/usr/local/lib/python3.13/site-packages/kombu/transport/...
对于这样的任务： 从 celery.decorators 导入任务 @任务（） def 添加（x，y）： 如果不是 x 或不是 y： 引发异常（“测试错误”） 返回 self.wait_until_server_responds( 如果是的话...
我正在尝试使用 celery 应用程序设置 SQS 代理，并在 django 项目中配置。 这是我的设置： 芹菜.py： 导入操作系统 从芹菜进口芹菜 os.environ.setdefault("DJANGO_SETTINGS_MOD...
Django Celery 结果表缺少periodictaskname 和taskname 字段
我已经用 Celery 设置了 Django，使用 django_celery_results 和 django_celery_beat 来安排任务并存储结果。任务运行成功，但我遇到了问题...
我需要使用 python 和 Celery 获取工作队列大小。该代码运行良好，但结果仅限于 10 项。有什么方法可以获取排队任务的完整列表吗？我得到了 100 多件物品，但只有......
Celery Beat 无法在 Django 项目中调度任务
我正在开发一个 Django 项目，其中使用 Celery 进行任务调度。我有一个应该每分钟运行一次的定期任务，但 Celery Beat 似乎没有执行此任务。这是我的...
如何使用可通过 AWS Elastic Beanstalk 扩展的 Django 应用程序运行 celery Worker？
如何将 Django 与 AWS Elastic Beanstalk 结合使用，并且仅在主节点上通过 celery 运行任务？
尝试第一次启动 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 应用程序中的一些 celery 任务编写一些单元测试。这些任务将模型 ID 作为参数，执行一些操作并更新模型。当运行 devserver 和 celery 时...
Django + Celery 中没有名为“project_name”的模块？
调试这个的第二天我必须转向 stackoverflow 我处于边缘。 几个月前我使用 cookiecutter-django 生成我的项目。 项目名 配置/设置/... 源代码/ 应用程序_na...
从 CSV 导入 Postgres 时缺少 python 中的一些行
我一直在尝试每 10 分钟后将大规模数据从 csv 导入到 Postgres。 在芹菜的帮助下，我同时安排了几项工作。 导入后 csv 中的行数不匹配
当在类中定义方法时，Python Django 无法运行 celery
我是 celery 新手，现在我正在使用它在后台计算 Django 任务。我遇到的问题可以使用下面的类方法来演示，我在其中定义了 3 个函数...
我使用 celery 2.4.1 和 python 2.6、rabbitmq 后端和 django。我希望如果工作人员关闭，我的任务能够正确清理。据我所知，您无法提供...
我遇到了一个问题，django_celery_results_chordcounter 表很快就填满了，导致我耗尽了服务器空间。它从几 MB 增长到超过 99 GB。 我已经尝试解决...
在celery任务中访问request或request.user
我正在尝试在 django celery 任务函数中访问 request.user 但由于该函数不接受任何请求实例而无法访问，那么我该如何访问它？ @共享任务 def run_ever...
我有一个 scrapy 项目，我想每天运行我的蜘蛛，所以我使用 celery 来做到这一点。这是我的tasks.py 文件： 从芹菜导入芹菜，shared_task 从 scrapy.crawler 导入 CrawlerProcess ...
Celerybeat：更改单个时区任务导致验证错误“无效时区”
芹菜--版本 5.1.2（太阳谐波） Django --版本 3.2.8 我有一个芹菜计划，其中有四个在不同时区运行的任务。我正在使用 nowfun 设置时区并已设置
有没有有效的方法来检索特定队列中当前正在执行的 celery 任务的数量？
我想知道当前正在执行的 celery 任务和等待任务的数量。 然而，所有的 celery 检查命令都显示不正确的结果，并且使用它们似乎并不容易。 我的芹菜信息...
在错误页面上隐藏 Django 设置值（对于 Celery）
我们在 Django 项目中使用 Celery，并将 CELERY_RESULT_DBURI 值（它携带数据库的密码）放入我们的 settings.py 文件中。显然，拥有通行证我感觉不太安全......