Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Consideremos este ejemplo de código: myfd = … # mi fd, puede ser un socket por ejemplo def reader(): data = myfd.recv(100) print(“Recibido:”, data.decode()) asyncio.get_event_loop().loop.add_reader(myfd, reader) asyncio.get_event_loop().run_forever() Mi problema es la parte de asyncio.get_event_loop().run_forever(). Me gustaría hacer un await en el evento de cierre de myfd en su lugar.
En el nuevo marco de trabajo asyncio, ¿Cómo escribo un equivalente async de sustitución para subprocess.check_output para capturar la salida completa de una ejecución de proceso?
Mientras se intenta desarrollar un cliente FastAPI en el entorno Spyder, no se puede iniciar la ejecución. El código falla y arroja: RuntimeError: asyncio.run() no puede ser llamado desde un ciclo de eventos en ejecución. Código mínimo a ser ejecutado: from fastapi import FastAPI import uvicorn app = FastAPI() @app.get(“/”) . . . Read more
PyLance muestra el mensaje “El código no se puede alcanzar” para el uso de Websocket en BinanceSocketManager ¿Es esto un error o el código realmente no funciona? async def main(coin): bm = BinanceSocketManager(client) ts = bm.trade_socket(coin) async with ts as tscm: while True: res = await tscm.recv() if res: frame . . . Read more
Lo siento por cualquier error en inglés… Básicamente, tengo una lista que contiene mensajes y sus destinos: messages = [(id_1, msg_1), (id_2, msg_2), (id_3, msg_3),] Lo que quiero es usar un bucle asíncrono: async for msg in messages, sin embargo, mi lista, obviamente, no es iterable de forma asíncrona (estoy . . . Read more