代码如下，consumer_task任务，是websocket持续接收数据，存入缓冲区；producer_task 任务，是取出缓冲区数据，处理后返回给前端。

问题现象：接收的数据延迟越来越大。
请问怎么排查？

async def handler(websocket, path):
    register(websocket)
    try:
        consumer_task = asyncio.ensure_future(
            consumer_handler(websocket, path)
        )
        producer_task = asyncio.ensure_future(
            producer_handler(websocket, path)
        )
        done, pending = await asyncio.wait(
            [consumer_task, producer_task],
            return_when=asyncio.FIRST_COMPLETED,
        )
        for task in pending:
            task.cancel()
    finally:
        unregister(websocket)
        logger.info("unregister:{}".format(websocket))
--
FROM 114.249.118.*