Call gRPC from AIOHTTP?

[brandomr]

This is more of a question really--is it possible to call the gRPC command from within a web request?

For example, I'd like the webview to look like:

    async def get(self) -> web.Response:
        channel = grpc.insecure_channel('0.0.0.0:50051')
        hello_world_stub = HelloWorldServiceStub(channel)
        print("Reaching out to gRPC now...")
        name = "SOME NAME"
        request = HelloRequest()
        request.name = name
        response = hello_world_stub.Hello(request)
        print(response.message)
        return web.Response(text=response.message)

But this endpoint then just hangs. Any suggestions?

[wlwanpan]

Hey @brandomr the hanging issue is due to not using the proper grpc adapter for AIO:

    async def get(self) -> web.Response:
        channel = grpc.aio.insecure_channel('localhost:50051') # Note grpc.aio
        hello_world_stub = HelloWorldServiceStub(channel)
        print("Reaching out to gRPC now...")
        name = "SOME NAME"
        request = HelloRequest()
        request.name = name
        response = await hello_world_stub.Hello(request) # Dont forget to await
        return web.Response(text=response.message)

Hope that works for you now, feel free to reopen if not.

[brandomr]

Thanks, this is helpful and generally speaking your post/repo got me on the right track. Much appreciated!