Каналы Django: почему пропускается channel_layer.gruop_send? - PullRequest
Новая
       20

Каналы Django: почему пропускается channel_layer.gruop_send?

0 голосов
/ 08 мая 2019

Я пытаюсь отправить сообщение через websocket в django-channgels, используя channel-layer , но оно пропускается и даже не показывает никаких исключений или ошибок.

Я пыталсячтобы заставить его работать даже без асинхронного и асинхронного, но ни один не работает. 

class stock_consumer(AsyncWebsocketConsumer):

   channel_layer = get_channel_layer()

   async def websocket_connect(self, event):
      await self.accept()
      await self.channel_layer.group_add("stock_group", self.channel_name)
      u = stock_market(api_key, access_token)    
      u.subscribe(u.get_instrument_by_symbol('NYSE', 'AAPL'))
      u.start_websocket(True)
      def quote_update(message):
         stock_consumer.send_message(self, message)
      u.set_on_quote_update(quote_update)

   async def websocket_receive(self, event):
      print(event)

   async def websocket_disconnect(self, message):
      await self.channel_layer.group_discard('stock_grogup', self.channel_name)
      await self.close()

   def send_message(self, message):
      print("before") //runs

      ***SKIPPED BLOCK START***
      self.channel_layer.group_send("stock_group", {
         "type": "send_message",
         "text": json.dumps(message)    
      })
      ***SKIPPED BLOCK END***

      print("after") //runs

1 Ответ

0 голосов
/ 08 мая 2019

В вашем примере send_message () - это синхронный метод.По умолчанию self.channel_layer.group_send является асинхронным методом.Поэтому вы должны использовать async_to_sync: 

from asgiref.sync import async_to_sync

# ....

   def send_message(self, message):
      print("before") //runs

      ***SKIPPED BLOCK START***
      async_to_sync(self.channel_layer.group_send)("stock_group", {
         "type": "send_message",
         "text": json.dumps(message)    
      })
      ***SKIPPED BLOCK END***

      print("after") //runs

Дополнительная информация: https://channels.readthedocs.io/en/latest/topics/channel_layers.html#synchronous-functions

...