Я пытаюсь (не удается) использовать gRPC ( grpc.io ) с потоками.
Что я хочу, чтобы после получения запроса масштабировать его в потоке и отвечать через него, без части «return» gRPC.
Вот мой метод:
def CriaItem(self, request, context):
chave = request.chave
valor = request.valor
validacao = self.configs.valida_chave(chave)
if validacao[0]:
self.queue1.enqueue((comandos['create'], chave, valor, context))
else:
stub = self.cria_stub(validacao[1])
self.queue4.enqueue((comandos['create'], chave, valor, context, stub))
Процесс удаления из очереди будет происходить внутри потока. После этого я хочу вернуть некоторое значение обратно запрашивающей стороне.
Есть ли способ сделать это без , используя асинхронные ключевые слова?