python部署thrift服务以及客户端

2024-06-16 13:48

本文主要是介绍python部署thrift服务以及客户端,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

第一步:定义接口

文件名:parse.thrift

内容如下:

 

 service Parse {string parseHtml2Xml(1:string html)}


第二步:在thrift接口所在目录执行thrift命令

 

 

# thrift --gen py parse.thrift

这步会在当前目录生成gen-py文件夹

 

如果是用php,则用如下命令:

 

 服务端:thrift --gen php:server helloworld.thrift
 客户端:thrift --gen php:client helloworld.thrift

如果是用java,则用如下命令:

Linux环境:thrift --gen java importservice.thrift

windows环境: thrift-0.9.3.exe  --gen java importservice.thrift

要注意的是,服务端和客户端使用的thrift版本要保持一致

 

第三步: server服务的开发,文件名,server.py

import sys 
sys.path.append("./gen-py/parse")from Parse import *
from ttypes import *
from thrift.Thrift import TType, TMessageType, TException
from thrift.Thrift import TProcessor
from thrift.transport import TSocket
from thrift.protocol import TBinaryProtocol, TProtocol
from thrift.server import TServer
import logging
from constants import *

 

 

可在服务中定义日志模块,记录日志信息

 

logging.basicConfig(filename='logger.log', level=logging.INFO, format='%(asctime)s  %(filename)s : %(levelname)s  %(message)s', datefmt='%Y-%m-%d %H:%M:%S')


真正的服务代码

 

 

class ParseHandler:def parseHtml2Xml(self, html):logging.info("start parse html")return "1234"

 

def run():#创建服务端handler = ParseHandler()processor = Processor(handler)#监听端口transport = TSocket.TServerSocket('localhost', 9234)#选择传输层tfactory = TTransport.TBufferedTransportFactory()#选择传输协议pfactory = TBinaryProtocol.TBinaryProtocolFactory()#创建服务端server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory)server.setNumThreads(5)logging.info('start thrift serve in python')server.serve()logging.info('done!')if __name__ == '__main__':run()


第四步:启动python服务

 

# python  server.py

 

第五步: client客户端的开发,客户端文件名为client.py

 

import sys 
sys.path.append('./gen-py/parse')from Parse import *
from thrift import Thrift 
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
import requeststry:transport = TSocket.TSocket('localhost', 9234)transport = TTransport.TBufferedTransport(transport)protocol = TBinaryProtocol.TBinaryProtocol(transport)client = Client(protocol)transport.open()print 'start'res = requests.get('http://baike.baidu.com/item/%E7%A2%A7%E6%A1%82%E5%9B%AD%E5%98%89%E8%AA%89/19775381')xml = client.parseHtml2Xml(res.content)print xml transport.close()
except Thrift.TException as e:print 'exceptino'print e


第六步: 启动客户端调用

 

# python  client.py

 

下面是一个thrift文件的case

 

 

service ImportService {//单个导入string singleImport(1:string url, 2:list<string> importModule, 3:i64 authorId)//批量新增导入string batchCreateImport(1:list<string> urls, 2:list<string> importModule, 3:i64 authorId)//批量覆盖导入string batchCoverImport(1:list<string> urls, 2:list<string> importModule, 3:i64 authorId)//检查相似度string checkSimilarity(1:string url, 2:list<string> importModule)//检查词条状态string checkLemmaStatus(1:string url)//批量导入时获取导入进度string getImportProcess(1:i64 authorId)
}

 

 

在thrift中,i32表示整型int,i64表示长整型long
 

这篇关于python部署thrift服务以及客户端的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1066617

相关文章

python panda库从基础到高级操作分析

《pythonpanda库从基础到高级操作分析》本文介绍了Pandas库的核心功能,包括处理结构化数据的Series和DataFrame数据结构,数据读取、清洗、分组聚合、合并、时间序列分析及大数据... 目录1. Pandas 概述2. 基本操作:数据读取与查看3. 索引操作:精准定位数据4. Group

Python pandas库自学超详细教程

《Pythonpandas库自学超详细教程》文章介绍了Pandas库的基本功能、安装方法及核心操作,涵盖数据导入(CSV/Excel等)、数据结构(Series、DataFrame)、数据清洗、转换... 目录一、什么是Pandas库(1)、Pandas 应用(2)、Pandas 功能(3)、数据结构二、安

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

Python安装Pandas库的两种方法

《Python安装Pandas库的两种方法》本文介绍了三种安装PythonPandas库的方法,通过cmd命令行安装并解决版本冲突,手动下载whl文件安装,更换国内镜像源加速下载,最后建议用pipli... 目录方法一:cmd命令行执行pip install pandas方法二:找到pandas下载库,然后

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连

Python实现网格交易策略的过程

《Python实现网格交易策略的过程》本文讲解Python网格交易策略,利用ccxt获取加密货币数据及backtrader回测,通过设定网格节点,低买高卖获利,适合震荡行情,下面跟我一起看看我们的第一... 网格交易是一种经典的量化交易策略,其核心思想是在价格上下预设多个“网格”,当价格触发特定网格时执行买

Python标准库之数据压缩和存档的应用详解

《Python标准库之数据压缩和存档的应用详解》在数据处理与存储领域,压缩和存档是提升效率的关键技术,Python标准库提供了一套完整的工具链,下面小编就来和大家简单介绍一下吧... 目录一、核心模块架构与设计哲学二、关键模块深度解析1.tarfile:专业级归档工具2.zipfile:跨平台归档首选3.

使用Python构建智能BAT文件生成器的完美解决方案

《使用Python构建智能BAT文件生成器的完美解决方案》这篇文章主要为大家详细介绍了如何使用wxPython构建一个智能的BAT文件生成器,它不仅能够为Python脚本生成启动脚本,还提供了完整的文... 目录引言运行效果图项目背景与需求分析核心需求技术选型核心功能实现1. 数据库设计2. 界面布局设计3

使用IDEA部署Docker应用指南分享

《使用IDEA部署Docker应用指南分享》本文介绍了使用IDEA部署Docker应用的四步流程:创建Dockerfile、配置IDEADocker连接、设置运行调试环境、构建运行镜像,并强调需准备本... 目录一、创建 dockerfile 配置文件二、配置 IDEA 的 Docker 连接三、配置 Do

Python进行JSON和Excel文件转换处理指南

《Python进行JSON和Excel文件转换处理指南》在数据交换与系统集成中,JSON与Excel是两种极为常见的数据格式,本文将介绍如何使用Python实现将JSON转换为格式化的Excel文件,... 目录将 jsON 导入为格式化 Excel将 Excel 导出为结构化 JSON处理嵌套 JSON: