您的位置:澳门新葡8455最新网站 > 编程教学 > python调用RPC接口

python调用RPC接口

发布时间:2019-11-06 06:58编辑:编程教学浏览(137)

    要调用RPC接口,python提供了四个框架grpc,那是google开源的

    gRPC 简介:

    gRPC 是意气风发款高品质、开源的 RPC 框架,产自 谷歌,基于 ProtoBuf 类别化协议进行付出,协助两种语言(Golang、Python、Java等卡塔 尔(阿拉伯语:قطر‎,本篇只介绍 Python 的 gRPC 使用。因为 gRPC 对 HTTP/2 公约的辅助使其在 Android、IOS 等客商端后端服务的支出世界有着卓绝的前途。gRPC 提供了生龙活虎种轻便的措施来定义服务,相同的时间顾客端能够充足利用 HTTP/2 stream 的特性,进而助长节省带宽、减少 TCP 的连天次数、节省CPU的选择等。

    rpc相关文书档案:

    安装:

    1. gRPC 的安装:

    $ pip install grpcio

    1. 安装 ProtoBuf 相关的 python 依赖库:

    $ pip install protobuf

    1. 安装 python grpc 的 protobuf 编写翻译工具:

    $ pip install grpcio-tools

    https://grpc.io/docs/tutorials/basic/python.html

    实践:

    上面大家使用 gRPC 定义二个接口,该接口完结对传播的数额开展大写的格式化处理。

    • 始建项目 python demo 工程:
    ![](https://upload-images.jianshu.io/upload_images/208550-bd34d08e0c12cdeb.png)
    
    Paste_Image.png
    
    1. client目录下的 main.py 实现了客商端用于发送数据并打字与印刷选择到 server 端管理后的数额
    1. server 目录下的 main.py 完成了 server 端用于收纳客商端发送的数目,并对数据开展大写管理后回来给客商端
    2. example 包用于编写 proto 文件并生成 data 接口
    • 定义 gRPC 接口:
    syntax = "proto3";
    package example;
    service FormatData {
      rpc DoFormat(Data) returns (Data){}
    }
    message Data {
      string text = 1;
    }
    
    • 编译 protobuf:

    $ python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. ./data.proto #在 example 目录中实行编写翻译,会变卦:data_pb2.py 与 data_pb2_grpc.py

    • 实现 server 端:
    #! /usr/bin/env python
    # -*- coding: utf-8 -*-
    import grpc
    import time
    from concurrent import futures
    from example import data_pb2, data_pb2_grpc
    
    _ONE_DAY_IN_SECONDS = 60 * 60 * 24
    _HOST = 'localhost'
    _PORT = '8080'
    
    class FormatData(data_pb2_grpc.FormatDataServicer):
        def DoFormat(self, request, context):
            str = request.text
            return data_pb2.Data(text=str.upper())
    
    def serve():
        grpcServer = grpc.server(futures.ThreadPoolExecutor(max_workers=4))
        data_pb2_grpc.add_FormatDataServicer_to_server(FormatData(), grpcServer)
        grpcServer.add_insecure_port(_HOST + ':' + _PORT)
        grpcServer.start()
        try:
            while True:
                time.sleep(_ONE_DAY_IN_SECONDS)
        except KeyboardInterrupt:
            grpcServer.stop(0)
    
    if __name__ == '__main__':
        serve()
    
    • 实现 client 端:
    #! /usr/bin/env python
    # -*- coding: utf-8 -*-
    import grpc
    from example import data_pb2, data_pb2_grpc
    
    _HOST = 'localhost'
    _PORT = '8080'
    
    def run():
        conn = grpc.insecure_channel(_HOST + ':' + _PORT)
        client = data_pb2_grpc.FormatDataStub(channel=conn)
        response = client.DoFormat(data_pb2.Data(text='hello,world!'))
        print("received: " + response.text)
    
    if __name__ == '__main__':
        run()
    
    • 试行验证结果:
    1. 先运转 server,之后再试行 client
    1. client 侧调整台假如打印的结果为:“received: HELLO,WOCR-VLD!” ,申明gRPC 接口定义成功

    • 沟通能够加 QQ 群:397234385
    • 要么 QQ 扫码入群:

    澳门新葡萄京娱乐场 1

    qq群.jpg

    澳门新葡萄京娱乐场, 

    内需设置的python包如下:

    1.grpc安装

    pip install grpcio

     

    2.grpc的python protobuf相关的编写翻译工具

    pip install grpcio-tools

     

    3.protobuf相关python依赖库

    pip install protobuf

     

    4.片段分布原型的生成python类的集纳:

    pip install googleapis-common-protos

     

     

    编写翻译protobuf文件:使用以下命令生成Python代码:

    python3 -m grpc_tools.protoc -I<指标路线目录> --python_out=. --grpc_python_out=<指标文件所在目录路线> <目标文件data.proto>

    python3 -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. data.proto

     

     

    注意:protobuf文件,为定义服务接口代码文件,这里是data.proto

    会生成:data_pb2.py 与 data_pb2_grpc.py

    data_pb2.py是劳动接口映射

    data_pb2_grpc.py方法映射

     

    protobuf内容示例:

    syntax = "proto3";
    package grpcDemo;
    
    message HelloRequest {
       string name = 1;
    }
    
    message HelloReply {
       string message = 1;
    }
    
    
    service gRPC {
      rpc SayHello (HelloRequest) returns (HelloReply) {}
    }
    

    接口调用内容示例:

    # -*- coding: utf-8 -*-
    import grpc
    import data_pb2,data_pb2_grpc
    
    _HOST = 'localhost'
    _PORT = '8080'
    
    def run():
        conn = grpc.insecure_channel(_HOST + ':' + _PORT)
        client = data_pb2_grpc.gRPCStub(channel=conn)
        response = client.SayHello(data_pb2.HelloRequest(name='hello,world!'))
        print("received: " + response.text)
    
    if __name__ == '__main__':
        run()
    

     

     

     

     

    本文由澳门新葡8455最新网站发布于编程教学,转载请注明出处:python调用RPC接口

    关键词: