我有一个用django开发的应用程序,在这个应用程序中,用户上传一个文件,然后发送到另一个服务器,然后执行几个脚本。由于这是一个相当慢的进程(可能需要10分钟),我决定将此进程的执行传递给celery ,我用redis配置celery (因为rabbitmq有时会出现一些断开连接的问题)。
整个过程的一个要求是将文件发送到服务器/一次执行一个脚本,我的意思是,如果两个用户同时上传一个文件,他们不能并行运行,需要先执行一个,然后再执行另一个
我用这个命令做到了
celery -A my_app worker -B -l info --concurrency=1 --scheduler django_celery_beat.schedulers:DatabaseScheduler
但我不知道这种方法有多可靠,这种执行celery 的方法有可能与celery 有什么关系,有时不接任务?就像有时我执行函数来调用任务,但什么都没有发生
暂无答案!
目前还没有任何答案,快来回答吧!