Hola a todos: Sin conocer mucho de GPRC, parece que no estás usando precisamente la nueva AsyncIO API del GRPC para que te funcione asyncio.
Revisa la documentación en https://grpc.github.io/grpc/python/grpc_asyncio.html Saludos. El sáb, 19 mar 2022 a las 16:22, Miguel de Dios Matias (< tres.14...@gmail.com>) escribió: > Buenas. > > Me estoy haciendo unos POC en python sobre GRPC porque un compa del > curro lo quiere meter. > > Y ya casi tengo (después de mucho sufrimiento...me da que no tiene > muchs comunidad y esta medio abandonado GRPC salvo en Golang) todos > los posibles formas de comunicación. > > Pero me queda la que el request sea un stream, bueno a medias, porque > sincrona (que se quede clavado el client.py enviando mensajes si) pero > asyncrona, naranjas de la china. > > Mi último intento fallido es: > > test.proto > --------------------------------------------------------- > syntax = "proto3"; > > message Saludo { > string nombre = 1; > int32 segundo = 2; > } > message Respuesta { > string frase = 1; > int32 segundo = 2; > } > service Saluda { > // Sends a greeting > rpc buenosdias (stream Saludo) returns (stream Respuesta) {} > } > ----------------------------------------------------- > > client.py > ------------------------------------------------------- > import grpc > from concurrent import futures > > # Generate pb2 and bp2_grpc generated python files > # python3 -m grpc_tools.protoc --proto_path=. --python_out=. > --grpc_python_out=. ./*.proto > > import test_service_pb2_grpc > import test_pb2 > > from datetime import datetime > from time import sleep > > import asyncio > from uuid import uuid4 > > class MyIterator: > def __init__(self, start=0): > self.num = start > > def __iter__(self): > return self > > def __next__(self): > sleep(2) > nombre = uuid4() > print(nombre) > return test_pb2.Saludo(nombre=f'{nombre}', > segundo=datetime.now().second) > > > class AsyncIterator: > def __aiter__(self): > return self > > async def __anext__(self): > await asyncio.sleep(2) > nombre = uuid4() > print(nombre) > return test_pb2.Saludo(nombre=f'{nombre}', > segundo=datetime.now().second) > > > if __name__ == '__main__': > print("TEST CLIENT GRPC") > > server_uri = 'localhost:50053' > print(f"CONNECT TO: {server_uri}") > with grpc.insecure_channel(server_uri) as channel: > stub = test_service_pb2_grpc.SaludaStub(channel) > # ~ saludo = test_pb2.Saludo(nombre=f'{uuid4()}', > segundo=datetime.now().second) > # ~ stream_connection = stub.buenosdias(iter((saludo,saludo))) > stream_connection = stub.buenosdias(MyIterator()) > for response in stream_connection: > response_dict = {k.name: getattr(response, k.name) for k > in response.DESCRIPTOR.fields} > print(f"CLIENTE RECEIVED: {response_dict}") > > -------------------------------------------------------------------------------------- > > Con un iterador "sincrono" funciona pero se queda o llamando con un > iterador de 1 elemento puest también y solo se clava 1 vez pero si > meto: > stream_connection = stub.buenosdias(AsyncIterator()) > > Falla. > > Saludos. > _______________________________________________ > Python-es mailing list > Python-es@python.org > https://mail.python.org/mailman/listinfo/python-es > -- Hyperreals *R "Quarks, bits y otras criaturas infinitesimales": https://blog.ch3m4.org Buscador Python Hispano: http://busca.ch3m4.org <https://blog.ch3m4.org/pages/busqueda-python-es/>
_______________________________________________ Python-es mailing list Python-es@python.org https://mail.python.org/mailman/listinfo/python-es
