
Create a real-time weather reporting system ingesting data from weather API and streaming through Azure Databricks, Event Hub, Microsoft Fabric, and Kusto, with email alerts and a Power BI dashboard.
Set up the Weather API data source, then create and connect essential Azure resources, including resource group, Azure Databricks, Function App, Event Hub, Key Vault secret, and Microsoft Fabric.
Learn to ingest data using Azure Databricks by pulling weather data from the weather API and streaming it to Azure Event Hub through eight steps.
Use Azure Databricks to fetch current weather, forecast, alerts, and air quality data from a weather API via an API key, then stream flattened results to an Event Hub.
Explore data ingestion with an Azure function app by creating a Python function in Visual Studio Code, using a timer trigger every 30s to send events to an Event Hub.
Assess Azure Databricks versus Azure Functions via the Azure Pricing Calculator to estimate monthly costs and performance, guiding a cost-efficient, real-time data ingestion decision.
Execute an end-to-end streaming flow by loading weather data from Azure Event Hub into a Fabric SQL database via an Event Stream pipeline, enabling real-time analysis and Power BI reporting.
Build a real-time weather dashboard in Power BI using fabric query sets, and learn to publish, refresh, and visualize live data.
Configure a real-time alert system for the end-to-end weather data pipeline. Implement a kql query set, data activator, and email alerts running every minute.
Demonstrates end-to-end pipeline testing of a real-time Azure data engineering workflow, from data ingestion by a function app to Event Hub, Fabric processing, and Power BI reporting.
Explore how virtual networks, subnets, private DNS zones, and private endpoints secure Azure Databricks compute plane communications with the control plane.
Build a production-style real-time streaming data pipeline on Azure, right from Data Ingestion to live dashboards. In this hands-on project, we ingest Live Weather API events through two paths (Databricks PySpark and Azure Functions), publish to Azure Event Hubs, process with Microsoft Fabric Eventstream, land data in Eventhouse (Kusto), and visualize insights in Power BI with real-time alerts via Data Activator.
You’ll learn how to provision the environment correctly (Resource Groups, Databricks workspace/cluster, Event Hubs namespace & hub, Key Vault, Fabric workspace), manage secrets securely, and wire services together for a reliable streaming architecture. We’ll write KQL for fast analysis, and apply cost-savvy choices for clusters, Throughput Units, and storage.
By the end, you will be able to:
Design a secure, scalable streaming architecture on Azure.
Implement ingestion with Databricks (PySpark) and Azure Functions.
Stream events into Event Hubs and route them with Fabric Eventstream.
Load/query data in Eventhouse using KQL.
Build live Power BI dashboards and trigger alerts with Data Activator.
Monitor, troubleshoot, and optimize for cost and performance.
Perform final end-to-end pipeline testing, from data ingestion all the way to the report updating with the latest data.
This project is perfect for anyone who wants a clear, practical understanding of how streaming ETL pipelines are built in real-world projects.