Python gRPC：如何使用实验性单线程实现？

Question

我正在 Python 中构建 gRPC 服务，并尝试改进延迟指标。我检查了 Python gRPC Performance Best Practices 并发现了以下内容：

(Experimental) An experimental single-threaded unary-stream implementation is available via the SingleThreadedUnaryStream channel option, which can save up to 7% latency per message.

问题是 link 指向位于 experimental 文件夹中的 class，没有任何使用说明。我搜索了手册（和一般的 Github 回购协议），但没有找到关于如何启用此功能的参考资料

如何在我的代码中使用或调用 SingleThreadedUnaryStream 频道选项功能？

Answer 1

深入研究 gRPC 源代码后，以下内容似乎有效：

from grpc import experimental

channel_options = [(experimental.ChannelOptions.SingleThreadedUnaryStream, 1)]
with grpc.insecure_channel(f"{HOST}:{PORT}", options=channel_options) as channel:
    stub = xxx_pb2_grpc.XxxStub(channel)

但是，对延迟或吞吐量没有影响。

Python gRPC：如何使用实验性单线程实现？

Python gRPC: How to use the experimental single-threaded implementation?

python

grpc