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 ==========================#
评论列表
文章目录