consumers.py 文件源码

def portfolioDataPush():
    for userid in redis_conn.hkeys("online-users"):
        userid = userid.decode("utf-8")
        try:
            portfolioData = portfolio(userid)
            Channel( redis_conn.hget("online-users",userid)).send(
                {
                'text': json.dumps(portfolioData,cls=DjangoJSONEncoder)
                })
        except:
            print("Error in portfolioPush")




#======================= SELL CHANNEL ==========================#