我在主管中使用芹菜和设置芹菜命令,并在我的Django项目中面临此问题
主管:无法执行/无法执行/home/tspl/python_project/venv/bin/celery:enoent 主管:没有产生儿童过程, 这是我的代码: ; =========================…
可能部署在Heroku A(Django,Blask,FastAPI)REST API中使用芹菜与Redis使用Docker?
我正在与芹菜和工人Redis一起在Python的API休息。在我的本地PC中,我需要运行两个服务器,即烧瓶/FastApi服务器和芹菜服务器。我的问题是,是否可能在…
如何获取运行芹菜工人的名称?
我想特别关闭芹菜工人。我正在使用 app.control.broadcast('shutdown');但是,这将关闭所有工人;因此,我想传递目标参数。 当我运行 PS -EF | GREP…
用add_periodic_task()设置芹菜击败任务优先级
我已经进行了广泛的搜索,但找不到任何东西。 当使用 add_periodic_task()之类的东西时,是否可以为芹菜节拍任务设置芹菜任务优先级 sender.add_per…
芹菜在due_date上发送电子邮件
日期有所不同。 根据模型中使用芹菜中的截止日期将电子邮件发送给用户,Due_date与创建任务 models.py 的 class Task(BaseModel): name = models.Char…
我想路由2个不同的Celery_BROKER_URL
我想将2种不同的芹菜broker_url用于2个不同的IP,并且特定任务应在另一个URL中进行(ex -redis://127.0.0.2:6379)。 环境文件 CELERY_TASK_TRACK_S…
Django和芹菜日志
我们有一个Django应用程序(带有芹菜),该应用程序每分钟处理数万个HTTP请求。 获得了大量日志, ip... - - [date...] "POST /url... HTTP/1.0" 200 …
ModulenotFoundError在Django项目中启动芹菜时
我有这样的Django项目结构(没有显示所有文件/文件夹): myproj/ ├── __init__.py ├── config/ │ ├── __init__.py <-- imports `celery_ap…
如何从Python脚本开始芹菜工人,然后将其关闭?
我尝试过但无法正常工作的方法: if __name__ == "__main__": # Start celery worker in detached mode app.worker_main(argv = ['-A', 'myapp', 'wor…
通过使用Django-Celery-Beat设置动态任务调度来获得错误
我正在基于模型创建设置动态cron,以创建另一个模型对象 错误im获取 无法分配”(&lt; crontabschedule:0 0 27 1 *(m/h/h/dm/my/d)utc&gt;, tru…
将芹菜与RabbitMQ一起用作经纪人,而仅使用RabbitMQ&#x2B; PIKA用于异步任务,使用一个任务的优点
我目前的辩论是我们是否应该使用皮卡(Pika)坚持使用RabbitMQ实施,还是移至芹菜,如果我们与芹菜一起使用,那么所有优势都会有什么优势。据我所知,…
带有Plotly/Dash回调和芹菜/Redis的Django应用
我有一个Django项目,我的一个应用程序使用DASH/PLOTLY提供交互式数据可视化,并将其部署到Heroku。随着我的数据库越来越大,收集相关数据,将其归一…
限制不同数量的芹菜任务组的工人
对于不同的芹菜工作组,我们如何以不同的方式限制工人的数量。 这是有关如何将不同芹菜任务组合在一起的很好的参考: https://sayari3.com/articles/1…
限制芹菜中活动任务的数量
有任务 from celery import Celery celery = Celery(__name__, **kwargs) # Some setting here probably? @celery.task(name="task_runner", bind=Tru…