【bf88必发唯一官网】grpc在django中的施用,种类化之

by admin on 2019年3月31日

要调用君越PC接口,python提供了二个框架grpc,那是google开源的

gRPC 简介:

gHighlanderPC 是一款高性能、开源的 LANDPC 框架,产自 谷歌(Google),基于 ProtoBuf
体系化协议举办支付,援救三种语言(Golang、Python、Java等),本篇只介绍
Python 的 gTiggoPC 使用。因为 gRubiconPC 对 HTTP/2 协议的支持使其在 Android、IOS
等客户端后端服务的开发世界拥有能够的前景。gLANDPC
提供了一种简易的办法来定义服务,同时客户端能够丰裕利用 HTTP/2 stream
的本性,从而拉动节省带宽、降低 TCP 的连天次数、节省CPU的接纳等。

近期在做微服务这一块,后端与java同盟,本身是python的,所以考虑动用grpc,一点考虑是grpc是http2.0,另一些设想是万分要求的:)

ProtoBuf:bf88必发唯一官网 , 是一套完整的 IDL(接口描述语言),出自谷歌(Google),基于 C++
进行的贯彻,开发人士能够依照 ProtoBuf
的言语专业生成各个编制程序语言(Golang、Python、Java
等)的接口代码,本篇只讲述 Python 的基础操作。旧事 ProtoBuf
所生成的二进制文件在存储成效上比 XML 高 3~10 倍,并且处理品质高 1~3个数据级,那也是接纳 ProtoBuf 作为种类化方案的三个首要成分之一。

rpc相关文书档案:

安装:

  1. gRPC 的安装:

$ pip install grpcio

  1. 【bf88必发唯一官网】grpc在django中的施用,种类化之。安装 ProtoBuf 相关的 python 依赖库:

$ pip install protobuf

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

$ pip install grpcio-tools


安装:

  1. 安装 protoc
    :Protoc下载地址,能够依据本身的系统下载相应的
    protoc,windows 用户统一下载 win32 版本。
  2. 配备 protoc 到系统的环境变量中,执行如下命令查看是或不是安装成功:

$ protoc –version
如果通常打字与印刷 libprotoc 的版本新闻就注解 protoc 安装成功

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

$ pip install protobuf

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

实践:

下边我们选用 gSportagePC
定义3个接口,该接口达成对传播的数目举办大写的格式化处理。

  • 成立项目 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. 【bf88必发唯一官网】grpc在django中的施用,种类化之。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,WO昂科雷LD!” ,证明g奥德赛PC 接口定义成功

  • 调换可以加 QQ 群:397234385
  • 可能 QQ 扫码入群:

bf88必发唯一官网 1

qq群.jpg

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

使用

  1. 创建 demo python 工程
![](https://upload-images.jianshu.io/upload_images/208550-efc7e919daa289de.png)

Paste\_Image.png
  1. 在 example 包中编辑 person.proto

    syntax = "proto3";
    package example;
    
    message person {   
        int32 id = 1;
        string name = 2;
    }
    
    message all_person {    
        repeated person Per = 1;
    }
    
  2. 进入 demo 工程的 example 目录,使用 protoc 编译 person.proto

$ protoc –python_out=. person.proto
就会变卦 person_pb2.py 文件

  1. 在 python 工程中动用 protobuf 实行体系化与反种类化
    main.py:

    #! /usr/bin/env python
    # -*- coding: utf-8 -*-
    from example import person_pb2
    
    # 为 all_person 填充数据
    pers = person_pb2.all_person()
    p1 = pers.Per.add()
    p1.id = 1
    p1.name = 'xieyanke'
    p2 = pers.Per.add()
    p2.id = 2
    p2.name = 'pythoner'
    
    # 对数据进行序列化
    data = pers.SerializeToString()
    
    # 对已经序列化的数据进行反序列化
    target = person_pb2.all_person()
    target.ParseFromString(data)
    print(target.Per[1].name)  #  打印第一个 person name 的值进行反序列化验证
    

  • 交换能够加 QQ 群:397234385
  • 照旧 QQ 扫码入群:

bf88必发唯一官网 2

qq群.jpg

 

https://grpc.io/docs/quickstart/python.html
而是在教程里clone的不得了项目实在是大,不显明哪些是索要的,经过测试后交由须求的:

内需设置的python包如下:

  • grpcio==1.4.0
  • grpcio-tools==1.4.0
  • xxx.proto 没错,只须要如此三个文件
  • 编译xxx.proto的命令

1.grpc安装

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

pip
install grpcio

此处解释一下,python(不解释) -m(也不表明)
grpc_tools.protoc(上面安装的三方)
-I./protos(标识当前目录下的protos文件夹,xxx.proto须求在这么些文件夹中)
–python_out=.(当前目录生成输出文件)
–grpc_python_out=.(当前目录生成grpc文件)
./protos/xxx.proto(xxx.proto的绝对路径)

 

在配备好grpc的xxx.proto之后要保管java那边的这一个文件要一致(并不是总体,service伊始要求完全相同)

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

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

pip install
grpcio-tools

作者既想用django的model又想用grpc该怎么做吧,django是八个劳务,grpc是二个劳动,间接暴力把grpc代码到场django是不能使用models和views的。

 

不留余地办法就是在greeter_server.py中(这么些文件不明白请看上边的链接)加载django,差不多如下:

3.protobuf相关python依赖库

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)

pip install
protobuf

运行时只须求周转该脚本即可,django服务不必启用

 

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

 

 

 

 

发表评论

电子邮件地址不会被公开。 必填项已用*标注

网站地图xml地图