GEFS download fixes #3349
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -17,21 +17,11 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
|
|
||
|
|
||
| download_grid <- function(ens_index, location, directory, hours_char, cycle, base_filename1, vars,working_directory){ | ||
| ens_base <- if (ens_index == 1) { "gec" } else { "gep" } | ||
| ens_idx <- stringr::str_pad(ens_index - 1, width = 2, pad = "0") | ||
| base_filename2 <- paste0(ens_base,ens_idx,".t",cycle,"z.pgrb2a.0p50.f") | ||
infotroph marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| curr_hours <- hours_char | ||
|
|
||
| for(i in 1:length(curr_hours)){ | ||
| file_name <- paste0(base_filename2, curr_hours[i]) | ||
|
|
||
|
|
@@ -73,37 +63,12 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
|
|
||
| model_dir <- file.path(output_directory, model_name_raw) | ||
|
|
||
| #Availability: most recent 4 days | ||
| curr_time <- lubridate::with_tz(Sys.time(), tzone = "UTC") | ||
| curr_date <- lubridate::as_date(curr_time) | ||
|
There was a problem hiding this comment. These pages (here and on deleted line 91 below) load fine in a browser, but inside R and via curl they throw There was a problem hiding this comment. My experience is there can be delays in when files show up and occasionally gaps, which is why we didn't just assume forecasts are always there. There was a problem hiding this comment. That's good to know, but note that the existing code only checked whether there exists a date folder that matches the requested forecast date, not whether all forecasts (or even all cycles) are present in it. How often do delays/gaps occur at the whole-day level? Each individual file download (line 50 above) is wrapped in a tryCatch, so for both old and new code the likeliest outcome when files are missing will be a series of "skipping" messages (possibly then followed by a failure when downscaling can't bridge the time gap). Is that acceptable for this PR or do we need to dig further in on pre-download availability checks? |
||
infotroph marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| potential_dates <- curr_date - lubridate::days(3:0) | ||
|
|
||
| potential_dates <- potential_dates[which(potential_dates == forecast_date)] | ||
|
|
||
| if(length(potential_dates) == 0){PEcAn.logger::logger.error("Forecast Date not available")} | ||
|
|
||
|
|
@@ -118,7 +83,10 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
| floor(min(lat_list))) | ||
|
|
||
| base_filename1 <- "https://nomads.ncep.noaa.gov/cgi-bin/filter_gefs_atmos_0p50a.pl?file=" | ||
| vars <- paste0( | ||
| "&lev_10_m_above_ground=on&lev_2_m_above_ground=on&lev_surface=on&lev_entire_atmosphere=on", | ||
| "&var_APCP=on&var_DLWRF=on&var_DSWRF=on&var_PRES=on&var_RH=on&var_TMP=on", | ||
| "&var_UGRD=on&var_VGRD=on&var_TCDC=on") | ||
|
|
||
| for(i in 1:length(potential_dates)){ | ||
|
|
||
|
|
@@ -143,11 +111,11 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
| print(paste("Downloading", forecast_date, cycle)) | ||
|
|
||
| if(cycle == "00"){ | ||
| hours <- c(seq(0, 240, 3),seq(246, 840, 6)) | ||
| }else{ | ||
| hours <- c(seq(0, 240, 3),seq(246, 384 , 6)) | ||
| } | ||
| hours <- hours[hours<=end_hr] | ||
infotroph marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| hours_char <- hours | ||
| hours_char[which(hours < 100)] <- paste0("0",hours[which(hours < 100)]) | ||
| hours_char[which(hours < 10)] <- paste0("0",hours_char[which(hours < 10)]) | ||
|
|
@@ -163,12 +131,12 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
|
|
||
| parallel::mclapply(X = ens_index, | ||
| FUN = download_grid, | ||
| location = location, | ||
| directory = directory, | ||
| hours_char = hours_char, | ||
| cycle = cycle, | ||
| base_filename1 = base_filename1, | ||
| vars = vars, | ||
|
|
||
| working_directory = model_date_hour_dir, | ||
| mc.cores = 1) | ||
| }else{ | ||
|
|
@@ -177,6 +145,9 @@ noaa_grid_download <- function(lat_list, lon_list, forecast_time, forecast_date, | |
| } | ||
| } | ||
| } | ||
|
|
||
|
|
||
|
|
||
| #' Extract and temporally downscale points from downloaded grid files | ||
| #' | ||
| #' @param lat_list lat for site | ||
|
|
@@ -222,23 +193,13 @@ process_gridded_noaa_download <- function(lat_list, | |
| dlwrfsfc <- array(NA, dim = c(site_length, length(hours_char))) | ||
| dswrfsfc <- array(NA, dim = c(site_length, length(hours_char))) | ||
|
|
||
| ens_base <- if (ens_index == 1) { "gec" } else { "gep" } | ||
| ens_name <- stringr::str_pad(ens_index - 1, width = 2, pad = "0") | ||
| base_filename2 <- paste0(ens_base,ens_name,".t",cycle,"z.pgrb2a.0p50.f") | ||
|
There was a problem hiding this comment. Just for clarity -- this block was not producing errors
infotroph marked this conversation as resolved.
Show resolved
Hide resolved
|
||
|
|
||
| lats <- round(lat_list/.5)*.5 | ||
| lons <- round(lon_list/.5)*.5 | ||
|
Comment on lines
200
to
201
There was a problem hiding this comment. Not for this PR, but: GEFS is now also available on a 0.25 degree grid. Would it be of interest to add support for that? |
||
|
|
||
|
There was a problem hiding this comment. We're comparing these longitudes to the raw values in the grib file, which have negative values for west lon. I assume this must have changed at some point since these lines were written, but can't find any reference to it in the GEFS changelogs. |
||
| curr_hours <- hours_char | ||
|
|
||
| for(hr in 1:length(curr_hours)){ | ||
|
|
@@ -263,8 +224,13 @@ process_gridded_noaa_download <- function(lat_list, | |
| vgrd10m[s, hr] <- grib_data_df$`10[m] HTGL=Specified height level above ground; v-component of wind [m/s]`[index] | ||
|
|
||
| if(curr_hours[hr] != "000"){ | ||
| # total precip alternates being named as 3 or 6 hr total | ||
| # TODO: not sure if the contents actually differ or if this is a labeling bug in the grib files | ||
| precip_hr <- if ((as.numeric(curr_hours[hr]) %% 2) == 1) { "03" } else { "06" } | ||
| precip_name <- paste("SFC=Ground or water surface;", precip_hr, "hr Total precipitation [kg/(m^2)]") | ||
| apcpsfc[s, hr] <- grib_data_df[[precip_name]][index] | ||
|
|
||
| tcdcclm[s, hr] <- grib_data_df$`EATM=Entire Atmosphere; Total cloud cover [%]`[index] | ||
|
Comment on lines
+227
to
+233
There was a problem hiding this comment. This is weird and I don't understand why the grib files do it (or whether that means the interpretation of the precip totals should change from one time to the next), but I checked multiple sites and forecast days and the alternation is definitely there in the raw gribs. There was a problem hiding this comment. Note also the change in cloud cover name from "RESERVED..." to "EATM..." -- I would have expected this to show up in a changelog somewhere as well, but haven't been able to find any references to it. |
||
| dswrfsfc[s, hr] <- grib_data_df$`SFC=Ground or water surface; Downward Short-Wave Rad. Flux [W/(m^2)]`[index] | ||
| dlwrfsfc[s, hr] <- grib_data_df$`SFC=Ground or water surface; Downward Long-Wave Rad. Flux [W/(m^2)]`[index] | ||
| } | ||
|
|
@@ -301,17 +267,15 @@ process_gridded_noaa_download <- function(lat_list, | |
|
|
||
|
|
||
|
|
||
| cycle <- forecast_time | ||
infotroph marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| curr_forecast_time <- forecast_date + lubridate::hours(cycle) | ||
| cycle <- stringr::str_pad(cycle, width = 2, pad = "0") | ||
| if (cycle == "00") { | ||
| hours <- c(seq(0, 240, 3),seq(246, 840, 6)) | ||
| } else { | ||
| hours <- c(seq(0, 240, 3),seq(246, 384, 6)) | ||
| } | ||
| hours_char <- stringr::str_pad(hours, width = 3, pad = "0") # 3->"003", 384->"384" | ||
|
|
||
| raw_files <- list.files(file.path(model_name_raw_dir,forecast_date,cycle)) | ||
| hours_present <- as.numeric(stringr::str_sub(raw_files, start = 25, end = 27)) | ||
|
|
@@ -341,19 +305,21 @@ process_gridded_noaa_download <- function(lat_list, | |
| FUN = extract_sites, | ||
| hours_char = hours_char, | ||
| hours = hours, | ||
| cycle = cycle, | ||
| site_id = site_id, | ||
| lat_list = lat_list, | ||
| lon_list = lon_list, | ||
| working_directory = file.path(model_name_raw_dir,forecast_date,cycle), | ||
| mc.cores = 1) | ||
|
|
||
|
|
||
| forecast_times <- lubridate::as_datetime(forecast_date) + | ||
| lubridate::hours(as.numeric(cycle)) + | ||
| lubridate::hours(as.numeric(hours_char)) | ||
|
|
||
|
|
||
|
|
||
| #Convert negative longitudes to degrees east | ||
| if(lon_list < 0){ | ||
| lon_east <- 360 + lon_list | ||
| }else{ | ||
|
|
@@ -425,17 +391,18 @@ process_gridded_noaa_download <- function(lat_list, | |
| #Calculate wind speed from east and north components | ||
| wind_speed <- sqrt(noaa_data$eastward_wind$value^2 + noaa_data$northward_wind$value^2) | ||
|
|
||
| forecast_noaa <- tibble::tibble( | ||
| time = noaa_data$air_temperature$forecast.date, | ||
| NOAA.member = noaa_data$air_temperature$ensembles, | ||
| air_temperature = noaa_data$air_temperature$value, | ||
| air_pressure= noaa_data$air_pressure$value, | ||
| relative_humidity = noaa_data$relative_humidity$value, | ||
| surface_downwelling_longwave_flux_in_air = noaa_data$surface_downwelling_longwave_flux_in_air$value, | ||
| surface_downwelling_shortwave_flux_in_air = noaa_data$surface_downwelling_shortwave_flux_in_air$value, | ||
| precipitation_flux = noaa_data$precipitation_flux$value, | ||
| specific_humidity = specific_humidity, | ||
| cloud_area_fraction = noaa_data$cloud_area_fraction$value, | ||
| wind_speed = wind_speed) | ||
|
|
||
| forecast_noaa$cloud_area_fraction <- forecast_noaa$cloud_area_fraction / 100 #Convert from % to proportion | ||
|
|
||
|
|
@@ -455,14 +422,10 @@ process_gridded_noaa_download <- function(lat_list, | |
| for (ens in 1:31) { # i is the ensemble number | ||
|
|
||
| #Turn the ensemble number into a string | ||
| ens_name <- stringr::str_pad(ens - 1, width = 2, pad = "0") | ||
|
|
||
| forecast_noaa_ens <- forecast_noaa %>% | ||
| dplyr::filter(.data$NOAA.member == ens) %>% | ||
| dplyr::filter(!is.na(.data$air_temperature)) | ||
|
|
||
| end_date <- forecast_noaa_ens %>% | ||
|
|
@@ -525,6 +488,15 @@ process_gridded_noaa_download <- function(lat_list, | |
| return(results_list) | ||
| } #process_gridded_noaa_download | ||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
| #' @title Downscale NOAA GEFS from 6hr to 1hr | ||
| #' @return None | ||
| #' | ||
|
|
@@ -645,6 +617,14 @@ temporal_downscale <- function(input_file, output_file, overwrite = TRUE, hr = 1 | |
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
|
|
||
| ##' @title Write NOAA GEFS netCDF | ||
| ##' @name write_noaa_gefs_netcdf | ||
| ##' @param df data frame of meterological variables to be written to netcdf. Columns | ||
|
|
@@ -711,4 +691,4 @@ write_noaa_gefs_netcdf <- function(df, ens = NA, lat, lon, cf_units, output_file | |
|
|
||
| ncdf4::nc_close(nc_flptr) #Write to the disk/storage | ||
| } | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Most of my changes in this hunk are just to simplify the logic, but flagging that I can't figure out why this line was here at all: All ensemble members from a given forecast cycle have the same number of hours available, so my unconfident best guess is someone got confused between cycle ids and ensemble ids. But cycle 00 is the one with more hours, so this would have been wrong anyway.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I actually think there are some ensemble members that are the full 35 days, and others that are shorter, even for cycle 00
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can you point to any examples of the shorter members, or documentation that mentions them? I've been poking around and haven't yet found any yet, but if this is an intermittent thing it'd be easy for me to have missed it.