grpc-resolver

A simple Python gRPC service registry and resolver, is compatible for Python 2 and 3.

Now it only supports Etcd as configuration storage backend, but actually can support any storage backend.

Requirements

• grpcio
• etcd3

Install

$ pip install git+https://github.com/justdoit0823/grpc-resolver

How to use

Here we go:

Service Resolve

>>> from grpcresolver import EtcdServiceResolver, RoundrobinChannel

>>> import hello_pb2

>>> import hello_pb2_grpc

>>> resolver = EtcdServiceResolver(etcd_host='10.30.141.251', etcd_port=2376)

>>> channel = RoundrobinChannel('your_service_name', resolver)

>>> stub = hello_pb2_grpc.HelloStub(channel)

>>> # do gRPC call as usual

Service Registry

>>> from grpcresolver import EtcdServiceRegistry

>>> registry = EtcdServiceResolver(etcd_host='10.30.33.11', etcd_port=2376)

>>> registry.register(('your_grpc_service',), '192.168.10.20:11111', 360)

How it works

The grpcresolver.channel.LbChannel has implemented unary_unary, unary_stream, stream_unary and stream_stream four gRPC operations, but without subscribe and unsubscribe.

Meanwhile, also implementing the relative multi-callable operations.

When calling gRPC service method, the channel will return a grpcresolver.channel.Channel object from it's local cache or create a new one after resolving from it's resolver.

Features

• Easy to integrate while using standard Python gRPC channel
• Supporting gRPC service discovery with random and roundrobin algorithms
• Automatic etcd node selection and retry when etcd client gRPC request failed