Python asyncio gRPC client

asyncio_grpc_client.py

import asyncio
import grpc
from recommender_pb2_grpc import RecommenderStub
from recommender_pb2 import RecommendRequest


async def run() -> None:
    async with grpc.aio.insecure_channel('localhost:50051') as channel:
        client = RecommenderStub(channel)

        request = RecommendRequest()
        request.tmdb_ids.extend([
            44214,  # Black Swan
            641,  # Requiem for a Dream
        ])

        response = await client.Recommend(request)
        print(response.recommendations)


if __name__ == '__main__':
    asyncio.run(run())