带有 Django 通道的恒定数据流

Question

我正在努力熟悉Django channels和web-sockets。我有一个任务 - 不断地向连接到频道的任何人流式传输数据。

目前，这是来自官方教程的一段代码，有一些改进。

class ChatConsumer(AsyncWebsocketConsumer):

    async def connect(self):

        self.room_name = self.scope['url_route']['kwargs']['room_name']

        self.room_group_name = f'chat_{self.room_name}'

        if not hasattr(self, 'vehicle'):

            # this produses constant data stream

            self.vehicle = connect('/dev/ttyACM0', wait_ready=True, rate=4)

        await self.channel_layer.group_add(

            self.room_group_name,

            self.channel_name

        )

        await self.accept()

        # this part does not work!

        await self.send(text_data=json.dumps({

            'message': {

                        'mess': "Hi",

                        'yaw': self.vehicle._yaw,

                        'pitch': self.vehicle._pitch,

                        'roll': self.vehicle._roll,

                       }

        }))

    async def disconnect(self, close_code):

        # Leave room group

        await self.channel_layer.group_discard(

            self.room_group_name,

            self.channel_name

        )

但是现在这段代码断开连接，前面没有显示任何内容。我找到了这个答案，但那个循环也不起作用。

如果我将 while 循环移动到单独的方法并从receive方法中调用它（我现在不会在这里简短地展示） - 它可以工作，但是当新用户进入频道时，他看不到来自while 循环。但是在重新启动循环后，消息会发送给所有用户。

如何让所有用户在任何时候进入频道时都可以使用数据流？