Implement a custom rate-limiter for an internal API that manages high-throughput data streams from physical edge devices.