celery 相关问题

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

celery 任务的正确类型注释

我正在寻找正确的类型注释来归因于已由 celery @task 装饰器设置的 celery 任务。假设我有一个函数 run_task 接受一些 celery 任务。 @任务（...

python celery python-typing

回答 1 投票 0

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

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

django celery django-celery celery-task

回答 2 投票 0

从 celery 工作线程到 prometheus 的自定义指标

我有一些 celery 工作人员在 kubernetes 下的容器中运行。它们不会由 celery 自动缩放，并且每个都在单个进程中运行（即没有多处理）。我想要一堆不同的...

django kubernetes celery prometheus

回答 2 投票 0

当消息到达共享 RabbitMQ 队列时，KEDA ScaledObject 无法扩展多个 pod

我有以下情况：我有一个 Kubernetes 集群，其中有一个使用 RabbitMQ 进行通信的 Celery 应用程序。我有一个包含 Celery 任务的 pod，但有 3 个不同的

kubernetes triggers rabbitmq celery keda

回答 1 投票 0

Celery 命名任务执行并通过名称获取任务执行

我有一个名为 my_task 的 Celery 任务。我通过多次调用 my_task.delay() 创建任务的多次执行。我想为每次执行赋予一个唯一的标签/名称，并且能够获得...

python celery django-celery

回答 1 投票 0

如何在 celery 任务之外（在 django 视图内）登录 celery 日志？

假设 django 项目中有一个端点 def my_view(请求, my_id): 如果 is_request_valid(请求): logger =logging.getLogger('celery.task') logger.info('正在启动一个任务...

python django logging celery python-logging

回答 1 投票 0

优雅退出ForkPoolWorker中的celery任务

我的任务的简化版本：对于 _ 在范围内（100000）： # 检查worker是否没有关闭 # 如果是，则优雅退出 # 否则，做点什么。我尝试使用它来处理

celery

回答 1 投票 0

优雅地停止芹菜任务

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

python celery django-celery celery-task

回答 2 投票 0

celery如何使用Django ORM？

celery如何使用Django ORM？ Celery 和 django 是不同的进程。但是，Celery 工作人员可以使用 Django 应用程序代码。（ORM、模型..）我认为 celery 进程有 django 应用程序代码。难道是……

django celery django-celery

回答 1 投票 0

带有选择数据库数据的 Celery 周期性任务

我根据数据库中的数据设置发送生日祝福。使用Python和Celery（on_after_configure）。它看起来像这样：从烧瓶导入烧瓶从 celery.schedules 导入 crontab ...

python-3.x celery

回答 1 投票 0

flask celery 抛出错误“url 必须以前导斜杠开头”

我正在尝试使用 Flask 实现 celery，当我运行此命令 celery -A src.celery_worker.celery_appworker --loglevel=debug 来启动 celeryworker 时，它会抛出错误：我不能...

python flask celery flask-restx

回答 1 投票 0

Celery WorkerLostError Worker 过早退出：信号 6 (SIGABRT)

我想让异步工作同步完成。我使用couchbase中数据的id作为redis的key。我再次使用 redis 的值更新 couchbase。运行时效果很好

python asynchronous redis celery couchbase

回答 1 投票 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 任务未在 Mac M2 上运行（进程“ForkPoolWorker”退出并显示“信号 11 (SIGSEGV)”）

我在尝试在 Mac M1 计算机上运行 Celery 任务时遇到问题。我收到的错误消息如下：进程已分叉，您无法使用此 CoreFoundation 功能...

django rabbitmq celery apple-m1 task-queue

回答 1 投票 0

Celery 在调度的事件中发送父工作进程的进程 ID，而不是工作进程

我正在开发一个celery监控工具。为此，我正在记录来自 celery.events.receiver.EventReceiver 的事件。正在发送的数据如下所示（删除了不必要的信息以简化...

celery python-billiard

回答 1 投票 0

Django / Celery：一个任务如何能够不断地做某事？是否可以为任务设置无限循环？

我目前正在学习 Django 和 Celery。因此，我必须对 Django 项目执行一项功能，为此我使用 Celery：我需要不断检查 Redis 服务器中的列表。为此，我使用芹菜......

python python-3.x django celery

回答 1 投票 0

Celery Worker 在 Docker 中运行时不执行任何写入操作

我不知道如何描述问题，但基本上，我有一个 celery 任务，它执行一些工作并将对象写入数据库。从 app.celery 导入 celery_app 从 some.models 导入 Thing 小鬼...

python django docker celery django-celery

回答 1 投票 0

如何在celery任务中同步运行多个celery任务？

我必须设计两个任务，即任务A和任务B，用于通过API调用获取数据，这两个任务应该能够按计划每天在后台运行，但也可以从

celery

回答 1 投票 0

Celery Worker 找不到任务

我将worker与beats结合使用，beats发现一切都很完美，但是一旦beat将任务传递给worker，就会弹出错误：KeyError: 'tasks.cache_popular_posts' 所有信息...

python django celery

回答 1 投票 0

使用Python、Flask、Celery和Redis，包含多个组的任务无法调用其上有链的子任务

@celery.task(bind=True,ignore_result=False) def process_ml_model_dataset（自身，dataset_serialized，media_serialized，ml_model_serialized，collection_name，n_factor）：如果 n_factor == 1：

python docker flask redis celery

回答 1 投票 0

celery 相关问题

最新问题