Python RPC 之 gRPC彩民之家论坛9066777

2019-10-12 20:06 来源:未知

pip install protobuf

实践:

下边我们利用 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,WOWranglerLD!” ,注明gRPC 接口定义成功

  • 沟通能够加 QQ 群:397234385
  • 也许 QQ 扫码入群:

彩民之家论坛9066777 1

qq群.jpg

自家既想用django的model又想用grpc该怎么做呢,django是一个劳务,grpc是三个劳务,直接暴力把grpc代码插足django是无法使用models和views的。

# -*- 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()

gRPC 简介:

gRPC 是一款高品质、开源的 RPC 框架,产自 Google,基于 ProtoBuf 体系化公约举办支付,支持二种语言(Golang、Python、Java等),本篇只介绍 Python 的 gRPC 使用。因为 gRPC 对 HTTP/2 合同的支撑使其在 Android、IOS 等顾客端后端服务的支付领域有所卓越的前景。gRPC 提供了一种简易的措施来定义服务,同有时候客商端能够充足利用 HTTP/2 stream 的风味,进而助长节省带宽、减弱 TCP 的连年次数、节省CPU的利用等。

import os
from concurrent import futures

import grpc
import time

import bus_pb2
import bus_pb2_grpc

import django

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "xxx.settings")

django.setup()

from enterprise.views import enterprise_list, add_enterprise

_ONE_DAY_IN_SECONDS = 60 * 60 * 24


class Greeter(bus_pb2_grpc.BusInfoServicer):
    def BusMethod(self, request, context):
        if request.method == 'e':
            response = enterprise_list(request)
            return bus_pb2.BusReply(data=response['data'], code=response['code'], message=response['msg'])
        elif request.method == 'a':
            response = add_enterprise(request)
            return bus_pb2.BusReply(message=response['msg'])
        return bus_pb2.BusReply(message='')


if __name__ == '__main__':
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    bus_pb2_grpc.add_BusInfoServicer_to_server(Greeter(), server)
    server.add_insecure_port('0.0.0.0:50051')
    server.start()
    try:
        while True:
            time.sleep(_ONE_DAY_IN_SECONDS)
    except KeyboardInterrupt:
        server.stop(0)

4.局地大范围原型的生成python类的集聚:

安装:

  1. gRPC 的安装:

$ pip install grpcio

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

$ pip install protobuf

  1. 设置 python grpc 的 protobuf 编写翻译工具:

$ pip install grpcio-tools

初始尝试是在python脚本中与java对接接口,平时官方文书档案的一顿学习,成功调通了接口

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

此间解释一下,python(不解释) -m(也不表达) grpc_tools.protoc(上边安装的三方)
-I./protos(标记当前目录下的protos文件夹,xxx.proto须求在此个文件夹中) --python_out=.(当前目录生成输出文件) --grpc_python_out=.(当前目录生成grpc文件) ./protos/xxx.proto(xxx.proto的相对路径)

 

近些日子在做微服务这一块,后端与java协作,本身是python的,所以思索选择grpc,一点思量是grpc是http2.0,另一些记挂是那些供给的:)

syntax = "proto3";
package grpcDemo;

message HelloRequest {
   string name = 1;
}

message HelloReply {
   string message = 1;
}


service gRPC {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

运营时只须要周转该脚本就可以,django服务不必启用

 

焚林而猎办法就是在greeter_server.py中(这一个文件不清楚请看上边的链接)加载django,大概如下:

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

运维命令后会生成xxx_pb2.py 和 xxx_pb2_grpc.py多个文件,接下去重点来了(拍桌子)

data_pb2.py是劳动接口映射

https://grpc.io/docs/quickstart/python.html
唯独在教程里clone的百般项目实际是大,不明确哪些是须要的,经过测验后交由要求的:

会生成:data_pb2.py 与 data_pb2_grpc.py

python -m grpc_tools.protoc -I./protos --python_out=. --grpc_python_out=. ./protos/xxx.proto

protobuf内容示例:


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

在配置好grpc的xxx.proto之后要保管java那边的那一个文件要一律(而不是全部,service初步必要完全相同)

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

  • grpcio==1.4.0
  • grpcio-tools==1.4.0
  • xxx.proto 没有错,只须求如此叁个文本
  • 编译xxx.proto的命令

pip install grpcio-tools

1.grpc安装

亟需安装的python包如下:

 

pip install googleapis-common-protos

 

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

pip install grpcio

 

 

3.protobuf相关python依赖库

rpc相关文书档案:

 

 

 

Python RPC 之 gRPC彩民之家论坛9066777。 

接口调用内容示例:

 

 

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

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

data_pb2_grpc.py方法映射

 

版权声明:本文由彩民之家高手论坛发布于编程技术,转载请注明出处:Python RPC 之 gRPC彩民之家论坛9066777