gavindiaz/PolyWeather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

接入伊斯坦布尔机场 MGM 17058 高频推送

Browse Source 
伊斯坦布尔新机场 (LTFM, MGM 17058) 加入 10 分钟级推送队列，
obs_log 已有 MGM 数据覆盖，只需加入高频城市列表。

马德里 AEMET 注册地址：https://opendata.aemet.es/centrodedescargas/registro

Tested: pytest 176 passed, ruff check 通过
This commit is contained in:
2569718930@qq.com
2026-05-12 20:48:02 +08:00
parent 84e7518b04
commit 12c2b39b16
3 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/analysis/market_alert_engine.py
+1 -1
View File
@@ -813,7 +813,7 @@ def _build_advice_cn(
return "，".join(parts) + "。"
_AIRPORT_ICAO_MAP = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM"}
_AIRPORT_ICAO_MAP = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058"}
def _calc_airport_rapid_temp_change(
src/bot/runtime_coordinator.py
+1 -1
View File
@@ -190,7 +190,7 @@ class StartupCoordinator:
details = {
"mode": "airport-periodic",
"interval_sec": interval,
"cities": ["seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam"],
"cities": ["seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul"],
"chat_targets": len(chat_ids),
"window": "DEB proximity ≤3°C",
}
src/utils/telegram_push.py
+4 -3
View File
@@ -690,8 +690,8 @@ def start_trade_alert_push_loop(bot: Any, config: Dict[str, Any]) -> Optional[th
# ── high-freq airport push loop ──
HIGH_FREQ_AIRPORT_CITIES = {"seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam"}
HIGH_FREQ_AIRPORT_ICAO = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM"}
HIGH_FREQ_AIRPORT_CITIES = {"seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul"}
HIGH_FREQ_AIRPORT_ICAO = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058"}
_AIRPORT_PUSH_STATE_PATH = os.path.join(
os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))),
@@ -723,7 +723,7 @@ def _save_airport_state(state: Dict[str, Any]) -> None:
os.replace(tmp, path)
_AIRPORT_CITY_LABEL = {"seoul": "首尔/仁川", "busan": "釜山/金海", "tokyo": "东京/羽田", "ankara": "安卡拉/Esenboğa", "helsinki": "赫尔辛基/Vantaa", "amsterdam": "阿姆斯特丹/Schiphol"}
_AIRPORT_CITY_LABEL = {"seoul": "首尔/仁川", "busan": "釜山/金海", "tokyo": "东京/羽田", "ankara": "安卡拉/Esenboğa", "helsinki": "赫尔辛基/Vantaa", "amsterdam": "阿姆斯特丹/Schiphol", "istanbul": "伊斯坦布尔/机场"}
def _build_airport_status_message(
@@ -772,6 +772,7 @@ _AIRPORT_PUSH_INTERVAL = {
"ankara": 600, # MGM ~10-min
"helsinki": 600, # FMI 10-min
"amsterdam": 600, # KNMI 10-min
"istanbul": 600, # MGM ~10-min
}
_DEB_PROXIMITY_THRESHOLD_C = 3.0