Merge pull request #1035 from akrherz/mrms_url

🐛 Update NCEP MRMS base URL

CHANGELOG.md

@@ -14,6 +14,7 @@ All notable changes to this library are documented in this file.
 ### Bug Fixes
 
 - Correct web links for SPC day 2,3 convective outlook.
+- Update NCEP MRMS base URL for real-time downloads.
 
 ## **1.23.0** (1 Mar 2025)
 

src/pyiem/mrms.py

@@ -13,6 +13,8 @@
 import numpy as np
 from affine import Affine
 
+from pyiem.util import LOG
+
 # NOTE: This is the info for the MRMS grib products, NOT the IEM netcdf
 # This is the center of the corner pixels
 WEST = -129.995
@@ -92,7 +94,7 @@ def get_url(center, valid, product):
                 f"/mrms/reanalysis/{product}/{fn}"
             )
     else:
-        uri = f"https://mrms{center}.ncep.noaa.gov/data/2D/{product}/MRMS_{fn}"
+        uri = f"https://mrms{center}.ncep.noaa.gov/2D/{product}/MRMS_{fn}"
     return uri
 
 
@@ -113,12 +115,15 @@ def fetch(product, valid: datetime, tmpdir="/mesonet/tmp"):
     tmpfn = os.path.join(tmpdir, fn)
     # Option 1, we have this file already in cache!
     if os.path.isfile(tmpfn):
+        LOG.info("Found %s in tmpdir cache", tmpfn)
         return tmpfn
     # Option 2, go fetch it from mtarchive
+    url = get_url("mtarchive", valid, product)
     try:
-        resp = httpx.get(get_url("mtarchive", valid, product), timeout=30)
+        resp = httpx.get(url, timeout=30)
         resp.raise_for_status()
     except Exception:
+        LOG.info("Failed to fetch %s", url)
         resp = None
     if resp and is_gzipped(resp.content):
         with open(tmpfn, "wb") as fd:
@@ -133,10 +138,12 @@ def fetch(product, valid: datetime, tmpdir="/mesonet/tmp"):
         return None
     # Loop over all IDP data centers
     for center in ["", "-bldr", "-cprk"]:
+        url = get_url(center, valid, product)
         try:
-            resp = httpx.get(get_url(center, valid, product), timeout=30)
+            resp = httpx.get(url, timeout=30)
             resp.raise_for_status()
         except Exception:
+            LOG.info("Failed to fetch %s", url)
             resp = None
         if resp and is_gzipped(resp.content):
             with open(tmpfn, "wb") as fd: