def on_message(self, _ws, msg):
    ts = int((time.time() * 1000))
    rdk = self.Config['RedisCollectKey']
    self.RedisConnection.lpush(rdk, json.dumps([ts, msg]))
def on_message(self, _ws, msg):
    ts = int((time.time() * 1000))
    rdk = self.Config['RedisCollectKey']
    self.RedisConnection.lpush(rdk, json.dumps([ts, msg]))