celery 相关问题

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

我正在 Celery 中运行一组任务，如下所示： def run_many(n): job_id = str(uuid4()) g = 组(dummy.s(job_id) for _ in range(n)) 作业 = 任务.apply_async(task_id=job_id) 作业.保存(...

python celery

回答 1 投票 0

带有 SQS 代理和死信队列的 Celery

我正在尝试弄清楚如何配置 celery，以便在消息按照配置传递 max_retries 后将其移动到死信队列。目前正在删除（确认）超出的消息

python celery amazon-sqs

回答 3 投票 0

如何从字符串值设置（Django）celerybeat cron 计划

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

django celery django-celery celerybeat django-celery-beat

回答 1 投票 0

Python Celery socket.error：[Errno 61]连接被拒绝

我正在使用 Celery 3.0 并具有如下所示的配置文件。 celeryconfig.py BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' CELERY_TASK_SERIALIZER...

python celery celery-task

回答 4 投票 0

fastapi、celery、redis、docker compose：无法分配请求的地址

我使用 fastapi、celery、redis 和 docker-compose 来托管 RestAPI。一切都运行良好，除了当我通过 Dockerfile 中的一行代码触发 api 测试时。如果没有这行代码...

docker redis celery fastapi

回答 1 投票 0

Celery Beat - 如何手动调用周期性任务？

在我们的生产环境中，我们有一个 Celerybeat 配置为根据频率执行周期性任务。我的问题是，有没有办法让我开始执行本应在

python-3.x celery celery-task celerybeat

回答 1 投票 0

Celery链，如何等待动态创建的子任务（好像排除了chord）

为了数据完整性，我有一系列应按顺序执行的任务。我不需要任何类型的 celery 编排；我可以只让一项任务完成顶级任务

python celery

回答 1 投票 0

如何在 Airflow 2.8.0 中为 Airflow Celery Worker 添加 `broker_url` 设置？

我正在尝试在我的 Ubuntu 计算机上使用 Redis 设置 Celery 以进行 Airflow 2.8.0 安装，但我不明白应该将broker_url 设置放在哪里。如果您检查airflow.cfg，您会注意到...

python-3.x airflow celery

回答 1 投票 0

我面临着一个rabbitmq [无法建立连接，目标主动拒绝]，有人可以告诉我为什么会发生这种情况吗

我正在尝试将rabbitmq连接到celery以进行项目。 ERROR/MainProcess] 消费者：无法连接到 amqp://local:**@127.0.0.1:5672//: [WinError 10061] 无法建立连接，因为 t...

python rabbitmq celery

回答 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 = "...

django django-rest-framework celery django-celery celerybeat

回答 1 投票 0

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

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

celery django-celery celery-task periodic-task django-celery-beat

回答 1 投票 0

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

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

django rabbitmq celery

回答 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'

django amazon-web-services celery amazon-sqs django-celery

回答 1 投票 0

Celery 优雅关闭

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

python celery

回答 1 投票 0

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

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

django celery background-process redis-server

回答 6 投票 0

Сelery（导入错误：无法导入名称“_state”）

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

django-rest-framework celery python-import importerror

回答 1 投票 0

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

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

python celery

回答 2 投票 0

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

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

python rabbitmq celery

回答 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...

django docker docker-compose celery docker-image

回答 1 投票 0

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

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

python postgresql celery backend

回答 2 投票 0

celery 相关问题

最新问题