电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術(shù)文章
文章詳情頁

如何用Python搭建gRPC服務(wù)

瀏覽:3日期:2022-06-15 15:42:12
目錄一、概述二、安裝python需要的庫三、定義gRPC的接口四、使用 protoc 和相應(yīng)的插件編譯生成對應(yīng)語言的代碼五、編寫grpc的服務(wù)端代碼六、編寫gRPC客戶端的代碼七、調(diào)用測試八、gRPC的使用總結(jié)一、概述

一個gRPC服務(wù)的大體結(jié)構(gòu)圖為:

如何用Python搭建gRPC服務(wù)

圖一表明,grpc的服務(wù)是跨語言的,但需要遵循相同的協(xié)議(proto)。相比于REST服務(wù),gPRC 的一個很明顯的優(yōu)勢是它使用了二進制編碼,所以它比 JSON/HTTP 更快,且有清晰的接口規(guī)范以及支持流式傳輸,但它的實現(xiàn)相比rest服務(wù)要稍微要復(fù)雜一些,下面簡單介紹搭建gRPC服務(wù)的步驟。

二、安裝python需要的庫

pip install grpcio

pip install grpcio-tools  

pip install protobuf

三、定義gRPC的接口

創(chuàng)建 gRPC 服務(wù)的第一步是在.proto 文件中定義好接口,proto是一個協(xié)議文件,客戶端和服務(wù)器的通信接口正是通過proto文件協(xié)定的,可以根據(jù)不同語言生成對應(yīng)語言的代碼文件。這個協(xié)議文件主要就是定義好服務(wù)(service)接口,以及請求參數(shù)和相應(yīng)結(jié)果的數(shù)據(jù)結(jié)構(gòu),下面是一個簡單的例子。

syntax = 'proto3';​option cc_generic_services = true;​//定義服務(wù)接口service GrpcService { rpc hello (HelloRequest) returns (HelloResponse) {} //一個服務(wù)中可以定義多個接口,也就是多個函數(shù)功能}​//請求的參數(shù)message HelloRequest { string data = 1; //數(shù)字1,2是參數(shù)的位置順序,并不是對參數(shù)賦值 Skill skill = 2; //支持自定義的數(shù)據(jù)格式,非常靈活};​//返回的對象message HelloResponse { string result = 1; map<string, int32> map_result = 2; //支持map數(shù)據(jù)格式,類似dict};​message Skill { string name = 1;};四、使用 protoc 和相應(yīng)的插件編譯生成對應(yīng)語言的代碼

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

利用編譯工具把proto文件轉(zhuǎn)化成py文件,直接在當(dāng)前文件目錄下運行上述代碼即可。

1.-I 指定proto所在目錄

2.-m 指定通過protoc生成py文件

3.--python_out指定生成py文件的輸出路徑

4.hello.proto 輸入的proto文件

執(zhí)行上述命令后,生成hello_pb2.py 和hello_pb2_grpc.py這兩個文件。

五、編寫grpc的服務(wù)端代碼

#! /usr/bin/env python# coding=utf8​import timefrom concurrent import futures​import grpc​from gRPC_example import hello_pb2_grpc, hello_pb2​_ONE_DAY_IN_SECONDS = 60 * 60 * 24​​class TestService(hello_pb2_grpc.GrpcServiceServicer): ’’’ 繼承GrpcServiceServicer,實現(xiàn)hello方法 ’’’ def __init__(self):pass​ def hello(self, request, context):’’’具體實現(xiàn)hello的方法,并按照pb的返回對象構(gòu)造HelloResponse返回:param request::param context::return:’’’result = request.data + request.skill.name + ' this is gprc test service'list_result = {'12': 1232}return hello_pb2.HelloResponse(result=str(result), map_result=list_result)​def run(): ’’’ 模擬服務(wù)啟動 :return: ’’’ server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) hello_pb2_grpc.add_GrpcServiceServicer_to_server(TestService(),server) server.add_insecure_port(’[::]:50052’) server.start() print('start service...') try:while True: time.sleep(_ONE_DAY_IN_SECONDS) except KeyboardInterrupt:server.stop(0)​​if __name__ == ’__main__’: run()

在服務(wù)端側(cè),需要實現(xiàn)hello的方法來滿足proto文件中GrpcService的接口需求,hello方法的傳入?yún)?shù),是在proto文件中定義的HelloRequest,context是保留字段,不用管,返回參數(shù)則是在proto中定義的HelloResponse,服務(wù)啟動的代碼是標(biāo)準(zhǔn)的,可以根據(jù)需求修改提供服務(wù)的ip地址以及端口號。

六、編寫gRPC客戶端的代碼

#! /usr/bin/env python# coding=utf8​import grpc​from gRPC_example import #! /usr/bin/env python# coding=utf8​import grpc​from gRPC_example import hello_pb2_grpc, hello_pb2​​def run(): ’’’ 模擬請求服務(wù)方法信息 :return: ’’’ conn=grpc.insecure_channel(’localhost:50052’) client = hello_pb2_grpc.GrpcServiceStub(channel=conn) skill = hello_pb2.Skill(name='engineer') request = hello_pb2.HelloRequest(data='xiao gang', skill=skill) respnse = client.hello(request) print('received:',respnse.result)​​if __name__ == ’__main__’: run()​​def run(): ’’’ 模擬請求服務(wù)方法信息 :return: ’’’ conn=grpc.insecure_channel(’localhost:50052’) client = hello_pb2_grpc.GrpcServiceStub(channel=conn) skill = hello_pb2.Skill(name='engineer') request = hello_pb2.HelloRequest(data='xiao gang', skill=skill) response = client.hello(request) print('received:',response.result)​​if __name__ == ’__main__’: run()

客戶端側(cè)代碼的實現(xiàn)比較簡單,首先定義好訪問ip和端口號,然后定義好HelloRequest數(shù)據(jù)結(jié)構(gòu),遠(yuǎn)程調(diào)用hello即可。需要強調(diào)的是,客戶端和服務(wù)端一定要import相同proto文件編譯生成的hello_pb2_grpc, hello_pb2模塊,即使服務(wù)端和客戶端使用的語言不一樣,這也是grpc接口規(guī)范一致的體現(xiàn)。

七、調(diào)用測試

先啟動運行服務(wù)端的代碼,再啟動運行客戶端的代碼即可。

八、gRPC的使用總結(jié) 定義好接口文檔 工具生成服務(wù)端/客戶端代碼 服務(wù)端補充業(yè)務(wù)代碼 客戶端建立 gRPC 連接后,使用自動生成的代碼調(diào)用函數(shù) 編譯、運行

以上就是如何用Python搭建gRPC服務(wù)的詳細(xì)內(nèi)容,更多關(guān)于Python搭建gRPC服務(wù)的資料請關(guān)注好吧啦網(wǎng)其它相關(guān)文章!

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 换网器_自动换网器_液压换网器--郑州海科熔体泵有限公司 | 数控车床-立式加工中心-多功能机床-小型车床-山东临沂金星机床有限公司 | 818手游网_提供当下热门APP手游_最新手机游戏下载 | 欧盟ce检测认证_reach检测报告_第三方检测中心-深圳市威腾检验技术有限公司 | 高压管道冲洗清洗机_液压剪叉式升降机平台厂家-林君机电 | 涡街流量计_LUGB智能管道式高温防爆蒸汽温压补偿计量表-江苏凯铭仪表有限公司 | 定制异形重型钢格栅板/钢格板_定做踏步板/排水沟盖板_钢格栅板批发厂家-河北圣墨金属制品有限公司 | 家庭教育吧-在线家庭教育平台,专注青少年家庭教育 | 土壤有机碳消解器-石油|表层油类分析采水器-青岛溯源环保设备有限公司 | 设计圈 - 让设计更有价值!| 云南标线|昆明划线|道路标线|交通标线-就选云南云路施工公司-云南云路科技有限公司 | 艺术漆十大品牌_艺术涂料加盟代理_蒙太奇艺术涂料厂家品牌|艺术漆|微水泥|硅藻泥|乳胶漆 | CTP磁天平|小电容测量仪|阴阳极极化_双液系沸点测定仪|dsj电渗实验装置-南京桑力电子设备厂 | 北京律师事务所_房屋拆迁律师_24小时免费法律咨询_云合专业律师网 | 青岛侦探调查_青岛侦探事务所_青岛调查事务所_青岛婚外情取证-青岛狄仁杰国际侦探公司 | 车充外壳,车载充电器外壳,车载点烟器外壳,点烟器连接头,旅行充充电器外壳,手机充电器外壳,深圳市华科达塑胶五金有限公司 | 贵阳用友软件,贵州财务软件,贵阳ERP软件_贵州优智信息技术有限公司 | 无硅导热垫片-碳纤维导热垫片-导热相变材料厂家-东莞市盛元新材料科技有限公司 | 深圳办公室装修-写字楼装修设计-深圳标榜装饰公司 | 挖掘机挖斗和铲斗生产厂家选择徐州崛起机械制造有限公司 | 软膜天花_软膜灯箱_首选乐创品牌_一站式天花软膜材料供应商! | 欧必特空气能-商用空气能热水工程,空气能热水器,超低温空气源热泵生产厂家-湖南欧必特空气能公司 | 温州在线网| 称重传感器,测力传感器,拉压力传感器,压力变送器,扭矩传感器,南京凯基特电气有限公司 | 废水处理-废气处理-工业废水处理-工业废气处理工程-深圳丰绿环保废气处理公司 | 车间除尘设备,VOCs废气处理,工业涂装流水线,伸缩式喷漆房,自动喷砂房,沸石转轮浓缩吸附,机器人喷粉线-山东创杰智慧 | 板式换热器_板式换热器价格_管式换热器厂家-青岛康景辉 | PAS糖原染色-CBA流式多因子-明胶酶谱MMP-上海研谨生物科技有限公司 | 武汉高低温试验机-现货恒温恒湿试验箱-高低温湿热交变箱价格-湖北高天试验设备 | 企业微信scrm管理系统_客户关系管理平台_私域流量运营工具_CRM、ERP、OA软件-腾辉网络 | PCB厂|线路板厂|深圳线路板厂|软硬结合板厂|电路板生产厂家|线路板|深圳电路板厂家|铝基板厂家|深联电路-专业生产PCB研发制造 | 美国PARKER齿轮泵,美国PARKER柱塞泵,美国PARKER叶片泵,美国PARKER电磁阀,美国PARKER比例阀-上海维特锐实业发展有限公司二部 | 布袋除尘器|除尘器设备|除尘布袋|除尘设备_诺和环保设备 | 济南网站策划设计_自适应网站制作_H5企业网站搭建_济南外贸网站制作公司_锐尚 | 泰安塞纳春天装饰公司【网站】 | 打造全球沸石生态圈 - 国投盛世 锂电混合机-新能源混合机-正极材料混料机-高镍,三元材料混料机-负极,包覆混合机-贝尔专业混合混料搅拌机械系统设备厂家 | 无线遥控更衣吊篮_IC卡更衣吊篮_电动更衣吊篮配件_煤矿更衣吊篮-力得电子 | 安徽泰科检测科技有限公司【官方网站】| 出国劳务公司_正规派遣公司[严海] | Type-c防水母座|贴片母座|耳机接口|Type-c插座-深圳市步步精科技有限公司 | 洛阳防爆合格证办理-洛阳防爆认证机构-洛阳申请国家防爆合格证-洛阳本安防爆认证代办-洛阳沪南抚防爆电气技术服务有限公司 |