Как объединить каналы и DRF вместе - PullRequest
Новая
       27

Как объединить каналы и DRF вместе

0 голосов
/ 24 января 2019

В настоящее время я пытаюсь создать внутренний сервер для связи с некоторыми клиентами с помощью веб-сокета.Клиент делает некоторый запрос к бэкэнду, а бэкэнд отвечает напрямую клиенту через потребителя.

Кроме того, у меня есть API, который должен отправлять некоторые запросы клиенту.Он должен пройти через открытую розетку потребителя.Я использую Django Rest Framework для API.Итак, у меня есть 2 приложения на данный момент.Один для потребителя и один для API.Я хочу знать, правильный ли это путь или нет.

Это на самом деле код, о котором я сейчас думаю: 

# mybackendapp/consumers.py

class MyConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.client_id = self.scope['url_route']['kwargs']['client_id']
        # This line I don't get it very well. It comes from:
        # [channels doc: single channels][1]
        # I don't know if I should create the Clients myself or if it's 
        # created automatically
        Clients.objects.create(channel_name=self.channel_name, 
                               self.client_id)
        self.accept()

    async def disconnect(self):
         Clients.objects.filter(channel_name=self.channel_name).delete()

    async def receive(self, text_data):
        self.recv_data = json.loads(text_data)
        if self.recv_data[0] == CLIENT_REQUEST:
            self.handler = ClientRequestHandler(self.client_id, 
                                                self.recv_data)
            await self.handler.run()
            self.sent_data = self.handler.response
            self.send(self.sent_data)
        elif self.recv_data[0] == CLIENT_RESPONSE:
            self.handler = ClientResponseHandler(self.client_id,
                                                 self.recv_data)
            channel_layer = get_channel_layer()
            # Here I'm not sure but I may have several API requests so
            # several row with the same client_id.
            # I welcome info on how to deal with that.
            api_channel_name = self.another_handler.ext_channel_name
            channel_layer.send(api_channel_name, {
                "text_data": self.handler.response,
            })

    async def message_from_api(self, event):
        self.api_channel_name = event['channel_name_answer']
        # this line is for hiding the fact that I'm only manipulating data
        # to send it to a correct format to the socket
        self.another_handler = ExternalDataHandler(event['json_data'])
        query_to_client = another_handler.get_formatted_query()
        self.send(query_to_client)

При получении этот потребитель по-разному обрабатывает сообщения отклиент в зависимости от того, инициирован ли он клиентом или остальным API.Вы можете видеть это с CLIENT_REQUEST и CLIENT_RESPONSE константами.Теперь из представления API: 

# myapi/views.py

from channels.layers import get_channel_layer

def my_api_view(request, client_id):
    channel_layer = get_channel_layer()
    if request.method == 'POST':
        ext_request_data_json = request.data
        client_channel_name = Clients.objects.get(
            client_id=client_id).channel_name
        # I don't know what type is listen_channel_name. I assume it's str
        listen_channel_name = async_to_sync(channels_layers.new_channel)()
        async_to_sync(channel_layer.send)(
            client_channel_name, {
                'type': 'message.from.api',
                'json_data': ext_request_data_json,
                'channel_name_answer': listen_channel_name
            }
        )
        received_msg = channel_layer.receive(listen_channel_name)

Я считаю, что этот код должен работать.Я хочу знать, если это правильный способ сделать это.

...