celery-task 相关问题

celery-task是Celery分布式任务队列系统的构建块

通过 Django 中的 celery Worker 停止当前正在运行的任务

我有一个 Django 应用程序和 React 作为我的前端框架，我使用 celery 来运行冗长的任务，这确实需要很多时间，但一切都工作正常。我还提供真实的...

django celery django-celery celery-task

回答 2 投票 0

优雅地停止芹菜任务

我想优雅地退出 celery 任务（即不是通过调用 revoke(celery_task_id, Terminate=True)）。我想我应该向设置标志的任务发送一条消息，以便任务函数可以返回...

python celery django-celery celery-task

回答 2 投票 0

celery 正在运行，但没有执行任何任务

带有 Redis 的 Celery 正在运行，但任务未在 FastAPI 中执行命令-redis-服务器- 命令 - celery -A core.celery_app_work worker --loglevel=info -P eventlet - 芹菜花输出...

redis celery fastapi celery-task

回答 2 投票 0

如何从 celery 任务获取实时标准输出？

我有一个 Django 项目，其中我正在使用 celery 运行一些后台任务，我的目标之一是显示正在运行的任务的实时标准输出，以便用户可以看到进度。问题是...

python-3.x django celery django-celery celery-task

回答 1 投票 0

Celery 任务在 Django 测试中不会抛出异常

我的 Django 测试中包含几个 celery 任务。不幸的是，当通过 .delay() 调用任务时，不会抛出异常。我将 CELERY_ALWAYS_EAGER 设置为 True。任务.py

python django testing celery celery-task

回答 3 投票 0

@shared_task 装饰器不起作用

问题：当我从自定义文件导入数据时，@shared_task 装饰器不起作用。我的意思是，当我启动 celery 时，@shared_task 下的所有任务都不会出现在任务列表中。例如，在...

django celery celery-task cookiecutter-django

回答 2 投票 0

Celery 和 Django - 主进程是否等待任务完成？

我刚刚开始开发一个使用 Django 和 Celery 的项目。我对两者都很陌生。其中一个端点的代码如下所示： task_do_something.delay() 返回响应（ ...

django celery django-celery celery-task djcelery

回答 1 投票 0

Celery 单元测试重试

我目前正在为我的芹菜任务编写单元测试，并想测试我的任务是否正在重试。注意：ALWAYS_EAGER 在测试设置中设置为 True @app.shared_task(bind=True, soft_time_...

django celery celery-task

回答 1 投票 0

celery apply_async 返回缺少参数错误

我有一个带有定义的芹菜函数 - @async_worker.task(ignore_result=True, 队列=“data_path”) defpublish_msg_from_lock(self, mac: str, data: bytes, gateway_euid: str): 以前...

python django celery celery-task

回答 1 投票 0

Celery 限制每个用户运行的任务数量

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

django celery django-celery celery-task

回答 2 投票 0

如何使用 pytest 测试 Celery 实例的任务？

如何使用 pytest 测试 Celery 实例的任务？我不是在谈论使用 @shared_task 装饰器和 pytest 来测试创建的 Celery 任务。为此，已经有一个很好的解决方案...

celery celery-task

回答 2 投票 0

Python Celery socket.error：[Errno 61]连接被拒绝

我正在使用 Celery 3.0 并具有如下所示的配置文件。 celeryconfig.py BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' CELERY_TASK_SERIALIZER...

python celery celery-task

回答 4 投票 0

Celery Beat - 如何手动调用周期性任务？

在我们的生产环境中，我们有一个 Celerybeat 配置为根据频率执行周期性任务。我的问题是，有没有办法让我开始执行本应在

python-3.x celery celery-task celerybeat

回答 1 投票 0

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

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

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

回答 1 投票 0

Celery（Django + Redis）任务失败：“无法建立连接，因为目标机器主动拒绝”

更新：为了简单起见，我决定尝试使用 Django 作为代理，因为我认为我在 Redis 设置中做错了什么。然而，在进行文档中描述的更改后，我得到了同样的错误......