celery 相关问题

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

Python celery 通过 ssl 连接

我一直在尝试通过 celery 5.0.5 连接到 RabbitMQ（它是从 AWS Messaging Service 创建的）实例。连接链接的开头如下 amqps://user:password@..../。我

python python-3.x ssl rabbitmq celery

回答 3 投票 0

无法在docker中启动django项目

启动时，Redis 不起作用，因此缓存不起作用，因为我意识到没有与数据库的连接。我无法制作 loaddata 固定装置，Celery 也无法连接到 Redis。在ge...

django postgresql docker redis celery

回答 1 投票 0

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

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

python django testing celery django-celery

回答 1 投票 0

没有结果的 Celery 任务写入结果后端

我有一些任务应该返回结果，而有些任务则不会。我想强制不应该返回结果的任务不在结果后端写入任何内容（例如无）。我怎样才能...

celery django-celery

回答 3 投票 0

Scrapy/Celery 日志记录设置不起作用

我正在将 Scrapy 蜘蛛作为 Celery 任务运行。问题是 Scrapy 不会登录到文件 scrapy.log。它会记录到 Celery 日志中。此外，我可以在 Celery 日志中看到 DEBUG 级别...

python django logging scrapy celery

回答 5 投票 0

如何解决“ImportError：无法从‘flask’导入名称‘_request_ctx_stack’”错误？

当我使用 celery 和 redis 运行 Flask 应用程序时，命令提示符屏幕上出现导入错误。导入错误：无法从“flask”导入名称“_request_ctx_stack” 我更新了版本...

flask redis celery

回答 1 投票 0

Celery 工作线程挂起，没有任何错误

我有一个用于运行 celery 工作人员的生产设置，用于向远程服务发出 POST / GET 请求并存储结果，它每 15 分钟处理大约 20k 任务的负载。问题是

python celery blocking gevent

回答 4 投票 0

AttributeError：“Logger”对象没有属性“warn”

我正在尝试通过 docker 将 celery 连接到我的 django 项目。但是当启动工作容器时，我收到以下错误 - 文件“/usr/local/lib/python3.13/site-packages/kombu/transport/...

django docker docker-compose celery django-celery

回答 1 投票 0

以指数回退重试 Celery 任务

对于这样的任务：从 celery.decorators 导入任务 @任务（） def 添加（x，y）：如果不是 x 或不是 y：引发异常（“测试错误”）返回 self.wait_until_server_responds( 如果是的话...

python celery django-celery

回答 3 投票 0

让Airflow KubernetesPodOperator清除图像缓存而不在DAG上设置image_pull_policy？

我正在 Google Composer 上运行 Airflow。我的任务是 KubernetesPodOperators，默认情况下，对于 Composer，它们与 Celery Executor 一起运行。我刚刚更新了其中一个

celery google-cloud-composer airflow

回答 1 投票 0

GCP 日志记录在 Celery 任务中不起作用

我尝试在 celery 任务中使用 GCP 日志记录，但它不会将日志发送到 GCP Logs Explorer，它仅在运行 celery 应用程序的控制台上输出日志。类似的问题是...

python-3.x google-cloud-platform logging celery

回答 1 投票 0

Flask/Celery：AttributeError（“无法腌制本地对象'celery_init_app。<locals>.FlaskTask'”）

python 3.10 在 Windows 10 pro 上的 venv 中运行。我正在尝试遵循 Celery 和 Flask 集成的教程：https://flask.palletsprojects.com/en/latest/patterns/celery/ # 示例.py 来自

python flask redis celery attributeerror

回答 1 投票 0

Celery 与 postgresql 给出错误“无法适应类型‘AsyncResult’”

我使用 postgresql 作为 Celery (v5.3.5) 的后端。当我对任务 ASyncResult 调用 read() 时，Celery 返回 SQL 错误： sqlalchemy.exc.ProgrammingError: (psycopg2.ProgrammingError) c...

python postgresql sqlalchemy celery

回答 1 投票 0

创建一个支持 json 序列化的类，以便与 Celery 一起使用

我正在使用 Celery 来运行一些后台任务。其中一项任务返回我创建的 python 类。考虑到有关使用 pickle 的警告，我想使用 json 来序列化和反序列化此类。 ...

python json celery

回答 3 投票 0

如何在SQS中解码celery消息

sqs 中的一些 celery 任务永远处于待处理状态，我想在删除之前阅读这些消息（任务）。在进入 sqs 控制台时，我可以看到我尝试用它解码的编码消息值 =

django encoding celery amazon-sqs decoding

回答 2 投票 0

Celery 任务 on_success 处理程序的 kwargs 始终为空

芹菜版本= 4.3.0 我想要做的就是能够在任务的自定义成功处理程序中访问 celery 任务函数的实际参数（普通参数和关键字）。我能够推动...