The code from the whylogs workshop in DataTalks.Club on 29 March 2022
whylogs - The open source standard for data logging (Don't forget to give it a star!)
In this hands-on workshop, we’ll learn how to set up a system for monitoring your data pipelines, ensuring data quality and detecting changes in your data.
Without data monitoring, it’s impossible to guarantee to your stakeholders that the data that they are using for their analytics and machine learning use cases is trustworthy. By setting up a data observability system, you’ll be able to get visibility into the health of your data pipelines, thus building your customers’ trust in your work.
We’ll cover the following:
- Introduction to data observability and monitoring
- whylogs — the open source standard for data logging
- How to monitor batch Python or Spark data pipelines with whylogs
- How to monitor Kafka streaming pipelines with whylogs
By the end of this workshop, you’ll be able to set up such a system yourself.
This repository contains files that are needed for the workshop:
ccloud_lib.py
- file for connecting to confluent cloudconfluent_credentials.txt
- template for configuration (put your credentials there - but don't commit them!)producer.py
- the code for putting events to Kafkarequirements.txt
- all the dependencies for the workshop
For this workshop, you'll need
- Account in Deepnote
- Account in Confluent cloud (instructions)