Processing Service Logs for Error Detection and Reporting

Design a core component of a streaming system to process logs sent by upstream services. Filter out error logs, and provide real-time statistics of each service's error count and moving average, generating an alarm when a threshold is reached. Example Input logServiceA:error logServiceB:info logServiceA:error logServiceA:info logServiceB:error