Python liest WRFOut in der NC -Datei ⇐ Python

[Anonymous]

Ich verwende Python Version 3.9.18 zum Lesen von WRFOut-Dateien (Name wie: WRFOut_D02_2020-01-01_00: 00: 00) und erhalten Sie T2, Q2, PSFC, U10, V10, ACSWDNB-Variablen und kombinieren Sie alle Tage im Monat zu einer Ausgabe-NetCDF-Datei (Name wie folgt: Name: Name: Name: Name: Name: Name: Name: Name: Name: Name wie: name: name: WRF_PGW_2C_RE-202001-D02-HOURLY.NC)。
Es gibt den Code: < /p>

Code: Select all

import xarray as xr
import glob
from metpy.units import units
import numpy as np
import pandas as pd
import calendar
from tqdm import tqdm

def get_file_list(input_dir: str, year: int, month: int) -> list:
"""
Get list of WRF output files for a given year and month.

Args:
input_dir (str): Directory containing WRF output files.
year (int): Year of the data.
month (int): Month of the data.

Returns:
list: Sorted list of file paths.
"""
file_pattern = f'{input_dir}wrfout_d02_{year}-{month:02}-*_00:00:00'
return sorted(glob.glob(file_pattern))

def process_single_file(file: str) -> xr.Dataset:
"""
Process a single WRF output file and extract specified variables.

Args:
file (str): Path to the WRF output file.

Returns:
xr.Dataset: Dataset with extracted variables and units.
"""
ds = xr.open_dataset(file, engine='netcdf4')

# Extract variables with units
data_vars = {
'Times': ds['Times'],
'T2': ds['T2'] * units.kelvin,
'Q2': ds['Q2'] * units('kg/kg'),
'PSFC': ds['PSFC'] * units.pascal,
'U10': ds['U10'] * units('m/s'),
'V10': ds['V10'] * units('m/s'),
'ACSWDNB': ds['ACSWDNB'] * units('J/m^2'),
}

# Create new dataset
single_ds = xr.Dataset(data_vars)

# Copy attributes
for var in data_vars:
single_ds[var].attrs = ds[var].attrs

ds.close()
return single_ds

def merge_datasets(datasets: list, year: int, month: int) -> xr.Dataset:
"""
Merge datasets along the 'ymd' dimension.

Args:
datasets (list): List of xarray Datasets.
year (int): Year of the data.
month (int): Month of the data.

Returns:
xr.Dataset: Merged dataset.
"""
#    merged_ds = xr.concat(datasets, dim='ymd', data_vars='minimal', coords='minimal')
merged_ds = xr.concat(datasets, dim='ymd')
return merged_ds.transpose('ymd', 'Time', 'south_north', 'west_east')

def save_to_netcdf(merged_ds: xr.Dataset, output_path: str, year: int, month: int) ->  None:
"""
Save merged dataset to a NetCDF file.

Args:
merged_ds (xr.Dataset): Merged dataset to save.
output_path (str): Directory to save the NetCDF file.
year (int): Year of the data.
month (int): Month of the data.
"""
#    output_file = f'WRF_CTRL-{year}{month:02}-d02-hourly.nc' #for CTRL run
output_file = f'WRF_PGW_2C_re-{year}{month:02}-d02-hourly.nc' #for PGW_2C run
#    output_file = f'WRF_PGW_4C_re-{year}{month:02}-d02-hourly.nc' #for PGW_4C run
merged_ds.to_netcdf(
f'{output_path}{output_file}',
format='NETCDF4',
engine='netcdf4',
encoding={
'Times': {'dtype': 'S1'},
'T2': {'dtype': 'float32'},
'Q2': {'dtype': 'float32'},
'PSFC': {'dtype': 'float32'},
'U10': {'dtype': 'float32'},
'V10': {'dtype': 'float32'},
'ACSWDNB': {'dtype': 'float32'},
}
)

def main():
"""
Main function to process WRF output files, merge daily data into monthly files,
and save as NetCDF.
"""

base_input_path = '/home/user/work/share/WRF3type/WRF_PGW/2C_re/' #for PGW_2C run
output_path = '/home/user/work/share/WRF3type/hrdata-TCCIP-WRF3type-nc/PGW_2C/' #for PGW_2C run

years = range(2020, 2021)

for year in tqdm(years, desc="Processing years"):
year_folder = f'2C_re-{year}-PGW_wrfout_ERA5_domainv2_L38/'
input_dir = f'{base_input_path}{year_folder}test3/'

for month in tqdm(range(1, 2), desc=f"Processing months for {year}", leave=False):
# Get file list
file_list = get_file_list(input_dir, year, month)

# Process each file with progress bar
datasets = [process_single_file(file) for file in tqdm(file_list, desc=f"Processing files for {year}-{month:02}", leave=False)]

# Merge datasets
merged_ds = merge_datasets(datasets, year, month)

# Save to NetCDF
save_to_netcdf(merged_ds, output_path, year, month)

if __name__ == "__main__":
main()
< /code>
Dann ncdump -c die netCDF -Datei: < /p>
netcdf WRF_PGW_2C_re-202001-d02-hourly {
dimensions:
ymd = 31 ;
Time = 24 ;
string19 = 19 ;
south_north = 230 ;
west_east = 150 ;
variables:
char Times(ymd, Time, string19) ;
Times:coordinates = "XTIME" ;
float T2(ymd, Time, south_north, west_east) ;
T2:_FillValue = NaNf ;
T2:FieldType = 104 ;
T2:MemoryOrder = "XY " ;
T2:description = "TEMP at 2 M" ;
T2:units = "K" ;
T2:stagger = "" ;
T2:coordinates = "XLAT XLONG XTIME" ;
float Q2(ymd, Time, south_north, west_east) ;
Q2:_FillValue = NaNf ;
Q2:FieldType = 104 ;
Q2:MemoryOrder = "XY " ;
Q2:description = "QV at 2 M" ;
Q2:units = "kg kg-1" ;
Q2:stagger = "" ;
Q2:coordinates = "XLAT XLONG XTIME" ;
float PSFC(ymd, Time, south_north, west_east) ;
PSFC:_FillValue = NaNf ;
PSFC:FieldType = 104 ;
PSFC:MemoryOrder = "XY " ;
PSFC:description = "SFC PRESSURE" ;
PSFC:units = "Pa" ;
PSFC:stagger = "" ;
PSFC:coordinates = "XLAT XLONG XTIME" ;
float U10(ymd, Time, south_north, west_east) ;
U10:_FillValue = NaNf ;
U10:FieldType = 104 ;
U10:MemoryOrder = "XY " ;
U10:description = "U at 10 M" ;
U10:units = "m s-1" ;
U10:stagger = "" ;
U10:coordinates = "XLAT XLONG XTIME" ;
float V10(ymd, Time, south_north, west_east) ;
V10:_FillValue = NaNf ;
V10:FieldType = 104 ;
V10:MemoryOrder = "XY " ;
V10:description = "V at 10 M"  ;
V10:units = "m s-1" ;
V10:stagger = "" ;
V10:coordinates = "XLAT XLONG XTIME" ;
float ACSWDNB(ymd, Time, south_north, west_east) ;
ACSWDNB:_FillValue = NaNf ;
ACSWDNB:FieldType = 104 ;
ACSWDNB:MemoryOrder = "XY " ;
ACSWDNB:description = "ACCUMULATED DOWNWELLING SHORTWAVE FLUX AT BOTTOM" ;
ACSWDNB:units = "J m-2" ;
ACSWDNB:stagger = "" ;
ACSWDNB:coordinates = "XLAT XLONG XTIME" ;
float XTIME(ymd, Time) ;
XTIME:_FillValue = NaNf ;
XTIME:FieldType = 104 ;
XTIME:MemoryOrder = "0  " ;
XTIME:description = "minutes since 2020-01-01 00:00:00" ;
XTIME:stagger = "" ;
XTIME:units = "minutes since 2020-01-01" ;
XTIME:calendar = "proleptic_gregorian" ;
float XLAT(Time, south_north, west_east) ;
XLAT:_FillValue = NaNf ;
XLAT:FieldType = 104 ;
XLAT:MemoryOrder = "XY " ;
XLAT:description = "LATITUDE, SOUTH IS NEGATIVE" ;
XLAT:units = "degree_north" ;
XLAT:stagger = "" ;
XLAT:coordinates = "XLONG XLAT" ;
float XLONG(Time, south_north, west_east) ;
XLONG:_FillValue = NaNf ;
XLONG:FieldType = 104 ;
XLONG:MemoryOrder = "XY " ;
XLONG:description = "LONGITUDE, WEST IS NEGATIVE" ;
XLONG:units = "degree_east" ;
XLONG:stagger = "" ;
XLONG:coordinates = "XLONG XLAT" ;
data:
}

Aber ich möchte ncdump -c wie folgt:

Code: Select all

netcdf WRF_CTRL-202001-d02-hourly {
dimensions:
ymd = 31 ;
Time = 24 ;
DateStrLen = 19 ;
south_north = 230 ;
west_east = 150 ;
variables:
char Times(ymd, Time, DateStrLen) ;
float XLAT(south_north, west_east) ;
XLAT:FieldType = 104 ;
XLAT:MemoryOrder = "XY " ;
XLAT:description = "LATITUDE, SOUTH IS NEGATIVE" ;
XLAT:units = "degree_north" ;
XLAT:stagger = "" ;
XLAT:coordinates = "XLONG XLAT" ;
float XLONG(south_north, west_east) ;
XLONG:FieldType = 104 ;
XLONG:MemoryOrder = "XY " ;
XLONG:description = "LONGITUDE, WEST IS NEGATIVE" ;
XLONG:units = "degree_east" ;
XLONG:stagger = "" ;
XLONG:coordinates = "XLONG XLAT" ;
float T2(ymd, Time, south_north, west_east) ;
T2:FieldType = 104 ;
T2:MemoryOrder = "XY " ;
T2:description = "TEMP at 2 M" ;
T2:units = "K" ;
T2:stagger = "" ;
T2:coordinates = "XLONG XLAT XTIME" ;
float Q2(ymd, Time, south_north, west_east) ;
Q2:FieldType = 104 ;
Q2:MemoryOrder = "XY " ;
Q2:description = "QV at 2 M" ;
Q2:units = "kg kg-1" ;
Q2:stagger = "" ;
Q2:coordinates = "XLONG XLAT XTIME" ;
float PSFC(ymd, Time, south_north, west_east) ;
PSFC:FieldType = 104 ;
PSFC:MemoryOrder = "XY " ;
PSFC:description = "SFC PRESSURE" ;
PSFC:units = "Pa" ;
PSFC:stagger = "" ;
PSFC:coordinates = "XLONG XLAT XTIME" ;
float U10(ymd, Time, south_north, west_east) ;
U10:FieldType = 104 ;
U10:MemoryOrder = "XY " ;
U10:description = "U at 10 M" ;
U10:units = "m s-1" ;
U10:stagger = "" ;
U10:coordinates = "XLONG XLAT XTIME"  ;
float V10(ymd, Time, south_north, west_east) ;
V10:FieldType = 104 ;
V10:MemoryOrder = "XY " ;
V10:description = "V at 10 M" ;
V10:units = "m s-1" ;
V10:stagger = "" ;
V10:coordinates = "XLONG XLAT XTIME" ;
float ACSWDNB(ymd, Time, south_north, west_east) ;
ACSWDNB:FieldType = 104 ;
ACSWDNB:MemoryOrder = "XY " ;
ACSWDNB:description = "ACCUMULATED DOWNWELLING SHORTWAVE FLUX AT BOTTOM" ;
ACSWDNB:units = "J m-2" ;
ACSWDNB:stagger = "" ;
ACSWDNB:coordinates = "XLONG XLAT XTIME" ;
data:
}

Wie kann ich es tun?