Estoy usando WebSockets y FastAPI para enviar dos tipos diferentes de datos a mi interfaz: datos de lecturas de presión/temperatura y datos de video de una cámara.

¿Hay alguna forma en Python de crear un bucle de eventos de modo que si el primer generador todavía está esperando una respuesta, se saltará una sección del código y pasará al siguiente generador? Esencialmente, los datos de video son básicamente en tiempo real. Podemos enviar un marco tantas veces como queramos. Pero los datos de temperatura/presión vienen cada 10 segundos o cada 5 segundos. Aquí hay un ejemplo de lo que me gustaría:

 @app.websocket("/ws") async def websocket_endpoint(websocket: WebSocket): await websocket.accept() await websocket.send_json({"text": "testing"}) iter_one = get_rtd() #this is the temp/pressure data iter_two = get_frame() #this is the video feed while True: await asyncio.sleep(0.1) if waiting_for_response(iter_one): payload = next(iter_two) await websocket.send_json({"type": "video", "payload": payload}) else: payload = next(iter_one) await websocket.send_json({"type": "rtd", "payload": payload})

Los generadores de mi solución actual no son asíncronos. Mi solución actual es tener dos puntos finales de websocket diferentes, uno para los datos de temperatura/presión y el otro para video. Tengo mi bucle de temperatura/presión esperando 4,5 segundos, por lo que se bloquea mientras se envían los datos de la cámara. No es ideal porque los datos de la cámara luego se congelan una vez que el ciclo de temperatura/presión se desbloquea y la transmisión de video en vivo se retrasa cada vez más.