celery 相关问题

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

我正在使用 ubuntu 16 和 systemd 将 celery 作为守护进程运行。我也创建了单元文件，但我无法将 celery 作为服务运行。为什么会出现这个错误？ /etc/systemd/system/celery.service...

celery ubuntu-16.04 systemd

回答 2 投票 0

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

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

django celery django-celery celery-task djcelery

回答 1 投票 0

Celery 中的永久任务？

我正在构建一个 django 应用程序，在其中使用相机捕获图像、分析图像、将元数据和分析结果存储在数据库中，最后将数据呈现给用户。我正在考虑使用

python django multithreading image celery

回答 2 投票 0

Celery 未接收在后台运行的任务

我在设置 celery 与我的 Flask 应用程序一起使用时遇到问题。我使用了准系统应用程序来测试配置，发现我的 celery 工作程序已启动，但没有获取任何任务...

python redis celery amqp

回答 2 投票 0

Celery Beat 无法连接到 Rabbitmq 容器

我的 celery Beat docker 容器（据我认为）连接消息代理时出现问题。我有一个正在运行的 RabbitMQ 容器： .... 兔子MQ：图片：rabbitmq:3.11.13-management-alpine

django docker docker-compose rabbitmq celery

回答 1 投票 0

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

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

django amazon-s3 celery django-celery python-django-storages

回答 1 投票 0

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) 是否可以？怎么办？