Faust: Stream Processing Using Models, Agents, & Channels

Faust 1.10    |    Intermediate
  • 12 Videos | 1h 36m 42s
  • Includes Assessment
  • Earns a Badge
Stream processing in Faust uses native Python code, meaning you don't have to learn a new domain-specific language to perform data transformations. All you need to know is how existing concepts, such as models, work within a Faust context. Faust models allow you to specify fields and their data types and use this well-defined data structure to access streaming data. In this course, you'll learn how to represent the individual elements of a stream using Faust models. You'll work with agents, which are at the heart of every Faust stream processing application. You'll perform operations using agents and invoke agents synchronously and asynchronously from within your application. You'll then work with channels in Faust. At the end of this course, you'll have the confidence to use models, agents, and channels in the right way to build a successful application.

WHAT YOU WILL LEARN

  • discover the key concepts covered in this course
    use models to represent stream elements
    create models with multiple fields and different data types
    publish messages to a Kafka topic using the pykafka library
    invoke the ask() method to await processing results from an agent
    invoke the cast() method to await processing results from an agent
  • use multiple agents for chained processing of data
    use multiple agents to process elements from different topics
    use channels to send and receive messages
    create streams manually using the .stream() method
    define stream processors to transform stream elements
    summarize the key concepts covered in this course

IN THIS COURSE

  • Playable
    1. 
    Course Overview
    2m 21s
    UP NEXT
  • Playable
    2. 
    Using Faust Models for Stream Elements
    12m 25s
  • Locked
    3. 
    Specifying Multiple Model Fields in Faust
    5m 48s
  • Locked
    4. 
    Programmatically Publishing Messages to Kafka
    8m 14s
  • Locked
    5. 
    Invoking the ask() Method on Faust Agents
    12m 13s
  • Locked
    6. 
    Invoking the cast() Method on Faust Agents
    4m 32s
  • Locked
    7. 
    Using Multiple Faust Agents for Chained Processing
    12m 59s
  • Locked
    8. 
    Using Multiple Faust Agents for Multiple Topics
    4m 56s
  • Locked
    9. 
    Using Faust Channels to Send and Receive Messages
    9m 45s
  • Locked
    10. 
    Manually Creating Streams in Faust
    8m 1s
  • Locked
    11. 
    Defining Stream Processors in Faust
    8m 6s
  • Locked
    12. 
    Course Summary
    2m 24s

EARN A DIGITAL BADGE WHEN YOU COMPLETE THIS COURSE

Skillsoft is providing you the opportunity to earn a digital badge upon successful completion of this course, which can be shared on any social network or business platform

Digital badges are yours to keep, forever.