celery 相关问题

Celery是Python的分布式任务队列框架，用于异步和并行执行。

RedBeatScheduler 发送新任务，但 celery-worker 没有收到它们

如果 celery-worker 有大约 10-15 个任务，那么它会停止处理来自 RedBeatScheduler 的新任务，这些新任务是在工作期间动态创建的。但是，如果任务少于 10 个，那么他们...

redis celery celerybeat

回答 1 投票 0

django celery [celery.worker] 调试：定时器唤醒！运行 scrapy 进程时的下一个预计到达时间

我正在 Django 中使用 celery 在 task.py 文件中运行一个简单的蜘蛛。运行我的蜘蛛的代码如下：文件任务.py： @shared_task(绑定=True) def scrape_amazon_products(self,products_urls,

python django scrapy celery

回答 1 投票 0

在 Python 中将 WebSocket 与 Celery 和 FastAPI 集成

我正在将 WebSocket 与 Python 中的 Celery 和 FastAPI 集成，但面临 AttributeError 和 EncodeError 等问题。需要帮助解决这些错误以实现无缝集成。任何建议或指导...

websocket rabbitmq celery python-asyncio fastapi

回答 1 投票 0

如何更改 django celery 配置中的“传输”url

我有django 3.2.7，celery 5.2.1，redis 3.5.3 我有下一个芹菜设置。 (REDIS_PASSWORD) 是环境变量： CELERY_BROKER_URL = f'redis://:{REDIS_PASSWORD}@redis:6379/4' CELERY_BROKER_TRANSPORT_O...

django docker-compose redis celery

回答 3 投票 0

Celery 单元测试重试

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

django celery celery-task

回答 1 投票 0

Celery + SQS - pycurl 错误

今天我一直在尝试使用 AWS SQS 作为代理来设置 Celery，但是在执行以下命令时：测试.py 从芹菜进口芹菜 access_key_id = '********************'

python python-3.x celery amazon-sqs

回答 6 投票 0

需要了解celery crontab

我正在使用 celery.schedules crontab 库运行一个 cron 作业，如下所示 “每小时任务”：{ '任务'：'任务'， '计划': crontab(小时='*/1'), '选项'： { ...

python cron celery scheduled-tasks django-crontab

回答 1 投票 0

Celery 引发 ImproperlyConfigured 异常

我正在 Celery 文档中测试以下情况，但引发了 ImproperlyConfigured 异常。 http://docs.celeryproject.org/en/master/userguide/calling.html#id3 回溯（最近一次调用最后一次）：文件“测试...

python celery

回答 3 投票 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 安排每月 1 号运行的任务？

如何使用 celery 安排每月 1 号运行的任务？

python django scheduled-tasks scheduling celery

回答 3 投票 0

如何监控 Celery Worker 并在 Worker 死亡或被杀死时将任务返回到队列？

**问题描述：** 我有一个使用 Celery 执行异步任务的微服务。我需要监视 Celery 工作人员的状态，如果工作人员...

python django celery

回答 1 投票 0

避免 celery Broker 中的重复任务

我想使用 celery 配置 pi 创建以下流程：仅当 celery 队列没有已挂起的 TaskA(argB) 时才发送 TaskA(argB) 是否可以？怎么办？

celery

回答 5 投票 0

使用rabbitmq配置Celery多节点

我有一个celery节点，它使用rabbitMQ作为代理，它在一台机器上运行良好。我想在另一台机器上设置一个 celery 节点，但它将使用相同的rabbitMQ代理。这是否意味着如果我...

rabbitmq celery

回答 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

无法在 celery Worker 中使用 YOLO 加载和预测图像

这是我的代码导入系统从 Question_Detection.inference_object_detection.check_model 导入 verify_model 从记录器导入记录器从 ultralytics 导入 YOLO 类 ModelNotFoundError（除了...

python machine-learning celery yolov8

回答 1 投票 0

有什么方法可以非暴力地停止芹菜工人的特定任务吗？

正如 Celery 文档所述，已经执行的任务不会通过调用 .revoke() 中止，除非设置了 Terminate=True。但不建议这样做，因为它会杀死工人本身，w...

python celery

回答 2 投票 0

celeryshared_task装饰器中没有名为delay()的方法，如何修复它？

#订单/任务.py 从芹菜导入共享任务从 django.core.mail 导入 send_mail from .models import 订单 @共享任务 def order_created(order_id): order = Order.objects.get(id=order_i...

django celery

回答 1 投票 0

Celery 工作人员不执行 django 数据库更新任务

我正在开发一个仪表板，它需要运行长时间的后台任务，并最终更新数据库中的模型。我正在使用 Celery 来执行后台操作这是我的任务功能...

python django celery

回答 1 投票 0

Celery 因 redis.exceptions.ResponseError 崩溃：UNBLOCKED

我将 Celery 与 Django 和 Redis 一起用于日常任务。它实际上有效，但有时 celery 会因 redis.exceptions.ResponseError 崩溃，这是我不允许的。我看到了配置解决方案...

python django docker redis celery

回答 1 投票 0

celery 相关问题

最新问题