我如何使用 Python gRPC

如何解决我如何使用 Python gRPC

作为问题的答案：how-do-i-handle-streaming-messages-with-python-grpc，@Nathaniel 提供了处理请求和响应的解决方案。

但是当我想统计每个响应的处理时间时，它看起来不太正确。例如，我在 stream_iter 中睡眠了 200 毫秒，但 tr 甚至不到 200 毫秒。我的代码：

t0 = time.time()
for rsp in stub.Process(stream_iter()):
    tr = (time.time() - t0) * 1000
    print(tr)
    t0 = time.time()
...

所以我想知道如何计时？

解决方法

很难判断给定的片段有什么问题。我建议创建一个完整的复制案例作为 https://github.com/grpc/grpc/issues 的问题。

这里有一些可能性：

1. 流量控制，客户端/服务器可能会缓冲它收到的消息，因此在某些情况下您可能会看到小爆发。
2. 迭代器中的错误，例如，我们想在 __next__ 中休眠，但可能不小心在 __iter__ 中注入了 sleep。

通常，如果您调整规模和吞吐量，噪音应该会消失。您可以用来衡量每个响应的延迟时间。