@bundles.register('quandl')
def quandl_bundle(environ, asset_db_writer, minute_bar_writer, daily_bar_writer, adjustment_writer, calendar, start_session, end_session, cache, show_progress, output_dir):
 api_key = environ.get('QUANDL_API_KEY')
 metadata = fetch_symbol_metadata_frame(api_key, cache=cache, show_progress=show_progress)
 symbol_map = metadata.symbol
 splits = []
 dividends = []
 asset_db_writer.write(metadata)
 daily_bar_writer.write(gen_symbol_data(api_key, cache, symbol_map, calendar, start_session, end_session, splits, dividends, environ.get('QUANDL_DOWNLOAD_ATTEMPTS', 5)), show_progress=show_progress)
 adjustment_writer.write(splits=pd.concat(splits, ignore_index=True), dividends=pd.concat(dividends, ignore_index=True))

@ bundles . register ( 'quandl' ) def quandl_bundle ( environ , asset_db_writer , minute_bar_writer , daily_bar_writer , adjustment_writer , calendar , start_session , end_session , cache , show_progress , output_dir ) : api_key = environ . get ( 'QUANDL_API_KEY' ) metadata = fetch_symbol_metadata_frame ( api_key , cache = cache , show_progress = show_progress ) symbol_map = metadata . symbol splits = [ ] dividends = [ ] asset_db_writer . write ( metadata ) daily_bar_writer . write ( gen_symbol_data ( api_key , cache , symbol_map , calendar , start_session , end_session , splits , dividends , environ . get ( 'QUANDL_DOWNLOAD_ATTEMPTS' , 5 ) ) , show_progress = show_progress ) adjustment_writer . write ( splits = pd . concat ( splits , ignore_index = True ) , dividends = pd . concat ( dividends , ignore_index = True ) )
build a zipline data bundle from the quandl wiki dataset .