Skip to content

Latest commit

 

History

History
160 lines (113 loc) · 8.66 KB

README.md

File metadata and controls

160 lines (113 loc) · 8.66 KB
Raw

SRF Quick Start Guide

🏄 Learn to SRF and Catch the Wave to GPU-Accelerated Streaming Pipelines 🏄

The SRF Quick Start Guide (QSG) provides Python, C++, and Hybrid (Python and C++) examples on how to get started building high-performance streaming pipelines with the SRF library. The goal of this tutorial is to provide a gentle on-ramp to building applications with SRF and is targeted towards a wide persona of developers - ranging from data scientists to performance engineers.

Table of Contents

Environment Setup

To get started with the Quick Start Guide, it is necessary to install the required SRF components and dependencies before running any of the examples. Similar to the SRF library, this tutorial supports installation either via Conda (preferred) or by building from source.

Installing Examples via Conda

If you've alredy followed the SRF library installation instructions in the main project README, you've most likely already created a Conda environment from which either srf (Python) or libsrf (C++) was installed. In this case, you can install the QSG dependencies and build the examples with:

# Change directory to the quickstart root
cd ${SRF_HOME}/docs/quickstart/

# Update the existing SRF conda environment. Here, we assume the environment is named `srf`, but you can change this to the environment name you used, if different
conda env update -n srf -f environment_cpp.yml
conda activate srf

# Build the QSG including the C++ examples
./compile.sh

# Install Python module (srf_qs_python) to build the SRF QSG Python examples
pip install -e python

If you haven't installed SRF or would like to create an entirely new Conda environment for the Quick Start Guide, run:

# Change directory to the quickstart root
cd ${SRF_HOME}/docs/quickstart/

# Create a new SRF conda environment. Here, we assume the environment is named `srf-quickstart`
conda env create -n srf-quickstart -f environment_cpp.yml
conda activate srf-quickstart

# Build the QSG including the C++ examples
./compile.sh

# Install Python module (srf_qs_python) to build the SRF QSG Python examples
pip install -e python

Note: If you encounter errors building the examples, this is mostly likely caused for two reasons:

  1. You forgot to activate your Conda environment prior to running ./compile.sh
  2. There's a stale build lingering which needs to be cleared with rm -rf build before running ./compile.sh again

Installing Examples via Source

A comprehensive overview of building SRF from source is provided in the SRF README. To build the Quick Start Guide examples, simply run

cd ${SRF_HOME}/docs/quickstart

# Build the QSG including the C++ examples
./compile.sh

# Install Python module (srf_qs_python) to build the SRF QSG Python examples
pip install -e python

Python SRF Examples

For users interested in using SRF from Python, the QSG provides several examples in the docs/quickstart/python/srf_qs_python directory. These examples are organized into separate folders each showing a different topic. Each example directory has a name with the format, ex##_${EXAMPLE_NAME}, where XX represents the example number (in increasing complexity) and ${EXAMPLE_NAME} is the example name. Below is a list of the available examples and a brief description:

# Name Description
00 simple_pipeline A small, basic pipeline with only a single source, node and sink
01 custom_data Similar to simple_pipeline, but passes a custom data type between nodes
02 reactive_operators Demonstrates how to use Reactive style operators inside of nodes for more complex functionality
03 config_options Illustrates how thread and buffer options can alter performance

Once installed, the examples can be run from any directory.

Running the Python SRF Examples

Each example directory contains a README.md file with information about the example and a run.py Python file. To run any of the examples, simply launch the run.py file from python:

python docs/quickstart/python/srf_qs_python/**ex##_ExampleName**/run.py

Some examples have configurable options to alter the behavior of the example. To see what options are available, pass --help to the example's run.py file. For example:

$ python docs/quickstart/python/srf_qs_python/ex03_config_options/run.py --help
usage: run.py [-h] [--count COUNT] [--channel_size CHANNEL_SIZE] [--threads THREADS]

ConfigOptions Example.

optional arguments:
  -h, --help            show this help message and exit
  --count COUNT         The number of items for the source to emit
  --channel_size CHANNEL_SIZE
                        The size of the inter-node buffers. Must be a power of 2
  --threads THREADS     The number of threads to use.

C++ SRF Examples

For users interested in using SRF with C++, the QSG provides several examples in the docs/quickstart/cpp directory. These examples are organized into separate folders each showing a different topic. Each example directory has a name with the format, ex##_${EXAMPLE_NAME}, where XX represents the example number (in increasing complexity) and ${EXAMPLE_NAME} is the example name. Below is a list of the available examples and a brief description:

# Name Description
00 simple_pipeline A small, basic pipeline with only a single source, node and sink
01 node_library Illustrates hopw to create SRF components in a reusable library
02 pipeline_with_library Demonstrates how to use the SRF components from Example #01 in a SRF Pipeline

Running the C++ SRF Examples

Each example directory contains a README.md file with information about the example. To run any of the examples, follow the instructions in the README.md for launching the example.

Hybrid (Python and C++) SRF Examples

For users interested in using SRF in a hybrid environment with both C++ and Python, the QSG provides several examples in the docs/quickstart/hybrid/srf_qs_hybrid directory. These examples are organized into separate folders each showing a different topic. Each example directory has a name with the format, ex##_${EXAMPLE_NAME}, where XX represents the example number (in increasing complexity) and ${EXAMPLE_NAME} is the example name. Below is a list of the available examples and a brief description:

# Name Description
00 wrap_data_objects How to run a pipeline in Python using C++ data objects
01 wrap_nodes How to run a pipeline in Python using sources, sinks, and nodes defined in C++
02 mixed_execution How to run a pipeline with some nodes in python and others in C++

Running the Hybrid SRF Examples

Each example directory contains a README.md file with information about the example and a run.py python file. To run any of the examples, simply launch the run.py file from python:

python docs/quickstart/hybrid/srf_qs_python/<ex##_ExampleName>/run.py

Some examples have configurable options to alter the behavior of the example. To see what options are available, pass --help to the example's run.py file. For example:

$ python docs/quickstart/hybrid/srf_qs_hybrid/ex02_mixed_execution/run.py --help
usage: run.py [-h] [--python_source] [--python_node] [--python_sink]

mixed_execution Example.

optional arguments:
  -h, --help       show this help message and exit
  --python_source  Specifying this argument will run the pipeline with a python source
  --python_node    Specifying this argument will run the pipeline with a python node
  --python_sink    Specifying this argument will run the pipeline with a python sink