深圳家装互联网网站浙江省城乡建设信息港

深圳家装互联网网站,浙江省城乡建设信息港,幼儿网站源代码,网络营销就业方向使用 Celery Redis 执行异步任务引言一、主要功能二、实现步骤2.1 安装依赖2.2 配置 Celery2.3 在 settings.py 中配置 Celery2.4 定义异步任务#xff08;tasks.py#xff09;2.5 在 View 中触发任务2.6 错误修正引言 计算机专业硕士在读#xff0c;主要研究方向是特定目…使用 Celery Redis 执行异步任务引言一、主要功能二、实现步骤2.1 安装依赖2.2 配置 Celery2.3 在 settings.py 中配置 Celery2.4 定义异步任务tasks.py2.5 在 View 中触发任务2.6 错误修正引言计算机专业硕士在读主要研究方向是特定目标大斜视角目标检测与定位。因为要做的是特定目标公开数据集较少经过多方考虑还是决定要自建数据集。最终考虑的解决方案还是BlenderPython API的方式项目起名叫RealEarthStudio。这系列文章主要对开发过程进行记录方便我个人后续查看也给相类似方向的同学提供一个思路。【项目目录】项目目录链接一、主要功能功能使用 Celery Redis 执行异步任务。背景上一篇文章已经安装了Redis数据库现在配置Celery将耗时任务交给后台工作进程处理。效果码云项目链接https://gitee.com/charlsewyq/RealEarthStudio二、实现步骤2.1 安装依赖在命令行中运行pipinstallcelery redis django-celery-results2.2 配置 Celery在项目根目录与settings.py同级创建celery.pyimportosfromceleryimportCelery# 设置 Django 的默认设置模块os.environ.setdefault(DJANGO_SETTINGS_MODULE,RealEarthStudio.settings)appCelery(RealEarthStudio)# 从 Django settings 中加载配置以 CELERY_ 开头的项app.config_from_object(django.conf:settings,namespaceCELERY)# 自动发现各 app 下的 tasks.pyapp.autodiscover_tasks()修改__init__.py确保 Celery 应用被加载from.celeryimportappascelery_app __all__(celery_app,)2.3 在 settings.py 中配置 Celery# Celery 配置CELERY_BROKER_URLredis://127.0.0.1:6379/0# 使用 Redis 作为消息代理CELERY_RESULT_BACKENDdjango-db# 将任务结果存入数据库需安装 django-celery-resultsCELERY_ACCEPT_CONTENT[json]CELERY_TASK_SERIALIZERjsonCELERY_RESULT_SERIALIZERjsonCELERY_TIMEZONEAsia/Shanghai# 如果使用 django-celery-results添加到 INSTALLED_APPSINSTALLED_APPS[django_celery_results,]2.4 定义异步任务tasks.py在app中新建tasks.py文件fromceleryimportshared_taskimportosfromdjango.utilsimporttimezonefrom.modelsimportRenderingTaskshared_taskdefexecute_render_task(render_id): 异步执行渲染任务 try:render_taskRenderingTask.objects.get(render_idrender_id)# 写入信息文件full_filepathos.path.join(render_task.rendered_result_dir.path,info.txt)withopen(full_filepath,w,encodingutf-8)asf:f.write(f 渲染任务信息 \n)f.write(f渲染任务ID:{render_task.render_id}\n)f.write(f渲染时间:{render_task.render_time.astimezone(timezone.get_default_timezone())}\n)f.write(f渲染器类型:{render_task.renderer_type}\n)f.write(f图像分辨率:{render_task.image_width}×{render_task.image_height}\n)f.write(f总像素数:{render_task.image_pixels}\n\n)f.write(f 模型信息 \n)f.write(f目标模型数量:{render_task.target_models.count()}\n)ifrender_task.target_models.exists():fori,target_modelinenumerate(render_task.target_models.all(),1):all_categoriesset(target_model.category.all())forcatinlist(all_categories):parentcat.parentwhileparent:all_categories.add(parent)parentparent.parent category_names, .join([str(cat.name)forcatinall_categories])f.write(f 目标模型{i}:{target_model.model_id}({category_names})\n)f.write(f场景模型数量:{render_task.scene_models.count()}\n)ifrender_task.scene_models.exists():fori,scene_modelinenumerate(render_task.scene_models.all(),1):category_names, .join([str(cat.name)forcatinscene_model.category.all()])f.write(f 场景模型{i}:{scene_model.model_id}({category_names})\n)f.write(f\n 光照参数 \n)f.write(f日光方位角:{render_task.sun_azimuth}°\n)f.write(f日光高低角:{render_task.sun_elevation}°\n\n)f.write(f 相机参数 \n)f.write(f相机距离列表:{render_task.camera_distances}\n)f.write(f相机高低角列表:{render_task.camera_elevations}\n)f.write(f相机方位角间隔:{render_task.camera_rotation_step}°\n\n)returnf渲染任务{render_id}完成exceptExceptionase:# 处理错误情况returnf渲染任务{render_id}失败:{str(e)}2.5 在 View 中触发任务在app中修改views.py文件fromrest_framework.viewsimportAPIViewfrom.tasksimportexecute_render_taskfromutils.statusimportresponseasmy_responseclassStartRender(APIView):staticmethoddefget(request,render_id):# 开始渲染print(准备启动渲染任务)execute_render_task.delay(render_id)print(渲染任务启动完成)# 返回信息data{render_id:render_id,# render_time: render_task.render_time,}returnmy_response.success(datadata,message开始渲染)2.6 错误修正我在做的时候出现一个问题。查看Celery日志celery -A RealEarthStudio worker --loglevelinfo报错[2025-12-17 11:55:37,580: ERROR/MainProcess] Task handler raised error: ValueError(‘not enough values to unpack (expected 3, got 0)’)billiard.einfo.RemoteTraceback:Traceback (most recent call last):File “D:\ProgramData\anaconda3\envs\realearthstudio_env\Lib\site-packages\billiard\pool.py”, line 362, in workloopresult (True, prepare_result(fun(*args, **kwargs)))^^^^^^^^^^^^^^^^^^^^File “D:\ProgramData\anaconda3\envs\realearthstudio_env\Lib\site-packages\celery\app\trace.py”, line 683, in fast_trace_tasktasks, accept, hostname _loc^^^^^^^^^^^^^^^^^^^^^^^ValueError: not enough values to unpack (expected 3, got 0)The above exception was the direct cause of the following exception:Traceback (most recent call last):File “D:\ProgramData\anaconda3\envs\realearthstudio_env\Lib\site-packages\billiard\pool.py”, line 362, in workloopresult (True, prepare_result(fun(*args, **kwargs)))^^^^^^^^^^^^^^^^^^^^File “D:\ProgramData\anaconda3\envs\realearthstudio_env\Lib\site-packages\celery\app\trace.py”, line 683, in fast_trace_tasktasks, accept, hostname _loc^^^^^^^^^^^^^^^^^^^^^^^ValueError: not enough values to unpack (expected 3, got 0)这个报错点在celery/app/trace.py的fast_trace_task在 Windows 上非常常见本质通常不是你任务函数写错了而是 Celery 在 Windows 的多进程billiard/prefork兼容性问题导致 worker 内部的局部变量_loc没有被正确初始化于是解包失败。Celery 官方文档也明确提到不支持 Microsoft Windows。解决方案Windows 下用solo池跑 worker在settings.py中添加CELERY_WORKER_POOLsolo即可正常运行。