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

remove Shenzhen airport Telegram push

Browse Source
This commit is contained in:
2569718930@qq.com
2026-06-11 16:08:33 +08:00
parent 87bf7c3575
commit 8e4a9ae552
2 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/utils/telegram_push.py
+6 -6
View File
@@ -608,7 +608,7 @@ def _alert_signature(alert_payload: Dict[str, Any]) -> str:
HIGH_FREQ_AIRPORT_CITIES = { HIGH_FREQ_AIRPORT_CITIES = {
"seoul", "singapore", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "seoul", "singapore", "busan", "tokyo", "ankara", "helsinki", "amsterdam",
"istanbul", "paris", "hong kong", "shenzhen", "taipei", "istanbul", "paris", "hong kong", "taipei",
"beijing", "shanghai", "guangzhou", "qingdao", "chengdu", "chongqing", "wuhan", "beijing", "shanghai", "guangzhou", "qingdao", "chengdu", "chongqing", "wuhan",
"new york", "los angeles", "chicago", "denver", "atlanta", "new york", "los angeles", "chicago", "denver", "atlanta",
"miami", "san francisco", "houston", "dallas", "austin", "seattle", "miami", "san francisco", "houston", "dallas", "austin", "seattle",
@@ -620,7 +620,7 @@ CHINA_HIGH_FREQ_AIRPORT_CITIES = {
HIGH_FREQ_AIRPORT_ICAO = { HIGH_FREQ_AIRPORT_ICAO = {
"seoul": "RKSI", "singapore": "WSSS", "busan": "RKPK", "tokyo": "44166", "seoul": "RKSI", "singapore": "WSSS", "busan": "RKPK", "tokyo": "44166",
"ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058",
"paris": "LFPB", "hong kong": "HKO", "shenzhen": "LFS", "taipei": "466920", "paris": "LFPB", "hong kong": "HKO", "taipei": "466920",
"beijing": "ZBAA", "shanghai": "ZSPD", "guangzhou": "ZGGG", "qingdao": "ZSQD", "beijing": "ZBAA", "shanghai": "ZSPD", "guangzhou": "ZGGG", "qingdao": "ZSQD",
"chengdu": "ZUUU", "chongqing": "ZUCK", "wuhan": "ZHHH", "chengdu": "ZUUU", "chongqing": "ZUCK", "wuhan": "ZHHH",
"new york": "KLGA", "los angeles": "KLAX", "chicago": "KORD", "new york": "KLGA", "los angeles": "KLAX", "chicago": "KORD",
@@ -1125,7 +1125,7 @@ def _build_airport_status_message(
_AIRPORT_EN = {"seoul": "Incheon", "singapore": "Changi", "busan": "Gimhae", "tokyo": "Haneda", _AIRPORT_EN = {"seoul": "Incheon", "singapore": "Changi", "busan": "Gimhae", "tokyo": "Haneda",
"ankara": "Esenboğa", "helsinki": "Vantaa", "amsterdam": "Schiphol", "ankara": "Esenboğa", "helsinki": "Vantaa", "amsterdam": "Schiphol",
"istanbul": "Airport", "paris": "Le Bourget", "istanbul": "Airport", "paris": "Le Bourget",
"hong kong": "Observatory", "shenzhen": "LFS Observatory", "hong kong": "Observatory",
"taipei": "Songshan", "beijing": "Capital", "shanghai": "Pudong", "taipei": "Songshan", "beijing": "Capital", "shanghai": "Pudong",
"guangzhou": "Baiyun", "qingdao": "Jiaodong", "guangzhou": "Baiyun", "qingdao": "Jiaodong",
"chengdu": "Shuangliu", "chongqing": "Jiangbei", "wuhan": "Tianhe", "chengdu": "Shuangliu", "chongqing": "Jiangbei", "wuhan": "Tianhe",
@@ -1507,7 +1507,7 @@ def _load_airport_city_weather_for_push(city: str) -> Dict[str, Any]:
_AIRPORT_HEAT_THRESHOLD = { _AIRPORT_HEAT_THRESHOLD = {
"seoul": 3.0, "ankara": 3.0, "istanbul": 3.0, "paris": 3.0, "seoul": 3.0, "ankara": 3.0, "istanbul": 3.0, "paris": 3.0,
"busan": 2.0, "tokyo": 2.0, "amsterdam": 2.0, "helsinki": 2.0, "busan": 2.0, "tokyo": 2.0, "amsterdam": 2.0, "helsinki": 2.0,
"hong kong": 1.5, "shenzhen": 1.5, "taipei": 1.5, "hong kong": 1.5, "taipei": 1.5,
} }
@@ -1675,8 +1675,8 @@ def _process_airport_city(
elif current_temp is None or deb_pred is None: elif current_temp is None or deb_pred is None:
return None return None
# Dedup: same observation → skip (with delayed retry for HK / LFS) # Dedup: same observation → skip (with delayed retry for HKO)
_CITIES_WITH_DELAYED_API = {"hong kong", "shenzhen"} _CITIES_WITH_DELAYED_API = {"hong kong"}
if (current_obs_time and last_obs_time and current_obs_time == last_obs_time if (current_obs_time and last_obs_time and current_obs_time == last_obs_time
and city in _CITIES_WITH_DELAYED_API and city in _CITIES_WITH_DELAYED_API
and now_ts - last_city_ts > 540): and now_ts - last_city_ts > 540):
tests/test_telegram_hashtags.py
+4 -6
View File
@@ -165,11 +165,9 @@ def test_singapore_is_in_telegram_push_city_lists():
assert HIGH_FREQ_AIRPORT_ICAO["singapore"] == "WSSS" assert HIGH_FREQ_AIRPORT_ICAO["singapore"] == "WSSS"
def test_shenzhen_is_in_high_freq_push_as_hko_station(): def test_shenzhen_is_not_in_airport_push_city_lists():
# shenzhen uses LFS / HKO 1-min data (formerly lau fau shan) assert "shenzhen" not in HIGH_FREQ_AIRPORT_CITIES
assert "shenzhen" in HIGH_FREQ_AIRPORT_CITIES assert "shenzhen" not in HIGH_FREQ_AIRPORT_ICAO
assert "shenzhen" in HIGH_FREQ_AIRPORT_ICAO
assert HIGH_FREQ_AIRPORT_ICAO["shenzhen"] == "LFS"
def test_china_airport_push_defaults_to_one_minute_city_interval(): def test_china_airport_push_defaults_to_one_minute_city_interval():
@@ -433,7 +431,7 @@ def test_airport_push_retries_main_chat_when_forum_thread_is_missing(monkeypatch
monkeypatch.setattr(telegram_push, "_rate_limited_send", fake_send) monkeypatch.setattr(telegram_push, "_rate_limited_send", fake_send)
result = telegram_push._process_airport_city( result = telegram_push._process_airport_city(
"shenzhen", "hong kong",
now_ts=1781164400, now_ts=1781164400,
last_city={}, last_city={},
chat_ids=["chat-1"], chat_ids=["chat-1"],