pip install -i https://test.pypi.org/simple/ example-package-asifr-berhampore==0.0.1

from example_package_asifr_berhampore.example_package_asifr_berhampore import TrafficProcessingSDK

kafka_bootstrap_servers = "localhost:9092"
group_id = "traffic-processing-group"
sdk = TrafficProcessingSDK(kafka_bootstrap_servers, group_id)

@app.middleware("http")
async def some_middleware(request: Request, call_next):
    response = await call_next(request)
    response_body = [chunk async for chunk in response.body_iterator]
    response.body_iterator = iterate_in_threadpool(iter(response_body))
    print(f"response_body={response_body[0].decode()}")
    print(request.url.path)
    print(request.method)

    sdk.process_request(request.url.path, request.method, response_body[0].decode())
    return response