python grpc

[yeomko22]

rpc 통신

• remote procedure call의 약자로 원격 제어를 위한 코딩 없이 procedure(subroutine)을 실행 가능한 것

protobuf

• grpc 통신에서 데이터의 인코딩을 위해 사용하는 기술

• 먼저 데이터의 자료구조를 protofile에 작성 (.proto 확장자 사용) 이 때 자료구조는 message라고 칭하고, 메세지는 필드로 구성된다.

  message Person {
  string name = 1;
  int32 id = 2;
  bool has_ponycopter = 3;
  }

• protofile을 만들었으면 protocol buffer compiler(protoc) 를 이용해서 선호하는 언어로 data access class를 생성한다.

grcp

• google이 개발
• 전송으로는 HTTP/2 사용, 인터페이스 언어로는 Protocol Buffer 사용

[yeomko22]

stream

service RouteGuide {
  rpc GetFeature(Point) returns (Feature) {}
  rpc ListFeatures(Rectangle) returns (stream Feature) {}
  rpc RecordRoute(stream Point) returns (RouteSummary) {}
  rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
}

• rpc를 정의할 때 request 쪽 혹은 response 쪽에 stream 키워드를 붙여줄 수 있다.
• stream을 붙이게 될 경우 데이터가 모두 전송되기를 기다리지 않는다는 의미이다.
• response 쪽에 stream이 붙을 경우 클라이언트 쪽에서 모든 데이터가 다 전송되기 전에 바로바로 읽는 다는 뜻이다.
• request 쪽에 stream이 붙을 경우 서버 쪽에서 클라이언트로부터 모든 데이터가 전송되기 전에 바로바로 읽는다는 뜻이다.
• 이를 protoc를 이용해서 클래스 파일로 생성하면 아래와 같은 파이썬 코드가 생성된다.

class RouteGuideServicer(object):
    def GetFeature(self, request, context):
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def ListFeatures(self, request, context):
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def RecordRoute(self, request_iterator, context):
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def RouteChat(self, request_iterator, context):
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

• request 쪽에 stream이 붙을 경우, request_interator를 파라미터로 전달받는다.
• response 쪽에 stream이 붙을 경우, yeild 키워드를 통해서 리턴 값을 주어야 한다. 붙지 않았을 경우에는 그냥 return 키워드를 사용하면 된다.