celery 相关问题

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

将自定义弹性beanstalk日志获取到cloudwatch组

遇到问题并且无法从 .ebextentions/logs.config 创建自定义 cloudwatch 日志组 这是我尝试过的不同文件。 1 --- 文件: /opt/elasticbeanstalk/tasks/bundlelogs.d/

回答 2 投票 0

使用芹菜和不使用multi有什么区别

我注意到有两种不同的方式来运行芹菜工人。您可以使用或不使用多命令后缀来启动工作程序: celery多启动worker -A main.celery --concurrency=10 和

回答 1 投票 0

Celery Broker 宕机了怎么办?

我有一个带有 RabbitMQ 代理的 Celery 服务器。我用它在 Django 项目中运行后台任务。 在我的一种观点中,触发了一个信号,然后调用一个 celery 任务,如下所示: 创建_som...

回答 3 投票 0

Flask + Celery 如何捕获ForkPoolWorker值?

无论如何,如何在 Celery 工作应用程序中捕获 ForkPoolWorker 值(例如 ForkPoolWorker-8)? 芹菜日志: [2023-08-31 11:53:53,151:警告/ForkPoolWorker-8]初始化一个新令牌 [2023...

回答 1 投票 0

Celerybeat:更改单个时区任务导致验证错误“无效时区”

芹菜--版本 5.1.2(太阳谐波) Django --版本 3.2.8 我有一个芹菜计划,其中有四个在不同时区运行的任务。我正在使用 nowfun 设置时区并已设置

回答 1 投票 0

Celery 任务类型错误表示运行任务时存在额外参数

我有两个芹菜任务: @共享任务 def start_scrapy(book_id, link, site, end_page=None, start_page=1): 书 = Book.objects.get(id=book_id) 进程 = CrawlerProcess(get_project_settings()...

回答 1 投票 0

带有动态参数的 Celery 定期任务

我想安排一个 Celery 任务,它可以在每个计划中接受动态参数。本质上,参数应该源自数据库查询的结果。有没有办法实现这个...

回答 1 投票 0

如何在使用 python、flask、docker 和 docker compose 时使用 celery rdb?

我在项目中使用 python、flask、celery、docker 和 docker compose,并想使用 celery rdb 来调试我的任务。我无法使用本地计算机上的 telnet 连接到 celery 容器来执行...

回答 1 投票 0

有没有有效的方法来检索特定队列中当前正在执行的 celery 任务的数量?

我想知道当前正在执行的 celery 任务和等待任务的数量。 然而,所有的 celery 检查命令都显示不正确的结果,并且使用它们似乎并不容易。 我的芹菜信息...

回答 1 投票 0

Airflow 重新启动调度程序后所有 DAG 都会排队

我已经为 ETL 管道部署了一个 Airflow 集群,其中包含以下组件: 气流2.5 PostgresSQL 芹菜执行者 雷迪斯 集群运行良好,但我注意到每次重新启动时......

回答 1 投票 0

芹菜加权任务

我想知道是否可以为芹菜任务添加“权重”。这是一个具体的例子: 我有一个带有 8Gb VRAM 的 GPU。 我有三个任务: 任务1占用2Gb 任务2占用4Gb 任务3 采取...

回答 1 投票 0

为什么不能从celery导入celery

当我将项目投入生产时,即使使用 runserver 测试,也不会出现此错误,但是当我使用gunicorn --bind 进行测试时,会发生这种情况 导入操作系统 从芹菜进口芹菜 # 设置默认值

回答 1 投票 0

Celery - 打印消息被打印两次到控制台

这是定义 celery 应用程序的文件: 从芹菜进口芹菜 从常量导入 TASKS_FILE_NAMES celery_app = Celery('任务', 后端='rpc://', 经纪人='pyamqp://guest@localh...

回答 1 投票 0

芹菜节拍卡在启动时

芹菜启动后,我有以下输出: [2022-12-24 17:42:25,851: INFO/MainProcess] 连接到 redis://localhost:6379// [2022-12-24 17:42:25,854:INFO/MainProcess] Mingle:搜索

回答 1 投票 0

具有 Celery 配置的 SQS

我尝试为 Celery 设置 Amazon SQS,我有以下配置: BROKER_BACKEND =“SQS” 经纪人_运输_选项 = { '地区': 'us-east-1', } AWS_ACCESS_KEY_ID = # 访问 ID

回答 3 投票 0

如何在celery中指定SQS队列名称

我需要用 SQS 代理替换我的 Redis 代理,在 google 搜索时我发现了很多页面,告诉我如何将 SQS 与 celery 结合使用。根据我的理解,它创建了自己的SQS队列,我只有......

回答 5 投票 0

使用 Flask 和 SQLAlchemy 在 Celery 任务中未更新数据库

我正在使用 Flask 和 SQLAlchemy 编写 Web 应用程序。我的程序需要在后台处理一些内容,然后将这些内容标记为在数据库中已处理。使用标准 Flask/Celery ex...

回答 2 投票 0

在错误页面上隐藏 Django 设置值(对于 Celery)

我们在 Django 项目中使用 Celery,并将 CELERY_RESULT_DBURI 值(它携带数据库的密码)放入我们的 settings.py 文件中。显然,拥有通行证我感觉不太安全......

回答 1 投票 0

使用 Django 在 Flask 中运行后台任务

我有一个完全使用 Flask 构建的 Web 应用程序,目前整个项目在 Flask 上运行,我正在使用许多 Flask 库来实现各种功能。然而,我正在运行其中一些任务......

回答 2 投票 0

Python celery - 如何等待和弦中的所有子任务

我正在对 celery 任务进行单元测试。 我的连锁任务也有组,所以产生了一个和弦。 测试应该如下所示: 运行 celery 任务(延迟) 等待任务和所有子任务 断言 我尝试...

回答 3 投票 0

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