This project demonstrates how to build a real-time data ingestion and processing pipeline using Azure Event Hubs, Azure Stream Analytics, and Azure Blob Storage. Simulated telecom call data is generated and streamed to the pipeline for real-time analysis and storage.
This project demonstrates an end-to-end pipeline using Azure Event Hubs, Stream Analytics, and Blob Storage to ingest and process simulated telecom call data. Built by Joshua Phillis, the solution showcases real-time data streaming and secure resource provisioning using Azure-native tools.
Component | Description |
---|---|
Event Hub Namespace | gleventproc-tio |
Event Hub Name | telecomeventhub |
Stream Analytics Job | telecomfakecallsjob |
Input Alias | gltelecominput (from Event Hub) |
Output Alias | gltelecomoutput (to Blob storage) |
Storage Container | telecomoutputstorage in gleventtio account |
- β
Create Resource Group:
GL-EVENT-PROC
- β
Deploy Event Hub namespace:
gleventproc-tio
- β
Create Event Hub:
telecomeventhub
(2 partitions, 1-day retention) - β
Set up Storage Account:
gleventtio
with LRS redundancy - β
Create Blob container:
telecomoutputstorage
- π Job Name:
telecomfakecallsjob
- π Input: Event Hub (
gltelecominput
) - π€ Output: Blob Storage (
gltelecomoutput
) - βοΈ Query: Extract call data using custom SQL logic
- π Download simulator: Telco Data Generator
- π₯οΈ Run:
cd C:\xxxxxx\xxxxxx\xxxxxx\TelcoGenerator\TelcoGenerator\ telcodatagen.exe 1000 0.2 2
Joshua Phillis Cloud & Infrastructure Engineer π LinkedIn
Always delete your resource group when done to avoid unnecessary Azure costs.