如何使用 Google Cloud get_operation？

Question

我正在尝试使用该OperationsClient get_operation()功能，以便我可以轮询长时间运行的任务并获取其状态。

https://google-cloud-python.readthedocs.io/en/stable/core/operations_client.html#google.api_core.operations_v1.OperationsClient.get_operation

代码看起来相当简单：

api = operations_v1.OperationsClient()

response = api.get_operation(name)

但是， 的初始化OperationClient需要一个通道：OperationsClient(channel)。我对频道做什么或如何创建一无所知。

任何帮助表示赞赏。谢谢

Answer 1

从您链接的文档中：channel( grpc.Channel ) – 与实现google.longrunning.operations接口的服务关联的 gRPC 通道。因此，如果它是您自己的 gRPC 服务，您将需要执行以下操作：import grpcchannel = grpc.insecure_channel('localhost:50051')api = operations_v1.OperationsClient(channel)response = api.get_operation(name)根据您尝试轮询的长时间运行的服务，您可能需要改用其通道。

Answer 2

这是我最终使用的代码。operation = self.stt_client.transport._operations_client.get_operation(operation_name)response = operation_core.from_gapic(             operation,             self.stt_client.transport._operations_client,             types.LongRunningRecognizeResponse,             metadata_type=types.LongRunningRecognizeMetadata,         )