1回答

Jack

2020-03-21

您好，推送到前端是你的后台和前端之间websocket通信。后台回调第三方数据，不管是HTTP Restful API获取还是websocket实时获取，都需要有一个事件循环，后台获取到数据之后立即在async def receive函数中调用await self.send方法。循环可以使用asyncio实现

import json
import asyncio
from channels.generic.websocket import AsyncWebsocketConsumer


class SampleConsumer(AsyncWebsocketConsumer):

   async def connect(self):
       """建立连接"""
       await self.close() if self.scope['user'].is_anonymous else await self.accept()

   async def receive(self, text_data=None, bytes_data=None):
       """将接收到的消息返回给前端"""

       while True:
           await asyncio.sleep(1)
           obj = "COVID-19"  # 回调第三方数据，可以直接写在这里；需要处理的话，可通过回调函数的方式实现
           await self.send(text_data=json.dumps(obj))

   async def disconnect(self, code):
       """断开连接"""
       await self.close()

0

0