| | |
|---|
| | | from db import redis_manager_delegate as redis_manager |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | __db = 1 |
|---|
| | | _redisManager = redis_manager.RedisManager(1) |
|---|
| | | # l2数据管理 |
|---|
| | | # 本地最新一次上传的数据 |
|---|
| | |
|---|
| | | # 保存l2数据 |
|---|
| | | def save_l2_data(code, datas, add_datas): |
|---|
| | | # 只有有新曾数据才需要保存 |
|---|
| | | if len(add_datas) > 0: |
|---|
| | | if add_datas: |
|---|
| | | # 保存最近的数据 |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | if datas: |
|---|
| | | RedisUtils.setex_async(_redisManager.getRedis(), "l2-data-latest-{}".format(code), tool.get_expire(), |
|---|
| | | RedisUtils.setex_async(__db, "l2-data-latest-{}".format(code), tool.get_expire(), |
|---|
| | | json.dumps(datas)) |
|---|
| | | # l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "保存最近l2数据用时") |
|---|
| | | # 设置进内存 |
|---|
| | |
|---|
| | | async_log_util.l2_data_log.info(log.logger_l2_data, f"{code}-{add_datas}") |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | # 暂时不将数据保存到redis |
|---|
| | | # saveL2Data(code, add_datas) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 设置最新的l2数据采集的数量 |
|---|
