Serverless Data Processing with Dataflow - Using Dataflow for Streaming Analytics (Python)
This exercise is part of the course
Serverless Data Processing with Dataflow: Develop Pipelines
Exercise instructions
In this lab you read data from a streaming source, perform the same aggregations you performed before, and write out results in a streaming fashion to BigQuery. You will also experiment with the difference in processing time and event time with lagging (late) data.