asyncio wrapper for grpc.io. Currently, only client-side interfaces are supported.
aiogrpc has exactly the same interface as grpc.io (https://grpc.io/grpc/python/grpc.html#module-grpc), except:
call_soon_threadsafe()to run in the same thread with the event loop
__call__for unary methods,
details(), ...) become coroutines
Compile your proto file with protoc to generate stub files
Use the stub files with aiogrpc.Channel, instead of grpc.Channel:
from aiogrpc import insecure_channel import asyncio from mystub import MyStub channel = insecure_channel('ipv4:///127.0.0.1:8080') mystub = MyStub(channel) async def test_call(): return await mystub.mymethod(...) async def test_call_stream(): async for v in mystub.my_stream_method(...): ...
Same as the original grpc.io, balancing (fail over) between multiple servers are supported:
Use multiple IPv4 or IPv6 addresses for balancing - use target like:
Specify ONE DNS name which resolves to multiple addresses. GRPC will balance between the resolved addresses, and try
to update the resolving result in interval. Example:
Notice that you cannot mix up IPv4, IPv6 and DNS addresses; only addresses with the same type can be balanced. Also, when using DNS target, only one DNS name can be specified.
The default load balancing strategy is
"pick_first" (fail-over). Set
"grpc.lb_policy_name" option to
round-robin load balancing:
channel = insecure_channel('ipv4:///188.8.131.52:9999,184.108.40.206:9999,220.127.116.11:9999', [('grpc.lb_policy_name', 'round_robin')])
All code are published under Apache 2.0 License
Some code and docstrings are modified from grpc.io (https://grpc.io/grpc/python/grpc.html#module-grpc)