Django-celery为Django提供Celery集成。
从 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 文件中。显然,拥有通行证我感觉不太安全......
我有一个 Django 应用程序。那还有redis、celery 和flower。 一切都在我的本地机器上运行。 但是当我尝试对其进行 dockerize 时,redis 和 django 应用程序正在启动。但是芹菜和花...
无法使用 celery 延迟保存表单:对象不可 JSON 序列化
使用Django 1.8,我想在表单保存在视图中后触发延迟的celery函数 def new_topic(请求,forum_id): 形式 = TopicForm() uid = 请求.用户.id 如果请求满足...
我的 Python 应用程序中有一个 Celery 实现。我使用的经纪商是SQS。发送到 SQS 的消息通过 Boto3 的 send_message() API 来自不同的应用程序。现在我很困惑...
我正在尝试找到一种方法来获取触发芹菜节拍来触发任务的时间条件。 获取 datetime.now() 通常会偏离 celerybeat 任务排队的时间,因为...
Celery 工作人员未正确执行任务(正在从beat 接收任务)
我正在尝试将 celery-redis 组合添加到我的 django 项目中。安装了 celery、django-celery-beat 并进行了其他设置。我编写了一个简单的任务来在电报中向我发送消息(在...
cookiecutter-django 模板 django.db.utils.ProgrammingError:关系“django_celery_beat_periodictask”不存在
我使用 cookiecutter 模板生成了 django 应用程序,并收到错误消息 celery_beat_periodictask 不存在。 我运行了以下 docker-compose 命令: docker-compose -f local.yml up -d --
是否可以仅为和弦任务配置结果后端?或者我是否需要为 Celery 应用程序中的所有任务配置通用结果后端才能使用和弦? 我已经有了资源...
Django celery - Django Admin 中的任务结果为空
我已经按照教程设置了celery/redis相关设置。 celery 任务可以成功运行,但 django admin 中的“任务结果”为空,记录为 0。 这是我的
我正在尝试实现一个任务,其中全局变量在两个不同的 Celery 任务之间共享。为此,我继承了任务类并使用了属性。根据芹菜文档,基础......
朋友们有一个问题:我想在Django中更新celery的任务状态。我想要的一个例子: 1-在任务中创建一个任务,比如从多个文本文件中提取数字: @shared_tas ...
当我尝试使用命令 celery -A blogger.celery worker 启动 celery 时,我遇到了以下错误。我从我的包目录运行命令,我有我的 celery.py