Django-芹菜工人-频道

Question

提前感谢

我正试图启动一个Celery Worker来接受WebConnections usng通道，但当我的工作程序启动时，它似乎找不到通道。当I 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

请参阅有关在消费者之外使用通道层的文档

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'
})
})

您可能需要考虑使用通道工作者和后台任务