Django channels views.pyから特定roomにwebsocket送信

Question

お世話になります。

質問は表題の通り、views.pyから特定ルームへメッセージを送信する方法です。

昨日からchannelsを触りはじめたため、ドキュメントもどこを読めばいいのかよくわかりません。
チュートリアルは終えたため基本的なところはできます。

試したコード

# consumer.py
class ChatConsumer(WebsocketConsumer):
　　　•
　　　•
　　　•
　def receive_view(self, roomname):
        # Send message to room group
            async_to_sync(self.channel_layer.group_send)(
            roomname,
            {
                'type': 'chat_message',
                'message': “template message”
            }
        )
　def send_temp_message(self, event):
         message = event['message']
         self.send(text_data=json.dumps({
            'message': message
         }))

# views.py
from .consumer import ChatConsumer
　　　•
　　　•
　　　•
ChatConsumer.recieve(roomname)

Internal Server Error: /chat/send/test
Traceback (most recent call last):
  File "/usr/local/lib/python3.8/dist-packages/asgiref/sync.py", line 339, in thread_handler
    raise exc_info[1]
  File "/usr/local/lib/python3.8/dist-packages/django/core/handlers/exception.py", line 38, in inner
    response = await get_response(request)
  File "/usr/local/lib/python3.8/dist-packages/django/core/handlers/base.py", line 233, in _get_response_async
    response = await wrapped_callback(request, *callback_args, **callback_kwargs)
  File "/usr/local/lib/python3.8/dist-packages/asgiref/sync.py", line 304, in __call__
    ret = await asyncio.wait_for(future, timeout=None)
  File "/usr/lib/python3.8/asyncio/tasks.py", line 455, in wait_for
    return await fut
  File "/usr/lib/python3.8/concurrent/futures/thread.py", line 57, in run
    result = self.fn(*self.args, **self.kwargs)
  File "/usr/local/lib/python3.8/dist-packages/asgiref/sync.py", line 343, in thread_handler
    return func(*args, **kwargs)
  File "/channels-test/mysite/chat/views.py", line 15, in send
    ChatConsumer.send_notification()

どなたか詳しい方、回答よろしくお願いいたします。

Comments

[y_waiwai]

エラーが出たなら、エラーメッセージを提示しましょう
エラーメッセージは、いらぬ翻訳省略しないで、出たそのママをコピペで提示してください

Answer 1

一応非同期にしました。

## consumer.py

import json
from asgiref.sync import async_to_sync
from channels.generic.websocket import AsyncWebsocketConsumer

class ChatConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.room_name = self.scope['url_route']['kwargs']['room_name']
        self.room_group_name = 'chat_%s' % self.room_name

        # Join room group
        await self.channel_layer.group_add(
            self.room_group_name,
            self.channel_name
        )

        await self.accept()

    async def disconnect(self, close_code):
        # Leave room group
        await self.channel_layer.group_discard(
            self.room_group_name,
            self.channel_name
        )

    # Receive message from WebSocket
    async def receive(self, text_data):
        text_data_json = json.loads(text_data)
        message = text_data_json['message']

        # Send message to room group
        await self.channel_layer.group_send(
            self.room_group_name,
            {
                'type': 'chat_message',
                'message': message
            }
        )

    # Receive message from room group
    async def chat_message(self, event):
        message = event['message']

        # Send message to WebSocket
        await self.send(text_data=json.dumps({
            'message': message
        }))

    async def view_noti(self, event):
        print ("2")
        message = event['message']

        # Send message to WebSocket
        await self.send(text_data=json.dumps({
            'message': message
        }))

---

# views.py

from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync

def send(request):
    channel_layer = get_channel_layer()
    async_to_sync(channel_layer.group_send)("chat_aaa", { 
        "type": "view_noti",
        "message": "viewから送信試験"
    })
    return HttpResponse("OK")

aaaというルーム名で作成した場合、consumerでchat_が追加されていたのでchat_aaaとなります。