dagster-postgres

import os from dagster import Definitions, asset, EnvVar from dagster_postgres import postgres_resource @asset(compute_kind="sql") def my_postgres_asset(postgres: postgres_resource): """A simple asset that connects to PostgreSQL and runs a dummy query.""" with postgres.get_connection() as conn: with conn.cursor() as cursor: cursor.execute("SELECT 1;") result = cursor.fetchone() print(f"Postgres query result: {result}") # In a typical asset, you'd load/transform/store data here. defs = Definitions( assets=[my_postgres_asset], resources={ "postgres": postgres_resource.configured({ "database": EnvVar("POSTGRES_DB"), "host": EnvVar("POSTGRES_HOST"), "port": EnvVar("POSTGRES_PORT"), "user": EnvVar("POSTGRES_USER"), "password": EnvVar("POSTGRES_PASSWORD"), }) } ) # To run this example, set environment variables (e.g., in your shell): # export POSTGRES_DB=your_db_name # export POSTGRES_HOST=localhost # export POSTGRES_PORT=5432 # export POSTGRES_USER=your_user # export POSTGRES_PASSWORD=your_password # Then execute using `dagster dev -f your_file.py` and materialize `my_postgres_asset` in the UI.