【问题标题】:How to process multiple gRPC futures?如何处理多个 gRPC 期货?
【发布时间】:2019-07-29 17:16:42
【问题描述】:

我有几个 gRPC 存根。我想异步调用它们,然后将它们的结果(带有小的后处理)合并为一个。对于普通的 Python 期货,我可以使用 concurrent.futures.as_completedconcurrent.futures.wait,但 gRPC 期货 does not support this functions

如何并行调用 gRPC 存根并有效地组合它们的结果?

【问题讨论】:

    标签: python asynchronous parallel-processing future grpc


    【解决方案1】:

    您可以将每个调用调用为stub.SayHello.futures(HelloRequest(name="world")) 以实现并行性。然而,要结合它们的结果,没有比遍历 RPC 列表并等待它们中的每一个更方便的方法了。

    如果您发现此功能有用,请 ping GitHub 问题,并添加您的用例;)

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2020-11-06
      • 2020-05-07
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2017-06-22
      相关资源
      最近更新 更多