sqlmesh_context_plan_creation_and_apply_quickstart.py

1import pandas as pd
2from sqlmesh.core.context import Context
3
4# Initialize the SQLMesh context for a project located in the current directory
5# If no project exists, you can use `sqlmesh init` in the terminal first
6context = Context(paths=".")
7
8# Create a plan for the 'prod' environment
9# This will identify changes made to models and prepare them for application
10plan = context.plan("prod")
11
12# Apply the plan to the project
13# This executes the necessary SQL to bring the environment up to date
14context.apply(plan)
15
16# Example of interacting with the data using the context's engine adapter
17# This retrieves the first 5 rows of a model named 'full_model'
18df = context.fetchdf("SELECT * FROM sqlmesh.full_model LIMIT 5")
19print(df)