backend_live_runner.py 文件源码

def _getUserStrategy(self, downloadStrategyInterval=60):
    """??????????????
    downloadStrategyInterval: int default=60 ?
    return: df"""
    k = "SignForWebUser_preLoadTime"
    preLoadTime = myredis.get_obj(k)
    if preLoadTime is None:
        preLoadTime = datetime.datetime(2015, 10, 19, 15, 33, 47, 53000)    #????????
    #????
    if (agl.curTime() - preLoadTime).total_seconds() > downloadStrategyInterval:
        url = "http://stocksign.sinaapp.com/query?cmd=query_strategy"
        result = Http().get(url)
        df_source = pd.read_json(result)
        df_source.columns = ['id', 'user_id', 'title', 'code']
        preLoadTime = agl.curTime()
        myredis.set_obj(k, preLoadTime)
        myredis.set_obj('mysource', df_source)
    else:
        df_source = myredis.get_obj('mysource')
        if df_source is None:
        df_source = pd.DataFrame([])
    return df_source