Define event_monitoring_live_v1 views in view.sql files

bigquery_etl/view/__init__.py

@@ -190,16 +190,28 @@ def _valid_view_naming(self):
             for t in parsed.tokens
             if not (t.is_whitespace or isinstance(t, sqlparse.sql.Comment))
         ]
-        is_view_statement = (
-            " ".join(tokens[0].normalized.split()) == "CREATE OR REPLACE"
-            and tokens[1].normalized == "VIEW"
+        is_view_statement = " ".join(tokens[0].normalized.split()) in (
+            "CREATE",
+            "CREATE OR REPLACE",
+        ) and (
+            tokens[1].normalized == "VIEW"
+            or " ".join(t.normalized for t in tokens[1:3]).upper()
+            == "MATERIALIZED VIEW"
         )
         if is_view_statement:
-            target_view = str(tokens[2]).strip().split()[0]
-            try:
-                [project_id, dataset_id, view_id] = target_view.replace("`", "").split(
-                    "."
+            view_kw_index = 1 if tokens[1].normalized == "VIEW" else 2
+            if (
+                " ".join(
+                    t.normalized for t in tokens[view_kw_index + 1 : view_kw_index + 4]
                 )
+                == "IF NOT EXISTS"
+            ):
+                view_id_token = tokens[view_kw_index + 4]
+            else:
+                view_id_token = tokens[view_kw_index + 1]
+            target_view = str(view_id_token).replace("`", "").strip().split()[0]
+            try:
+                [project_id, dataset_id, view_id] = target_view.split(".")
                 if not (
                     self.name == view_id
                     and self.dataset == dataset_id

bqetl_project.yaml

@@ -188,7 +188,7 @@ dry_run:
   - sql/moz-fx-data-shared-prod/org_mozilla_firefox_beta_derived/experiment_events_live_v1/init.sql
   - sql/moz-fx-data-shared-prod/telemetry_derived/experiment_enrollment_cumulative_population_estimate_v1/view.sql
   - sql/moz-fx-data-shared-prod/telemetry/experiment_enrollment_cumulative_population_estimate/view.sql
-  - sql/moz-fx-data-shared-prod/**/event_monitoring_live_v1/init.sql
+  - sql/moz-fx-data-shared-prod/**/event_monitoring_live_v1/view.sql
   - sql/moz-fx-data-shared-prod/monitoring/event_monitoring_live/view.sql
   # Already exists (and lacks an "OR REPLACE" clause)
   - sql/moz-fx-data-shared-prod/org_mozilla_firefox_derived/clients_first_seen_v1/init.sql

sql_generators/glean_usage/event_monitoring_live.py

@@ -26,7 +26,7 @@ class EventMonitoringLive(GleanTable):
 
     def __init__(self) -> None:
         """Initialize materialized view generation."""
-        self.no_init = False
+        self.no_init = True
         self.per_app_id_enabled = True
         self.per_app_enabled = False
         self.across_apps_enabled = True
@@ -38,9 +38,10 @@ def __init__(self) -> None:
     def generate_per_app_id(
         self, project_id, baseline_table, output_dir=None, use_cloud_function=True
     ):
+        """Generate per-app_id views."""
         tables = table_names_from_baseline(baseline_table, include_project_id=False)
 
-        init_filename = f"{self.target_table_id}.init.sql"
+        view_filename = f"{self.target_table_id}.view.sql"
         metadata_filename = f"{self.target_table_id}.metadata.yaml"
 
         table = tables[f"{self.prefix}"]
@@ -68,23 +69,21 @@ def generate_per_app_id(
         Artifact = namedtuple("Artifact", "table_id basename sql")
         artifacts = []
 
-        if not self.no_init:
-            init_sql = render(
-                init_filename, template_folder=PATH / "templates", **render_kwargs
-            )
-            metadata = render(
-                metadata_filename,
-                template_folder=PATH / "templates",
-                format=False,
-                **render_kwargs,
-            )
-            artifacts.append(Artifact(table, "metadata.yaml", metadata))
+        view_sql = render(
+            view_filename, template_folder=PATH / "templates", **render_kwargs
+        )
+        metadata = render(
+            metadata_filename,
+            template_folder=PATH / "templates",
+            format=False,
+            **render_kwargs,
+        )
+        artifacts.append(Artifact(table, "metadata.yaml", metadata))
 
         skip_existing_artifact = self.skip_existing(output_dir, project_id)
 
         if output_dir:
-            if not self.no_init:
-                artifacts.append(Artifact(table, "init.sql", init_sql))
+            artifacts.append(Artifact(table, "view.sql", view_sql))
 
             for artifact in artifacts:
                 destination = (