Celery是Python的分布式任务队列框架,用于异步和并行执行。
在 celery 中使用 apply_async() 时,Worker 不消耗任务
我正在尝试在 django 项目之外使用 celery。 我定义一个这样的任务: 从芹菜进口芹菜 应用程序 = Celery('任务') 应用程序.conf.更新( result_backend =“rpc”, 经纪人网址=...
使用 docker 为 django 项目配置 celery 时出现错误
当我由于某种原因使用 docker compose up 命令启动 docker 容器时,出现此错误: 芹菜工人|用法:芹菜 [选项] 命令 [参数]... 芹菜工人| ...
经过多次测试和搜索,我没有得到结果,希望您能指导我。 我的代码可以在这个 GitHub 地址上找到。 由于主要代码比较复杂,所以我写了一个简单的...
“连接池已满,正在丢弃连接”警告 Selenium 在 Django 中的 Celery 任务上
所以我在 Django 上使用 Celery 来安排任务。我的任务之一是使用 Selenium 生成一个驱动程序,用于驱动 Selenium Grid 上的 chrome 节点。 该任务还会生成一个将驱动程序作为参数的线程
Dash/Plotly - long_callback 在 celery/redis 后端失败
总结 我一直在开发一个使用 long_callback 的 dash 应用程序,并且为了开发,我一直在为我的 long_callback_manager 使用磁盘缓存后端,正如我在这里找到的指南所推荐的:ht...
Django celery 和主应用程序位于一个核心 cpu vps 服务器上?
我是芹菜新手。我可以在一台核心 cpu vps 服务器上运行 Django celery 和主应用程序吗?我需要每小时从队列中更新网站上的信息,并将其保存在 Radis 缓存中。而且我也...
我需要配置芹菜应将任务执行结果放入哪个队列,我使用文档中描述的方式(项目“reply_to”): @app.task(reply_to='export_task') # <= configured
celery:守护进程不允许有子进程(使用并发.futures)
在Python(3.6)中,我尝试在celery任务(celery 3.1.17)中创建进程(使用多重处理),但它给出了错误: 守护进程不允许有子进程 代码 def mp(): 与
Python pyserial 使用大量 CPU 在 Celery 上执行简单任务
我在 Celery 工作线程中使用 Pyserial,每 150 毫秒在串行上写入一个最大 20 字节的数据包 从字面上看,芹菜工作人员除了使用 ser.write(packet) 在串行上发送数据之外什么都不做...
我想从 Heroku 中的应用程序监控 celery 日志。我做了一些研究,发现了几个部署新的 Heroku 应用程序的存储库,该应用程序使用 Flower 进行监控。 问题: 我遵循了这些指示...
在我的 django 应用程序的 Procfile 中我使用这个 worker: celery -Aproject.celeryworker(使用Redis作为代理) 并使用铁路平台来托管我的应用程序,但在部署应用程序后...
为什么要把celery和flask结合起来?有什么好处?为什么不单独使用它们?
为什么要把celery和flask结合起来?有什么好处?为什么不单独使用它们呢? 您能否分享几个例子,为什么需要集成它们,而不是单独使用它们?
FastApi:Celery Worker 未执行任务并且任务停留在 Unack 中
我给自己写了一个测试应用程序来掌握 Celery 和 RabbitMQ 的窍门。 我的所有消息似乎都停留在 RabbitMQ 上的“Unack”状态...... 该任务应该由工人执行,然后...
将函数从 DjangoListAPI 传递到 celery 任务
我在将函数传递给 celery 任务时遇到一些麻烦,并且无法传递其结果,因为加载需要很长时间并且会导致 api 请求超时 @celery.task(name='task_name',bind=Tru...
我有一个 Django 项目。我想将其托管在 VPS 上。我看到了一些 VPS 服务并喜欢 Hostinger VPS。我想将其托管到该 VPS。 但问题是,我正在使用 Django Celery。我也在用
我正在尝试找到一种方法来获取触发芹菜节拍来触发任务的时间条件。 获取 datetime.now() 通常会偏离 celerybeat 任务排队的时间,因为...
使用 RabbitMQ 优化和扩展 Celery 以执行 I/O 密集型任务
我有一个 celery 任务,它接受来自生产者的关键字并使用该关键字查询数据库 - DB1,然后将其插入到另一个数据库 - DB2 中。一个任务周期大约需要15秒。
经过一周的尝试和搜索,我没有得到任何结果,我将感谢您的帮助。 概括: 我有 10 个工人,每个工人里面都有一个 app.task 。 每天,这10名工人...
使用 MSSQL 作为数据库的多租户 Django 应用程序
我正在尝试使用 MSSQL 服务器创建多租户 Django 应用程序。它应该支持每租户数据库隔离。对于 PostgreSQL,有 django-multitenant 和 django-tenant-
Celery 在 docker 中运行时无法将任务发送到队列
我在windows上测试了它并且它有效,但现在我想使用docker来做到这一点。问题是当我尝试执行任务向用户发送电子邮件时出现错误:[Errno 111] 连接被拒绝,但是 celery s...