我正在使用Binance WebSocket API获取信息。我们已经有了主代码库，但决定在独立的应用程序中实现websockets。它看起来像这样：

import asyncio
from threading import Thread

import uvicorn
from fastapi import FastAPI

from binance import AsyncClient, BinanceSocketManager

app = FastAPI()

@app.get("/")
async def root():
    return "Websocket app"

async def main_socket_stream():
    client = await AsyncClient.create()
    binance_manager = BinanceSocketManager(client=client)
    multiplex_socket = binance_manager.futures_multiplex_socket(symbols)

    async with multiplex_socket as active_socket:
        while True:
            result = await active_socket.recv()
            print(result)
            # There are lots of further logic - proceed data, save something to db, etc.

def side_thread():
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    asyncio.run(main_socket_stream())

if __name__ == "__main__":
    thread = Thread(target=side_thread, args=(), daemon=True)
    thread.start()
    uvicorn.run(app, port=5105)

我删除了一些不必要的部分，但主要的想法是明确的。所以，我有WebSocket在后台-它的工作。但我想从主应用程序控制它们的能力（基于Django）.
我想到了这样的事情：

async with multiplex_socket as active_socket:
    while True:
        if await EventListenerClass.new_event_fired():
            break  # or do something special
        result = await active_socket.recv()
        print(result)

我想用Redis的Pub-Sub做一个“EventList”类，在channel中监听新消息。将有几种类型的消息，例如：“stop_WebSocket”、“reload_with_updated_symbols_list”等。
我需要一个解决方案：

• 每隔几秒钟就能工作
• 这将给予我控制websockets的机会

我对Redis的看法是正确的吗？