WIP

Author: jeremyholtzman

learn-dbt/data/country_codes.csv

@@ -0,0 +1,4 @@
+country_code,country_name
+US,United States
+MX,Mexico
+GB,Great Britain

learn-dbt/dbt_project.yml

@@ -23,6 +23,14 @@ clean-targets:         # directories to be removed by `dbt clean`
     - "target"
     - "dbt_modules"
 
+on-run-start:
+    - "create table if not exists audit (model text, state text, time timestamp_ltz)"
+
+on-run-end:
+  - 'grant usage on schema analytics.dbt to role analyst'
+  - 'grant select on all tables in schema analytics.dbt to role analyst'
+  - 'grant select on all views in schema analytics.dbt to role analyst'
+
 
 # Configuring models
 # Full documentation: https://docs.getdbt.com/docs/configuring-models
@@ -39,3 +47,4 @@ models:
             my_first_variable: True
             my_second_variable: 2020
             my_third_variable: 1
+          pre-hook: "insert into dbt.audit (model, state, time) values ('{{this.name}}', 'starting model deployment', current_timestamp)"

learn-dbt/models/example/my_first_dbt_model.sql

@@ -10,11 +10,13 @@
 
 with source_data as (
 
-    select 1 as id
+    select 1 as id, 'NY' as state, '2020-02-01 00:01:00.000'::timestamp as updated_at
     union all
-    select null as id
+    select null as id, 'CT' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
     union all
-    select 3 as id
+    select 4 as id, 'VT' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
+    union all
+    select 5 as id, 'NJ' as state, '2020-01-01 00:00:00.000'::timestamp as updated_at
 
 )
 

learn-dbt/models/example/schema.yml

@@ -39,3 +39,11 @@ models:
           tests:
             - accepted_values:
                 values: ['BUILDING', 'AUTOMOBILE', 'MACHINERY', 'HOUSEHOLD', 'FURNITURE']
+
+sources:
+  - name: sample
+    database: snowflake_sample_data  # Tell dbt to look for the source in the "raw" database
+    schema: tpch_sf1
+    tables:
+      - name: customer
+      - name: orders

learn-dbt/models/example/snowflake_customer_purchases.sql

@@ -3,8 +3,8 @@ SELECT
     c.c_name,
     c.c_nationkey as nation,
     sum(o.o_totalprice) as total_order_price
-from "SNOWFLAKE_SAMPLE_DATA"."TPCH_SF1"."CUSTOMER" c
-LEFT JOIN "SNOWFLAKE_SAMPLE_DATA"."TPCH_SF1"."ORDERS" o
+from {{ source('sample', 'customer') }} c
+LEFT JOIN {{ source('sample', 'orders') }} o
 ON c.c_custkey = o.o_custkey
 
 group by

learn-dbt/snapshots/first_model_snapshot.sql

@@ -0,0 +1,16 @@
+{% snapshot first_model_snapshot %}
+    {{
+        config(
+          target_database='analytics',
+          target_schema='snapshots',
+          unique_key='id',
+
+          strategy='timestamp',
+          updated_at='updated_at',
+        )
+    }}
+
+    -- Pro-Tip: Use sources in snapshots!
+    select * from {{ ref('my_first_dbt_model') }}
+
+{% endsnapshot %}