How to Parse gRPC Request Data in Python

from google.protobuf import json_format
import grpc
from concurrent import futures
import time


class DataParsingService:
    def parse(self, request):
        return {
            "received_json": json_format.MessageToJson(request),
            "parsed_fields": {
                "name": request.name,
                "count": request.count,
        }
    }


def create_grpc_server(servicer):
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    # Note: In real usage, add your generated proto servicer here
    print("Starting gRPC server...")
    server.add_insecure_port("[::]:50051")
    server.start()
    print("Server running on port 50051")
    return server


if __name__ == "__main__":
    # Simulate parsing flow for beginners
    sample_data = {
        "name": "example_record",
        "count": 42
    }
    service = DataParsingService()
    
    # Using a simple mock request object
    class SimpleRequest:
        def __init__(self, data):
            self.__dict__.update(data)
    
    request = SimpleRequest(sample_data)
    result = service.parse(request)
    
    print("Parsed result:")
    for key, value in result.items():
        print(f"  {key}: {value}")