Server-side logic of GetWeather ProtoBuf (gRPC) service

weather-servicer.py

from concurrent import futures
import grpc
import weather_pb2
import weather_pb2_grpc

class WeatherServicer(weather_pb2_grpc.WeatherServiceServicer):
    def GetWeather(self, request, context):
        # Implement the logic to retrieve the weather here. For simplicity, returning a fixed value.
        return weather_pb2.GetWeatherResponse(temperature=22.5)

def serve():
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    weather_pb2_grpc.add_WeatherServiceServicer_to_server(WeatherServicer(), server)
    server.add_insecure_port('[::]:50051')
    server.start()
    server.wait_for_termination()

if __name__ == '__main__':
    serve()