In this video, I'll go through how you can create an ELT pipeline using Airflow, Snowflake, and dbt, with cosmos to visualize your dbt workflows! Check out the repo below! github.com/ast...
Пікірлер: 20
@sainithinreddy663311 ай бұрын
Very clear explanation 👍
@thedataguygeorge11 ай бұрын
Thanks! Glad you enjoyed!
@maxpatrickoliviermorin248910 ай бұрын
Thank you! Would you mind making a much more elaborate version please?
@thedataguygeorge10 ай бұрын
Sure! What would you like to see?
@shubhamkawade73515 ай бұрын
Nice explanation! For a specific dag, how do I run a specific dbt command? e.g. How would you execute 'dbt run --select +third_day_avg_cost_run' for this project in the video ?
@thedataguygeorge5 ай бұрын
You could use the cosmos filtering mechanism to filter for just that specific step, but by default cosmos will automatically render each individual dbt model trigger as a task in the DAG
@WiseSteps.D5 ай бұрын
All good, But where we able to see snowflake connection details?
@thedataguygeorge5 ай бұрын
Go to the connection management UI and select the snowflake connection there!
@Rajdeep64523 ай бұрын
in airflow go to admin>connections and type in your { "account": "-", "warehouse": "", "database": "", "role": "", "insecure_mode": false }
@ameyajoshi65882 ай бұрын
can we have cyclic pre hook applied for a model? If so how to achieve it using dbt airflow
@thedataguygeorge2 ай бұрын
Yes definitely, if you have the pre-hook applied as part of your dbt model build process it should still work!
@vijayjoshi-mw8cr2 ай бұрын
Hello, I have build a ETL pipeline using python,pandas,airflow,snowflake but problem is when i run the task that time it will not load the data into snowflake.. so please can you help with us!!
@thedataguygeorge2 ай бұрын
What errors are you getting?
@VijayJoshi-eg2zq2 ай бұрын
@@thedataguygeorge when i will run the task that time it will get success message but when check snowflake warehouse i am not able to see the table
@Rajdeep64522 ай бұрын
So we are supposed to make the dbt init project first and then create the databases in snowflake? And what schema are you using?
@thedataguygeorge2 ай бұрын
The dbt init that's part of the project should create the databases for you as long as you have the proper permissions/setup