Django 通道中的类型错误

Question

我试图在我的 Django 应用程序中从客户端发送数据，但我一直收到此错误并且套接字断开连接。我不知道为什么会这样，这是错误：

Exception inside application: receive() got an unexpected keyword argument 'text_data'
Traceback (most recent call last):
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/staticfiles.py", line 44, in __call__
    return await self.application(scope, receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/routing.py", line 71, in __call__
    return await application(scope, receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/sessions.py", line 47, in __call__
    return await self.inner(dict(scope, cookies=cookies), receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/sessions.py", line 254, in __call__
    return await self.inner(wrapper.scope, receive, wrapper.send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/auth.py", line 181, in __call__
    return await super().__call__(scope, receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/middleware.py", line 26, in __call__
    return await self.inner(scope, receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/routing.py", line 160, in __call__
    send,
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/consumer.py", line 94, in app
    return await consumer(scope, receive, send)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/consumer.py", line 59, in __call__
    [receive, self.channel_receive], self.dispatch
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/utils.py", line 51, in await_many_dispatch
    await dispatch(result)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/consumer.py", line 73, in dispatch
    await handler(message)
  File "/Users/MichaelAjanaku/Desktop/Kitchen-Order/order/lib/python3.6/site-packages/channels/generic/websocket.py", line 196, in websocket_receive
    await self.receive(text_data=message["text"])
TypeError: receive() got an unexpected keyword argument 'text_data'
WebSocket DISCONNECT /ws/orders/ [127.0.0.1:49984]

这是consumers.py:

import json
from .models import Order
from channels.db import database_sync_to_async
from channels.generic.websocket import AsyncWebsocketConsumer

class WSConsumer(AsyncWebsocketConsumer):
    
    @database_sync_to_async
    def _get_order_info(self, number):
        order = Order.objects.get(order_number = number)
        return order

  
    async def connect(self):
        self.groupname = 'kitchen'
        await self.channel_layer.group_add(
                    self.groupname,
                    self.channel_name,
                )      
        await self.accept()

   
    async def disconnect(self, code):
        await self.channel_layer.group_discard(
            self.groupname,
            self.channel_name,
        )
        await super().disconnect(code)



    async def take_order(self, event):
        number = event['number']
        details = event['details']
        info = await self._get_order_info(number)
        time_taken = info.order_date_time
        taken_by = info.taken_by
        fulfilled = info.is_fulfilled
        fulfilled_by = info.fulfilled_by

        await self.send(order_data=json.dumps({   
    
                'number' : number,
                'details' : details,
                'time_taken' : time_taken,
                'taken_by' : taken_by,
                'fulfilled' : fulfilled,
                'fulfilled_by' : fulfilled_by,        }))

    async def receive(self, order_data):
        order_data_json = json.loads(order_data)
        number = order_data_json['number']
        details = order_data_json['details']
        time_taken = order_data_json['time_taken']
        taken_by = order_data_json['taken_by']
        fulfilled = order_data_json['fulfilled']
        fulfilled_by = order_data_json['fulfilled_by']

        await self.channel_layer.group_send(
            self.groupname,
            {   
                'type': 'take_order',
                'number' : number,
                'details' : details,
                'time_taken' : time_taken,
                'taken_by' : taken_by,
                'fulfilled' : fulfilled,
                'fulfilled_by' : fulfilled_by,   
            }
        )

模板中的 Javascript 代码如下：

var ws_url = 'ws://' + window.location.host + '/ws/orders/';
    var orderSocket = new WebSocket(ws_url);
    document.querySelector('#submit').onclick = function(e) {
        const numberInputDom = document.querySelector('#id_order_number');
        const detailsInputDom = document.querySelector('#id_order_details');
        const number = numberInputDom.value;
        const details = detailsInputDom.value;
        orderSocket.send(JSON.stringify({
            'number': number,
            'details' : details,
        }));
        console.log('data sent')
       
    };

为什么我会收到该特定错误？我一直在和它战斗一整天。

Answer 1

这是因为函数是用关键字参数 text_data 调用的，您将其命名为 order_data。

您需要重命名参数才能使其正常工作。

async def receive(self, text_data):
    order_data_json = json.loads(text_data)
    # Rest of the code ...

Django 通道中的类型错误

Typeerror in Django-Channels

python

django

websocket

django-channels