| | |
|---|
| | | # 保存最近的数据 |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | if datas: |
|---|
| | | RedisUtils.setex(_redisManager.getRedis(), "l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas)) |
|---|
| | | l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "保存最近l2数据用时") |
|---|
| | | RedisUtils.setex_async(_redisManager.getRedis(), "l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas)) |
|---|
| | | # l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "保存最近l2数据用时") |
|---|
| | | # 设置进内存 |
|---|
| | | local_latest_datas[code] = datas |
|---|
| | | set_l2_data_latest_count(code, len(datas)) |
|---|
| | |
|---|
| | | # 数据重复次数默认为1 |
|---|
| | | datas.append({"key": key, "val": item, "re": 1}) |
|---|
| | | dataIndexs.setdefault(key, len(datas) - 1) |
|---|
| | | # TODO 测试的时候开启，方便记录大单数据 |
|---|
| | | # 测试的时候开启，方便记录大单数据 |
|---|
| | | # l2_data_util.save_big_data(code, same_time_num, data) |
|---|
| | | return datas |
|---|
| | | |
|---|
