view.py 文件源码

def msgpack_lz4_to_series(data):
    try:
        import msgpack
        import lz4
    except ImportError:
        logging.info('To load lz4-msgpacked data, '
                     'install packages "python-msgpack" and "lz4"')
        raise
    content = msgpack.loads(lz4.decompress(data))
    series_load = lambda d: pd.Series(
        data=d['values'],
        index=d['index'] if d['index'][-1] <= 1e9 \
                         else pd.DatetimeIndex(d['index']),
        name=d['id']
    )
    seria = list(map(series_load, content))

    return seria