that automatically pipes every log event from CloudWatch → Kinesis in real time. Run ONCE before starting app.py and stream_processor.py.