You're overseeing an Apache Kafka-based IoT pipeline that processes 5000 messages per second. Your task is to create an alert that triggers when the one-hour moving average drops below 4000 messages per second. Which Google Cloud Platform strategy should you implement?