你好开发社区！介绍PydanticRPC：构建GRPC并连接RPC服务，而无需手动编写Protobuf文件

这是我的首届开发帖子，介绍了pydanticrpc ，它是一个自动创建GRPC并从Pydantic Models连接RPC服务的Python库。 没有更多的手册.proto文件创建！>

github -pydanticrpc

---

概述 Python REST API经常利用FastApi或Flask等框架。 但是，对于优化的数据传输或架构优先方法，GRPC或Connect RPC是令人信服的替代方案。 传统的RPC工作流程涉及定义.proto文件，代码生成（使用

>或

）和集成 - 一个过程通常很麻烦。 protocbuf> pydanticrpc 简化了这一点。 使用Pydantic模型定义RPC数据结构； Pydanticrpc动态生成Protobuf定义并启动服务器。>

什么是pydanticrpc？

---

>关键功能：

自动化的Protobuf生成：

直接从您的Python类和Pydantic模型创建.proto文件。

• >>动态代码生成：>使用
>生成服务器/客户端并集成了您的Python类。
• 广泛的支持：与GRPC，GRPC-WEB兼容（通过Sonora），Connect RPC（通过Connecpy）和异步（Asyncio）操作，包括服务器流量方法。 grpcio-tools
本质上是：“用pydantic模型定义Python类，并立即获得RPC服务 - 不需要.proto文件！”
• >
安装

>通过PYPI安装：

---

用法：创建GRPC服务

>

>使用

pip install pydantic-rpc

创建GRPC服务器。

---

>同步示例

别名pydantic_rpc.Server。

揭示其方法。

生成.proto文件并启动GRPC服务器（默认情况下为LocalHost：50051）。

异步示例

# server.py
from pydantic_rpc import Server, Message

class HelloRequest(Message):
    name: str

class HelloReply(Message):
    message: str

class Greeter:
    def say_hello(self, request: HelloRequest) -> HelloReply:
        return HelloReply(message=f"Hello, {request.name}!")

if __name__ == "__main__":
    server = Server()
    server.run(Greeter())

对于异步服务器，使用Message：pydantic.BaseModel> Greeter Server().run(Greeter())

是一个coroutine，在事件循环中运行。

用法：响应流AsyncIOServer

PydanticRPC

import asyncio
from pydantic_rpc import AsyncIOServer, Message

class HelloRequest(Message):
    name: str

class HelloReply(Message):
    message: str

class Greeter:
    async def say_hello(self, request: HelloRequest) -> HelloReply:
        return HelloReply(message=f"Hello, {request.name}!")

if __name__ == "__main__":
    server = AsyncIOServer()
    loop = asyncio.get_event_loop()
    loop.run_until_complete(server.run(Greeter()))

>支持服务器流响应（当前仅是异步GRPC）。 下面的示例使用了奥运琐事，展示了标准方法和流媒体方法：

server.run(Greeter())

---

是一单元rpc;

是服务器流，从而逐渐产生结果。 pydanticrpc生成一个.proto文件，以启动异步GRPC服务器。>

>用法：创建连接RPC服务

pydantic_ai>在ASGI应用中与Connect RPC的连接集成：

pydantic处理验证。 将此集成到您现有的ASGI框架（Fastapi，starlette）中。

pip install pydantic-rpc

app用法：创建GRPC-WEB服务

---

> 在WSGI或ASGI应用程序中使用GRPC-WEB：

共存的GRPC-WEB和REST端点。>

结论

# server.py
from pydantic_rpc import Server, Message

class HelloRequest(Message):
    name: str

class HelloReply(Message):
    message: str

class Greeter:
    def say_hello(self, request: HelloRequest) -> HelloReply:
        return HelloReply(message=f"Hello, {request.name}!")

if __name__ == "__main__":
    server = Server()
    server.run(Greeter())

PydanticRPC

> PydanticRPC简化了GRPC，GRPC-WEB和连接来自Pydantic模型的RPC开发，包括服务器流。 探索Pydanticrpc GitHub存储库以获取更多详细信息。 欢迎反馈！

---

以上是你好开发社区！介绍PydanticRPC：构建GRPC并连接RPC服务，而无需手动编写Protobuf文件的详细内容。更多信息请关注PHP中文网其他相关文章！