gis/xian_algorithm_new
13
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

存储标识符

Browse Source
This commit is contained in:
wzy-warehouse
2026-05-18 17:26:24 +08:00
parent 6dbcdf2a7f
commit 6df9b990c0
3 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/core/launcher.py
+1 -1
View File
@@ -56,7 +56,7 @@ def start():
# 启动降雨站点监测 # 启动降雨站点监测
logger.info("启动降雨站点监测服务...") logger.info("启动降雨站点监测服务...")
rainfall_manager.monitoring_rainfall_station_id('2025-08-20 12:00:00') rainfall_manager.monitoring_rainfall_station_id('2025-09-16 20:00:00')
# 阻塞主线程，防止程序立即退出 # 阻塞主线程，防止程序立即退出
block_main_thread() block_main_thread()
app/services/rainfall_grid_service.py
+2
View File
@@ -386,6 +386,7 @@ class RainfallGridService:
""" """
try: try:
redis_key = settings.REDIS_RAIN_STATION_GRID_KEY redis_key = settings.REDIS_RAIN_STATION_GRID_KEY
redis_identifier_key = settings.REDIS_RAIN_STATION_IDENTIFIER_KEY
# 处理query_time，可能是datetime对象或字符串 # 处理query_time，可能是datetime对象或字符串
if isinstance(query_time, datetime): if isinstance(query_time, datetime):
@@ -416,6 +417,7 @@ class RainfallGridService:
# 存储到Redis # 存储到Redis
redis_helper.set(redis_key, json.dumps(grid_info)) redis_helper.set(redis_key, json.dumps(grid_info))
redis_helper.set(redis_identifier_key, max_id)
self.logger.info(f"栅格信息已存储到Redis，key: {redis_key}, id: {max_id}") self.logger.info(f"栅格信息已存储到Redis，key: {redis_key}, id: {max_id}")
settings.toml
+2
View File
@@ -6,6 +6,8 @@ LOG_DIR = "logs"
RAIN_STATION_GRID_DIR = "/xian/rainfall/grid/images/:id" RAIN_STATION_GRID_DIR = "/xian/rainfall/grid/images/:id"
# 雨量站栅格存储redis的key # 雨量站栅格存储redis的key
REDIS_RAIN_STATION_GRID_KEY = "xian:rainfall:rain_station_grid" REDIS_RAIN_STATION_GRID_KEY = "xian:rainfall:rain_station_grid"
# 雨量站存储标识符的redis的key
REDIS_RAIN_STATION_IDENTIFIER_KEY = "xian:rainfall:rain_station_identifier"
# 开发环境 # 开发环境
[development] [development]