celery 相关问题

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

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

将 celery 与 Django-verify-email 一起使用

我正在尝试设置一个简单的任务来使用 django-verify-email 包和 celery 发送电子邮件验证 这是我的代码 #任务.py 从芹菜导入共享任务 来自 verify_email.email_handler

回答 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 优雅关闭

我有一个在 Docker 容器中运行的 Python 应用程序。该组件负责一些长时间运行的任务,我想在进行新部署时正常关闭这些任务。所有子...

回答 1 投票 0

Celery 连接到rabbitmq-server 而不是redis-server

我有一个 Django 应用程序,我想将其配置为 celery 来运行后台任务。 套餐: 芹菜==4.2.1 姜戈==2.1.3 Python==3.5 Redis-服务器==3.0.6 设置中芹菜的配置...

回答 6 投票 0

Сelery(导入错误:无法导入名称“_state”)

Win10系统,导入了celery和eventlet模块。我尝试将 celery 添加到我的 django 项目中,在设置文件夹中写入 init 文件并创建 celery.py 文件。我指定了所有

回答 1 投票 0

如何在外部 JSON/YAML 文件中定义 Celery Crontab 计划?

Celery 允许通过向 app.conf.beat_schedule 添加条目来定义计划任务。示例(基于链接) app.conf.beat_schedule = { # 每周一早上 7:30 执行 '做-

回答 2 投票 0

为什么芹菜任务没有被空闲的worker消耗?

我有一个 Python 应用程序,具有微服务架构和管道,我使用 Celery 以及 RabbitMQ 和 Redis。在应用程序流程(机器学习培训)中,8 种方法...

回答 1 投票 0

为什么我在创建 docker 镜像时遇到 403 错误?

Dockerfile: 来自 python:3.19-alpine 工作目录/应用程序 ENV Python不写入字节码1 ENV Python 无缓冲 1 ENV 路径 =“/PY/BIN:$PATH” 运行 pip install --升级 pip 复制 ./req.txt /app/req.tx...

回答 1 投票 0

postgres数据库中的celery任务结果是字节格式的?

我是芹菜新手。我尝试分别使用 redis 和 postgres db 作为结果后端。而对于redis后端,结果检索成功,对于postgres后端,结果检索

回答 2 投票 0

fastapi 0.105.0 引发错误:ValueError: 太多值无法解压(预计为 2),同时使用 celery5.3.6 和 centos 7

这是我的芹菜配置: 芹菜 = 芹菜(__name__) celery.conf.broker_url = os.getenv("BROKER_URL") celery.conf.result_backend = os.getenv("RESULT_BACKEND") celery.conf.task_ro...

回答 1 投票 0

kombu.exceptions.OperationalError:[Errno 111]连接被拒绝(flask,docker-compose)

我的烧瓶应用程序遇到问题 拥有以下场所: Python、Flask、Celerey、MongoDB、RabbitMQ。 当我向 API 发出请求时,我得到以下返回: kombu.exceptions.OperationalError:[

回答 1 投票 0

Celery(Django + Redis)任务失败:“无法建立连接,因为目标机器主动拒绝”

更新:为了简单起见,我决定尝试使用 Django 作为代理,因为我认为我在 Redis 设置中做错了什么。然而,在进行文档中描述的更改后,我得到了同样的错误......

回答 4 投票 0

Django:celery 任务不使用 .delay() 执行

我正在使用“Django 2 by Examples”书中的代码示例来构建我的电子商务商店。视图按其应有的方式工作,但任务永远不会执行。没有错误。页面冻结在“哇...

回答 4 投票 0

Celery 工作线程 - ConnectionResetError: [WinError 10054] 现有连接被远程主机强制关闭

执行长时间运行的任务时,Celery 连接会中断。 我使用 amqp 作为代理,使用 redis 作为后端。 芹菜正在远程主机上运行,我用于芹菜工作者的命令如下

回答 1 投票 0

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

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

回答 9 投票 0

将 Celery Gevent Pool 与 asyncio (asgiref) 结合

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

回答 1 投票 0

可以使用主机名连接到 Redis,但不能使用 URL

我正在尝试将 Celery 连接到另一台计算机上的 Redis 后端,但出现无主机路由错误。从问题中删除 Celery,我可以使用主机名连接 redis 客户端,但是......

回答 1 投票 0

Celery Beat 安排多个任务,但只运行第一个任务

我遇到了 Celery 的问题,我在 Celery Beat 中安排了多个任务,但只有一个任务(notify_after_sobes)正在执行。在 Celery Beat 日志中,我可以看到所有的 ta...

回答 1 投票 0

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