Pipeline Extension for Live Trading
Branch: master
Clone or download
Latest commit d99ea88 Sep 1, 2018
Type Name Latest commit message Commit time
Failed to load latest commit information.
pipeline_live Update migration doc Sep 1, 2018
tests Rename package to pipeline_live Aug 26, 2018
.gitignore Init Aug 18, 2018
Pipfile Add engine test Aug 26, 2018
Pipfile.lock Rename package to pipeline_live Aug 26, 2018
README.md Update readme Sep 1, 2018
migration.md Update migration doc Sep 1, 2018
setup.cfg Rename package to pipeline_live Aug 26, 2018
setup.py Rename package to pipeline_live Aug 26, 2018


Zipline Pipeline Extension for Live Trading

pipeline-live is an extension for zipline pipeline independently usable for live trading, outside of zipline. While zipline is a great backtesting library, the default Pipeline API requires complicated setup for data bundle, which is often challenging to average users. Quantopian's proprietary data sources such as Morningstar is also not available to many. This library is to address this issue by using online API data sources and simplify the interface for live trading usage. The interface complies the original zipline/pipeline for the most part. For more details about the Pipeline API, please see Quantopian's tutorial and zipline document.

If you are looking to use this library for your Quantopian algorithm, check out the migration document.

Data Sources

This library predominantly relies on the IEX public data API for daily prices and fundamentals, but plans to connect to other data sources in the future. Currently supported data sources include the following.


pipeline-live is a PyPI module and you can install it using pip command.

$ pip install pipeline-live

This module is tested and expected to work with python 3.6 and later


Here is a simple pipeline example.

from pipeline_live.engine import LivePipelineEngine
from pipeline_live.data.sources.iex import list_symbols
from pipeline_live.data.iex.pricing import USEquityPricing
from pipeline_live.data.iex.fundamentals import IEXKeyStats
from pipeline_live.data.iex.factors import AverageDollarVolume
from zipline.pipeline import Pipeline

eng = LivePipelineEngine(list_symbols)
top5 = AverageDollarVolume(window_length=20).top(5)
pipe = Pipeline({
    'close': USEquityPricing.close.latest,
    'marketcap': IEXKeyStats.marketcap.latest,
}, screen=top5)

df = eng.run_pipeline(pipe)

        close     marketcap
AAPL   215.49  1.044037e+12
AMZN  1902.90  9.293372e+11
FB     172.90  5.042383e+11
QQQ    180.80  7.092998e+10
SPY    285.79  2.737475e+11

Data Cache

Since most of the data does not change during the day, the data access layer caches the dataset on disk. In case you need to purge the cache, the cache data is located in $ZIPLINE_ROOT/data/daily_cache.

Pipeline API


This class provides the similar interface to zipline.pipeline.engine.SimplePipelineEngine. The main difference is its run_pipeline does not require the start and end dates as parameters, and returns a DataFrame with the data for the current date (US/Eastern time). Its constructor accepts list_symbol function that is supposed to return the full set of symbols as a string list, which is used as the maximum universe inside the engine.

IEX Data Source API

You don't have to configure anything to use these API


This class provides the basic price information retrieved from IEX Chart API.


This provides the DataSet interface using IEX Company API.


This provides the DataSet interface using IEX Key Stats API.


It is important to note that the original builtin factors from zipline does not work here as is, since some of them rely on zipline's USEquityPricing class. This package provides the same set of zipline's builtin factor classes using pipeline_live.data.iex.pricing.USEquityPricing class. For the complete list of builtin factors, please refer zipline document


A shortcut for IEXCompany.sector.latest


A shortcut for IEXCompany.industry.latest

Alpaca/Polygon Data Source API

You will need to set Alpaca API key to use these API.


This class provides the DataSet interface using Polygon Symbol Details API


Experimental. This class filteres symbols by the following rule to return something close to IsPrimaryShare() in Quantopian.

  • must be a US company
  • must have a valid financial data