как передавать данные CSV через gRPC?

#python #grpc #grpc-python

Вопрос:

Я довольно новичок в микросервисах и в самом grpc, так что извините за невежество. У меня есть CSV-файл, и я пытаюсь выполнить итерацию по строкам файла в одном микросервисе, а затем передать каждую строку в другой микросервис. Затем вторая микросервисная служба выполнит какие-то вычисления, прежде чем ее отправят на веб-сервер. Кто-нибудь знает, как бы вы поступили с этим?

Комментарии:

1. Прямо сейчас это слишком расплывчато, чтобы ответить. Пожалуйста, опубликуйте определение службы gRPC и соответствующий код Python.

Ответ №1:

Для этого вам следует использовать bidi-поток;

  • клиент
 for (line: file.readline()) {
    requestObserver.onNext(line);
}
requestObserver.onCompleted();
 
  • сервер
 StreamObserver<String>{
   onNext(HelloMessage helloMessage) {
     // handle content here
   }
}