需要的依赖包

grpcio
googleapis-common-protos

首先需要根据proto 文件生成代码

proto 示例代码

syntax = "proto3";

service MsgService {
 rpc GetMsg (MsgRequest) returns (MsgResponse){}
}

message MsgRequest {
  string name = 1;
}

message MsgResponse {
  string msg = 1;
}

根据proto 生成py代码

python -m grpc_tools.protoc -I . --python_out=. --grpc_python_out=. msg.proto

server 端代码示例

import grpc
from grpc_demo import msg_pb2
from grpc_demo import msg_pb2_grpc

from concurrent import futures
import time

_ONE_DAY_IN_SECONDS = 60 * 60 * 24


class MsgServicer(msg_pb2_grpc.MsgServiceServicer):

    def GetMsg(self, request, context):
        print("Received name: %s" % request.name)
        return msg_pb2.MsgResponse(msg='Hello, %s!' % request.name)


def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    msg_pb2_grpc.add_MsgServiceServicer_to_server(MsgServicer(), server)
    server.add_insecure_port('[::]:50051')
    server.start()
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        server.stop(0)


if __name__ == '__main__':
    serve()

客户端代码示例

import grpc
from grpc_demo import msg_pb2, msg_pb2_grpc

_HOST = 'localhost'
_PORT = '8080'


def run():
    # NOTE(gRPC Python Team): .close() is possible on a channel and should be
    # used in circumstances in which the with statement does not fit the needs
    # of the code.
    with grpc.insecure_channel('localhost:50051') as channel:
        stub = msg_pb2_grpc.MsgServiceStub(channel)
        response = stub.GetMsg(msg_pb2.MsgRequest(name='world'))
    print("Client received: " + response.msg)


if __name__ == '__main__':
    run()

proto 中 repeated 对象的属性是列表 

py接收到数据的时候需要遍历获取内容

 请求的参数中某个某个字段如下

google.protobuf.Timestamp after = 3;

时间类型的数据转换

from google.protobuf.timestamp_pb2 import Timestamp
after = "000-00-00T00:00:00"
befer = "000-00-00T00:00:00"
timestamp_message_after = Timestamp()
timestamp_message_befer = Timestamp()
timestamp_message_after.FromJsonString(after)
timestamp_message_befer.FromJsonString(befer)