Friday 1 p.m.–3 p.m.

Scalable Pipelines w/ Luigi or: I’ll have the Data Engineering, hold the Java!

Jonathan Dinu

Audience level:
Intermediate

Description

In this workshop you see how (and why) to leverage the PyData ecosystem to build a robust data pipeline. More specifically you will learn how to use the Luigi framework to integrate multiple stages of a model building pipeline (collection, processing, vectorization, training of multiple models, and validation) all in Python!

Abstract

As companies scale prototypes and ad hoc analyses into production systems, it is critical to build automated (and repeatable) systems for data collection/processing and model training /evaluation which are fault tolerant enough to adapt to changing constraints. Sustainable software development is often an afterthought for data scientists, especially since the tools for analysis (R, scientific python, etc.) do not naturally lend themselves to building scalable and extensible software abstractions. But now we can have our cake and eat it too... all with Python!

In this workshop you see how (and why) to leverage the PyData ecosystem to build a robust data pipeline. More specifically you will learn how to use the Luigi framework to integrate multiple stages of a model building pipeline: collection, processing, vectorization, training of multiple models, and validation.

Outline:

  1. The basic components of a data pipeline (5min)
  2. What and Why Luigi (10min)
  3. Lab: The Smallest (1 stage) pipeline (15min)
  4. Managing dependencies in a pipeline (10min)
  5. Lab: Multi-stage pipeline and introduction to the Luigi Visualizer (15min)
  6. Serialization in a Data Pipeline (10min)
  7. Lab: Integrating your pipeline with HDFS and Postgres (20min)
  8. Scheduling (10min)
  9. Lab: Parallelism and recurring jobs with Luigi (20min)
  10. Wrap up and next steps (5min)

Sponsors


Become a sponsor.