django-celery 相关问题

Django-celery为Django提供Celery集成。

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

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

回答 2 投票 0

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

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

回答 1 投票 0

优雅地停止芹菜任务

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

回答 2 投票 0

celery如何使用Django ORM?

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

回答 1 投票 0

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

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

回答 1 投票 0

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

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

回答 1 投票 0

如何在远程任务中使用 Celery 原语?

我想使用 celery 的工作流程,例如位于另一个系统上的任务的组和和弦。目前使用 send_task() 来执行这些任务,但现在需要对多个任务进行分组

回答 1 投票 0

Celery 和 Celery 在 docker 容器中运行一些作业后击败了 django

我正在尝试运行 django celery 和 celerybeat 当我开始芹菜和芹菜节拍后 这个进程每秒运行一次,这正常吗 芹菜-1 | [2024-03-10 16:08:11,479:信息/主流程]

回答 1 投票 0

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

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

回答 1 投票 0

将文件存储到 S3 在 Celery 工作线程中不起作用

我面临着从 django 的 celery 任务将文件存储在 S3 中的问题。我正在做以下事情 从数据库获取数据 使用 BytesIO 创建 XLSX 文件 使用 Dja 的 file.save 方法存储该文件...

回答 1 投票 0

celery 击败 ExpressionDescriptor.py get_full_description

我希望你今天一切顺利。我正在处理的 Django 项目遇到了一些障碍。我对 Django 比较陌生,如果您能抽出一点时间来帮助我,我将不胜感激

回答 1 投票 0

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

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

回答 2 投票 0

如何管理Docker环境中redis-server内存消耗的增加?

我使用 redis-server 作为 Django 项目中 Docker 堆栈的一部分,该项目使用 Celery Beat 来执行计划任务。在使用 htop 命令监视进程时,我注意到内存......

回答 1 投票 0

如何从字符串值设置(Django)celerybeat cron 计划

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

回答 1 投票 0

setting.py 中的 CELERY_BEAT_SCHEDULER 错误

设置.py # 芹菜 CELERY_TIMEZONE = "UTC" CELERY_BROKER_URL = "redis://127.0.0.1:6379" CELERY_ACCEPT_CONTENT = [“应用程序/json”] CELERY_RESULT_SERIALIZER = "...

回答 1 投票 0

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

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

回答 1 投票 0

通过 Django Celery [sqs] 连接到 Amazon SQS 密钥 (SSE-SQS) 加密的 SQS 队列

连接到 SQS 加密队列时,我无法让我的 Celery 运行 这是我的 django 项目的 settings.py SQS_AWS_ACCESS_KEY_ID = 'xxxx' SQS_AWS_SECRET_ACCESS_KEY = 'xxxx'

回答 1 投票 0

任何更改时 Celery 自动重新加载

当settings.py中的CELERY_IMPORTS中的模块发生更改时,我可以使celery自动重新加载。 我试图让母模块来检测子模块上的变化,但它确实......

回答 9 投票 0

将 Celery Gevent Pool 与 asyncio (asgiref) 结合

我有很多用于 websocket 连接的异步代码。想法很简单:从 websocket 获取数据,计算一些数学并执行大量 io。 数据 = 等待 websocket.recv() # 做一些数学计算 一个...

回答 1 投票 0

当任务由不同的 celery 应用执行时,无法测试 celery 链

我的环境中有两个 celery 应用程序,它们是: app1 = Celery('app1', 经纪人=BROKER_URL1, 后端=BROKER_URL1) app2 = Celery('app2', 经纪人=BROKER_URL2, 后端=BROKER_URL2) 来自 Django 应用程序...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.