consumers.py 文件源码

def sellDataPush():
    for userid in redis_conn.hkeys("online-sellers"):
        userid = userid.decode("utf-8")
        try:
            sellData = sell_data(userid)
            Channel( redis_conn.hget("online-sellers",userid) ).send(
                {
                'text' : json.dumps(sellData,cls=DjangoJSONEncoder)
                })
        except:
            print("sellDataPush failed!")



#================ Ticker Channel =======================#