CruxBit
Back to catalog
EasyTechnologyfinance

Starter MySQL Change Feed Ingestion into Delta Bronze

Added Jun 2025 3 design docs

Analytics platforms need a continuous copy of operational data, and the industry-standard first step is landing database changes into a raw Bronze layer, yet most beginners have only ever loaded static CSV files. Learning to capture inserts and updates from a live relational database is the gateway skill for real data engineering work in finance and beyond.

The intern builds a focused pipeline on Databricks that ingests change data from a MySQL table, for example a transactions table receiving new and updated rows, into a Delta Lake Bronze table using Spark. The project covers connecting to the source database from Python, identifying changed records, writing them to Delta format with simple schema enforcement so unexpected columns or types are caught rather than silently absorbed, and adding ingestion metadata such as load timestamps. Repeated runs demonstrate incremental behavior: only new changes land, and the Bronze table grows as an append-only history of what happened in the source.

The project gives the intern their first genuine big data ingestion pattern, teaches why Bronze layers preserve raw fidelity instead of transforming eagerly, and provides hands-on Delta Lake and Spark experience, a compact foundation that the full CDC, merge, and dimensional modeling techniques build directly upon.

Related projects

You might also like

TechnologyEasy

Market Insight Collection and Briefing Tool for Founders

Founders and small business operators make pricing, product, and expansion decisions with whatever market awareness they can scrape together between everything else. Industry reports are expensive, and manually monitoring competitor moves and sector news takes hours a week that early-stage teams cannot spare. What they need is a lightweight tool that collects market information relevant to their business and compresses it into short, decision-ready briefings. The intern builds that tool as a Python web service on Flask. The application lets a user define areas of interest, such as an industry segment, competitor set, or product category, then collects related market information and passes it through OpenAI models to produce structured briefings: what happened, why it may matter to a business like the user's, and what is worth watching next. The intern implements the collection layer, the summarization prompts that keep briefings concrete rather than generic, and endpoints for retrieving current and historical briefings so trends become visible over time. The project gives the intern a grounded introduction to building business intelligence features with generative AI: gathering and structuring source material, engineering prompts for analytical rather than conversational output, and serving results through a clean Flask API that a small company could adopt as-is.

financeagentic-aiflaskopenai+1
PRD · HLD · LLD includedView