add additional sql and json files because the workflow goes far beyond table creation

Author: FlosMume

sql/06_ai_functions.sql

@@ -0,0 +1,25 @@
+-- Spam detection demo
+CREATE TABLE IF NOT EXISTS dbsql_samuel.demo.inbox_messages (
+  timestamp TIMESTAMP,
+  from_number STRING,
+  text STRING
+);
+
+SELECT
+  text,
+  ai_query(
+    "databricks-meta-llama-3-3-70b-instruct",
+    "Classify the following message as spam or not spam: " || text
+  ) AS is_spam
+FROM dbsql_samuel.demo.inbox_messages
+LIMIT 10;
+
+-- Airline type classification demo
+SELECT
+  IATA,
+  ai_classify(
+    content => IATA,
+    labels => array('full service carriers','low cost carriers','regional airlines','charter airlines')
+  ) AS airline_category
+FROM dbsql_samuel.demo.airports
+LIMIT 10;

sql/07_alerts_and_permissions.sql

@@ -0,0 +1,10 @@
+-- ATL delay alert
+CREATE ALERT IF NOT EXISTS atl_flight_delay_alert
+AS
+SELECT COUNT(*) AS delayed_flights
+FROM dbsql_samuel.demo.flights_silver_mv
+WHERE Dest='ATL' AND IsArrDelayed='YES'
+HAVING delayed_flights > 100;
+
+-- Permissions example
+GRANT SELECT ON TABLE dbsql_samuel.demo.flights_silver_mv TO `data_analyst`;

sql/08_lakeflow_job.json

@@ -0,0 +1,9 @@
+{
+  "name": "Flight Orchestration Workflow",
+  "tasks": [
+    { "task_key": "ingest_airports_bronze", "type": "sql", "sql_task": { "query_name": "airports ST" } },
+    { "task_key": "replace_airports_mv", "type": "sql", "depends_on": ["ingest_airports_bronze"], "sql_task": { "query_name": "airports MV" } },
+    { "task_key": "check_atl_alert", "type": "sql", "depends_on": ["replace_airports_mv"], "sql_task": { "alert_name": "ATL Flight Alert" } },
+    { "task_key": "refresh_flight_dashboard", "type": "dashboard", "depends_on": ["check_atl_alert"], "dashboard_task": { "dashboard_name": "Flight Data Dashboard" } }
+  ]
+}