Late-Arriving Data: Deciding When a Day Is Actually Done
Late data is a distribution you can measure, not an edge case. How to set a waiting policy, handle what arrives after it, and say when a number is final.
31 articles
Late data is a distribution you can measure, not an edge case. How to set a waiting policy, handle what arrives after it, and say when a number is final.
Every record has three timestamps: when it happened, when it arrived, and when it was processed. Group by the wrong one and past days keep changing.
Enrich streaming data with reference data lookups for context-aware processing and alerting in real-time scenarios.
The SDK supports function calling with automatic TypeScript type inference, making it easy to extend your AI with custom capabilities.
Eventstreams support multiple source types including Azure Event Hubs, Azure IoT Hub, and custom applications. The visual designer makes it easy to…
Add a blinking cursor effect while streaming to indicate ongoing generation. Users perceive streaming responses as 3-5x faster than equivalent non-streaming…
Microsoft Fabric's Real-Time Intelligence workload has matured significantly since GA. We've implemented several production streaming scenarios, and I want…
Understanding streaming inference is essential for production AI systems. Here's what you need to know.
Streaming inference brings AI insights to real-time data. Design for throughput, latency, and reliability from the start.
Real-time AI requires discipline around latency. Design for the worst case and optimize for the common case.
How to put Azure OpenAI inside an Event Hubs pipeline without stalling partitions: batch triggers, a cheap triage tier, structured outputs, fail-closed errors.
A decision guide for placing filters, enrichment, aggregation and alerts across Eventstream, Eventhouse and Spark in Fabric Real-Time Intelligence.
Streaming ML enables intelligent real-time systems that continuously learn and adapt. Start with robust feature engineering and monitoring before enabling…
Eventstream enhancements make real-time analytics more powerful and accessible. Start with simple streaming scenarios and progressively add complexity.
Practical Fabric Eventstream patterns: what belongs in the no-code event processor, what belongs in KQL, and what to fix before events arrive.
How Eventstream, KQL databases, Power BI and the Data Activator preview fit together in Fabric as of January 2024, and when to choose something else.
Tomorrow we'll explore Real Time Dashboards for visualizing streaming data. Eventstream Documentation Event Hub Integration Streaming Best Practices
'{' ' "SoftDeletePeriod": "30.00:00:00",' ' "Recoverability": "Enabled"' '}'
Streaming improves the user experience significantly. Tomorrow, I will cover error handling for AI applications.
Real-Time Analytics in Fabric provides powerful streaming capabilities for time-sensitive workloads. Tomorrow, I will cover Power BI integration in Fabric.
Streaming transforms AI applications from feeling sluggish to feeling responsive. The implementation adds complexity, but the UX improvement is substantial.…
How stream=True works on the Azure OpenAI 2022-12-01 Completions API, what you give up by streaming, and how to relay tokens to a browser without losing any.
The built-in endpoint provides a reliable, scalable way to consume IoT device telemetry for real-time processing.
Azure's real time analytics stack enables instant insights from millions of events per second, powering live dashboards and alerts.
DLT streaming tables use append mode by default. For aggregations: DLT handles checkpointing automatically: Streaming tables in Delta Live Tables provide:…
Event Hubs with Kafka protocol offers: No Kafka cluster management Automatic scaling 99.99% SLA Native Azure integration Pay per throughput pricing Event…
The appeal of Spark Structured Streaming is that you write it almost identically to a batch Spark job. Same DataFrame API, same transformations, same Spark…
How to connect Auto Loader, Structured Streaming and Delta MERGE into a bronze, silver and gold pipeline that restarts safely and doesn't run up the bill.
Azure Media Services: broadcast-quality video for everyone.
Incrementally process files as they arrive. Structured Streaming makes real-time processing accessible with familiar DataFrame semantics.
The Kafka API compatibility makes Event Hubs a drop-in replacement for many streaming scenarios.