Celery是Python的分布式任务队列框架，用于异步和并行执行。
Celery shared_task 无法与 fastapi 中的 pytest 一起使用
我正在努力测试包含 celery 任务的 fastapi 端点。我想嘲笑芹菜任务。任务如下 发送电子邮件.延迟( 用户.电子邮件, “主题是 h...
Celery 无法与 fastapi 中的 pytest 一起使用
我正在努力测试包含 celery 任务的 fastapi 端点。我想嘲笑芹菜任务。任务如下 发送电子邮件.延迟( 用户.电子邮件, “主题是 h...
我有一组芹菜任务想要并行运行，然后等待它们全部完成。我目前正在使用： 组(task_list).apply_async().get() （有关更多详细信息，请参阅我的其他问题...
我有一个 Celery 任务，可以在几分钟内填充 PostgreSQL 数据库。我想在 Django 视图中从数据库检索当前数据并将其发送到模板...
如何使用Celery（无需第三方包）发送Django的密码重置邮件？
首先，我知道这个问题之前已经在这里得到了回答，它使用第三方包 django-celery-email，但我试图弄清楚如何在不依赖任何...的情况下完成这样的工作......
芹菜吃掉内存。 我们在 Django REST 中使用 Celery，并以 Redis 作为代理。 Celery 用于发送并重试发送回调，如果不成功（重试策略是尝试使用
我有以下情况。 我的客户向工作人员发送以下任务： ＃ 客户 任务 = my_task.apply_async((some_params), 队列='my_queue') # task.get() # 这会阻塞 我的工人执行...
我在应用程序中使用 celery 来运行定期任务。让我们看下面的简单示例 从 myqueue 导入队列 @perodic_task(run_every=timedelta(分钟=1)) def process_queue(): 队列=队列...
我正在使用 Django、Celery 和 RabbitMQ。我有一个发送电子邮件的简单任务。该任务有效，但速度非常慢。 例如，我发送 5000 封电子邮件，所有 5000 封电子邮件都直接发送到 RabbitMQ 作为规范...
如何使用自定义 Jinja2 模板函数，该函数依赖于调用“render”的函数中的变量
我试图弄清楚如何将变量传递到自定义模板函数中，到目前为止我还无法弄清楚如何使其工作。 我的想法是我将有一个模板
如何在我的任务中以 2 分钟的间隔按顺序（一个接一个）运行蜘蛛？ 信号.py @receiver(post_save, 发件人=ParseCategoryUrl) def start_parse_from_category_url(发件人, 创建,
如何使用 Django 正确地对 Celery 进行 dockerize？
我在将 Celery 与 Django 项目一起进行 docker 化时遇到了一些麻烦。最近我需要将 Celery 添加到我的项目中，我之前已经使用过它，但不是在 Docker 环境中。 ...
在我的应用程序部署到 AWS Elasticbeanstalk 后，我尝试运行 celery Worker。 99_celery_start.sh #!/usr/bin/env bash #制作目录 须藤 mkdir -p /usr/etc/ 须藤 chmod 755 /usr/etc/
使用 pytest 和 Monkeypatching 进行 Celery 集成测试
我正在尝试在 docker 上使用 Python 3.9.5、Celery 5.2.6、pytest 7.1.0 和 FastAPI 运行一些简单的集成测试。 项目结构： 📦 ┣ 📂应用程序 ┣ ┣ 📂API ┣ ┣ ┣ 📂路线 ┣ ┣ ┣ ┗ 📜芹菜...
如何将每个基于 celery 类的任务保存在 django 项目中的单独文件中？
我使用官方文档在我的 django 项目中设置了 celery http://docs.celeryproject.org/en/latest/django/first-steps-with-django.html#using-celery-with-django 所以我的项目结构...
PRECONDITION_FAILED：使用 Gevent 和并发在 Celery 和 RabbitMQ 上传递确认超时
我刚刚从 ForkPool 切换到 gevent，并发性 (5) 作为在 Kubernetes Pod 中运行的 Celery 工作线程的池方法。切换后，我在工作人员中遇到了不可恢复的错误：
芹菜花 UNAUTHENTICATED_API 无法正常工作
我正在开发一个使用 celery 工人和 Flower 来监控这些工人的项目。 Worker 和 Flower 都作为镜像在一个容器内运行。我想改变工人的属性...
django celery 显示错误 - 进程“ForkPoolWorker-1”pid:41 退出并显示“exitcode 70”
我的 django 中有一个 celery 计划任务，该任务在下午 4 点运行。该计划任务执行后，运行顺利，没有出现任何错误。昨天我的芹菜任务失败了...
如何在 Google App Engine 中启动工作人员？
我想在 Google App Engine 上的 Django 应用程序中使用 Celery。 我的问题是：如何启动/运行工作人员？