Django

Question

提前致谢

我正在尝试启动一个 Celery Worker 以使用 Channels 接受 WebConnections - 但是当我的 worker 启动时它似乎无法找到频道。当我安装 pip 列表频道时

settings.py 有频道

INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'channels','

tasks.py

from __future__ import absolute_import, unicode_literals
import os
import threading
from merlin.celery import app, get_blender
from django.conf import settings
from celery import shared_task
from channels import Channel

@app.task(bind=True, track_started=True)
def render(task, data, reply_channel):
    bpy = get_blender()
    setup_scene(bpy, data)

context = {'rendering': True, 'filepath': os.path.join(settings.BLENDER_RENDER_TMP_DIR, task.request.id)}
sync_thread = threading.Thread(target=sync_render, args=(bpy, context, reply_channel))
sync_thread.start()
bpy.ops.render.render()
context['rendering'] = False
sync_thread.join()

if os.path.exists(context['filepath']):
    os.remove(context['filepath'])

if reply_channel is not None:
    Channel(reply_channel).send({
        'text': json.dumps({
            'action': 'render_finished'
        })
    })'

我得到的错误-

from channels import Channel
ImportError: cannot import name 'Channel' from 'channels' 
(/usr/local/lib/python3.8/dist-packages/channels/__init__.py)

再次感谢您

Answer 1

See the documentation for using channel layers outside of consumers

from asgiref.sync import async_to_sync
from channels.layers import get_channel_layer
channel_layer = get_channel_layer()

@app.task(bind=True, track_started=True)
def render(task, data, reply_channel):
    ...
    async_to_sync(channel_layer.send)(reply_channel, {
        'type': 'this_is_required',
        'text': json.dumps({
            'action': 'render_finished'
        })
    })

You may want to consider using channel workers and background tasks

Django - Celery Worker - 频道

Django - Celery Worker - Channels

python

celery

worker

channels