You are configuring a DAG in a Cloud Composer 2 instance, which uses Apache Airflow to process files from a Cloud Storage bucket individually. The instance resides in a subnetwork without Internet connectivity. Your goal is to activate the DAG dynamically upon the arrival of each new file, instead of relying on a predetermined schedule. How can you implement this reactive triggering mechanism under these constraints?