gRPC Python：配置重试机制中的总超时而非单次尝试超时-Python教程-PHP中文网

gRPC Python：配置重试机制中的总超时而非单次尝试超时

心靈之曲

发布： 2025-07-19 18:24:12

原创

233人浏览过

grpc python：配置重试机制中的总超时而非单次尝试超时

正如摘要所述，在 gRPC Python 中，配置的 timeout 并非针对每次重试的超时时间，而是整个 gRPC 调用的总超时时间。这意味着，即使配置了重试策略，每次尝试的总时间加起来也不能超过 timeout 值。

gRPC 的重试机制旨在提高在网络不稳定或服务器偶发性故障情况下的调用成功率。其设计理念是，任何一次尝试都有可能成功，人为地缩短单次尝试的时间反而会降低成功的概率。因此，gRPC 并没有提供针对单次尝试设置超时的功能。

配置重试策略和超时

以下示例展示了如何在 gRPC Python 中配置重试策略和总超时时间：

立即学习“Python免费学习笔记（深入）”；

百度智能云·曦灵

百度旗下的AI数字人平台

查看详情

import grpc
import json
import asyncio

async def call_grpc(host_port, request):
    settings = {
        'methodConfig': [
            {
                'name': [{}],
                'retryPolicy': {
                    'maxAttempts': 5,
                    'initialBackoff': '0.1s',
                    'maxBackoff': '2s',
                    'backoffMultiplier': 2,
                    'retryableStatusCodes': [
                        'UNAVAILABLE',
                        'INTERNAL',
                        'DEADLINE_EXCEEDED',
                    ],
                },
            },
        ],
    }
    settings_as_json_string = json.dumps(settings)

    async with grpc.aio.insecure_channel(
       host_port, options=(('grpc.service_config', settings_as_json_string),),
    ) as channel:
        stub = StubClass(channel=channel)
        try:
            response = await stub.SomeMethod(
                request=request,
                timeout=0.5, # 总超时时间为0.5秒
            )
            return response
        except grpc.RpcError as e:
            print(f"gRPC call failed: {e}")
            return None


# 示例用法
if __name__ == '__main__':
    async def main():
        # 假设 host_port 和 Request 已经定义
        host_port = "localhost:50051" # 替换为你的 gRPC 服务器地址
        request = Request() # 替换为你的请求对象

        result = await call_grpc(host_port, request)
        if result:
            print(f"gRPC call succeeded: {result}")

    asyncio.run(main())

登录后复制

代码解释：