celery 相关问题

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

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

celery celery-task

回答 2 投票 0

这是我的代码导入系统从 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、RabbitMQ 在执行任务时从消费者列表中删除工人

我已经启动了我的 celery Worker，它使用 RabbitMQ 作为代理，如下所示： celery -A my_app 工人 -l 信息 -P gevent -c 100 --prefetch-multiplier=1 -Q my_app 然后我的任务看起来很像......

python django rabbitmq celery

回答 1 投票 0

通过Airflow的UI TriggerDag参数指定DAG队列

感谢您阅读这个问题。我按照此处的官方说明完成了设置 Airflow 集群，并成功添加了托管在远程计算机上的工作人员。看来一切都这样了

celery airflow

回答 1 投票 0

芹菜花与不同 Docker 容器中的多个 Worker

我一直在 StackOverflow 和 Google 上徘徊，但我似乎无法接近答案。 tl;dr 如何在 dockerized Flower 仪表板中注册 dockerized Celery 工作人员？我该如何指向

python celery fastapi

回答 2 投票 0

如何将 celery 任务 stdout \ stderr 保存到文本文件？

我将 celery 任务与外部模块一起使用，这些模块通过 print() 将信息发送到标准输出。如何将 celery 任务的所有打印保存到预定义文件中？理想情况下，如果每个任务都有自己单独的文件。埃克...

python celery

回答 2 投票 0

Celery：“function”对象没有属性“apply_async”

尝试运行 celery 任务时出现错误“function”对象没有属性“apply_async” db_sinc.py def create_or_update_google_creative(): ...逻辑任务.py @共享任务定义

python celery

回答 1 投票 0

Celery - 手动指定任务父级？

我正在 Celery 中运行一组任务，如下所示： def run_many(n): job_id = str(uuid4()) g = 组(dummy.s(job_id) for _ in range(n)) 作业 = 任务.apply_async(task_id=job_id) 作业.保存(...

python celery

回答 1 投票 0

带有 SQS 代理和死信队列的 Celery

我正在尝试弄清楚如何配置 celery，以便在消息按照配置传递 max_retries 后将其移动到死信队列。目前正在删除（确认）超出的消息

python celery amazon-sqs

回答 3 投票 0

如何从字符串值设置（Django）celerybeat cron 计划

我正在使用 Django 和 celerybeat。我想通过 env var （cron 的字符串值）配置 cron 计划。我们目前正在使用 celery.schedules 设置这样的 cron 计划。

django celery django-celery celerybeat django-celery-beat

回答 1 投票 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

fastapi、celery、redis、docker compose：无法分配请求的地址

我使用 fastapi、celery、redis 和 docker-compose 来托管 RestAPI。一切都运行良好，除了当我通过 Dockerfile 中的一行代码触发 api 测试时。如果没有这行代码...

docker redis celery fastapi

回答 1 投票 0

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

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

python-3.x celery celery-task celerybeat

回答 1 投票 0

Celery链，如何等待动态创建的子任务（好像排除了chord）

为了数据完整性，我有一系列应按顺序执行的任务。我不需要任何类型的 celery 编排；我可以只让一项任务完成顶级任务