Revision b6e392da
Added by Adam Wilson almost 12 years ago
| climate/procedures/MOD06_L2_process.r | ||
|---|---|---|
| 1 | 1 |
################################################################################### |
| 2 | 2 |
### R code to aquire and process MOD06_L2 cloud data from the MODIS platform |
| 3 | 3 |
|
| 4 |
|
|
| 5 |
# Redirect all warnings to stderr() |
|
| 6 |
#options(warn = -1) |
|
| 7 |
#write("2) write() to stderr", stderr())
|
|
| 8 |
#write("2) write() to stdout", stdout())
|
|
| 9 |
#warning("2) warning()")
|
|
| 10 |
|
|
| 11 |
|
|
| 4 | 12 |
## import commandline arguments |
| 5 | 13 |
library(getopt) |
| 6 | 14 |
## get options |
| 7 | 15 |
opta <- getopt(matrix(c( |
| 8 | 16 |
'date', 'd', 1, 'character', |
| 9 | 17 |
'tile', 't', 1, 'character', |
| 18 |
'verbose','v',1,'logical', |
|
| 10 | 19 |
'help', 'h', 0, 'logical' |
| 11 | 20 |
), ncol=4, byrow=TRUE)) |
| 12 | 21 |
if ( !is.null(opta$help) ) |
| ... | ... | |
| 16 | 25 |
q(status=1); |
| 17 | 26 |
} |
| 18 | 27 |
|
| 19 |
#gridfile = paste("HDF4_EOS:EOS_GRID:\"", opta$data,"\":MODIS_Grid_Daily_1km_LST:Night_view_angl", sep="")
|
|
| 20 |
#cat(paste("Checking : ", gridfile, " ...\n"));
|
|
| 21 |
|
|
| 22 |
|
|
| 23 |
## Load command line arguments (mname) |
|
| 24 |
#args=(commandArgs(TRUE)) ##args is now a list of character vectors |
|
| 25 |
## Then cycle through each element of the list and evaluate the expressions. |
|
| 26 |
#eval(parse(text=args)) |
|
| 27 |
#print(args) |
|
| 28 |
|
|
| 29 |
#system("module list")
|
|
| 30 |
#system("source ~/moduleload")
|
|
| 31 |
#system("module list")
|
|
| 32 |
|
|
| 33 | 28 |
|
| 34 | 29 |
date=opta$date #date="20030301" |
| 35 | 30 |
tile=opta$tile #tile="h11v08" |
| 36 |
outdir="2_daily" #directory for separate daily files
|
|
| 37 |
#outdir2="3_summary" #directory for combined daily files and summarized files
|
|
| 31 |
verbose=opta$verbose #print out extensive information for debugging?
|
|
| 32 |
outdir=paste("daily/",tile,"/",sep="") #directory for separate daily files
|
|
| 38 | 33 |
|
| 39 |
print(paste("Processing tile",tile," for date",date))
|
|
| 34 |
## permanent storage on lou: |
|
| 35 |
ldir=paste("lfe1.nas.nasa.gov:/u/awilso10/mod06/daily/",tile,sep="")
|
|
| 40 | 36 |
|
| 41 |
#system("module list")
|
|
| 42 |
#system("ldd /u/awilso10/R/x86_64-unknown-linux-gnu-library/2.15/rgdal/libs/rgdal.so")
|
|
| 37 |
print(paste("Processing tile",tile," for date",date))
|
|
| 43 | 38 |
|
| 44 | 39 |
## load libraries |
| 45 | 40 |
require(reshape) |
| ... | ... | |
| 47 | 42 |
require(raster) |
| 48 | 43 |
library(rgdal) |
| 49 | 44 |
require(spgrass6) |
| 45 |
require(RSQLite) |
|
| 50 | 46 |
|
| 51 | 47 |
|
| 52 | 48 |
## specify some working directories |
| 53 | 49 |
setwd("/nobackupp1/awilso10/mod06")
|
| 54 | 50 |
|
| 55 |
print(paste("tempdir()=",tempdir()))
|
|
| 56 |
print(paste("TMPDIR=",Sys.getenv("TMPDIR")))
|
|
| 57 |
|
|
| 58 | 51 |
## load ancillary data |
| 59 | 52 |
load(file="allfiles.Rdata") |
| 60 | 53 |
|
| 61 | 54 |
## load tile information |
| 62 | 55 |
load(file="modlandTiles.Rdata") |
| 63 |
### use MODIS tile as ROI |
|
| 64 |
#modt=readOGR("modgrid","modis_sinusoidal_grid_world",)
|
|
| 65 |
#modt@data[,colnames(tb)[3:6]]=tb[match(paste(modt$h,modt$v),paste(tb$ih,tb$iv)),3:6] |
|
| 66 |
#write.csv(modt@data,file="modistile.csv") |
|
| 67 | 56 |
|
| 68 | 57 |
## vars to process |
| 69 | 58 |
vars=as.data.frame(matrix(c( |
| ... | ... | |
| 84 | 73 |
############################################################################ |
| 85 | 74 |
### Define functions to process a particular date-tile |
| 86 | 75 |
|
| 76 |
#### get swaths |
|
| 77 |
#getswaths<-function(tile,db="/nobackupp4/pvotava/DB/export/swath_geo.sql.sqlite3.db"){
|
|
| 78 |
# db=dbConnect( |
|
| 79 |
# } |
|
| 80 |
|
|
| 87 | 81 |
swath2grid=function(file,vars,upleft,lowright){
|
| 88 | 82 |
## Function to generate hegtool parameter file for multi-band HDF-EOS file |
| 89 | 83 |
print(paste("Starting file",basename(file)))
|
| ... | ... | |
| 118 | 112 |
## write it to a file |
| 119 | 113 |
cat(c(hdr,grp) , file=paste(tempdir(),"/",basename(file),"_MODparms.txt",sep="")) |
| 120 | 114 |
## now run the swath2grid tool |
| 121 |
## write the tiff file
|
|
| 122 |
# log=system(paste("/nobackupp4/pvotava/software/heg/bin/swtif -p ",paste(tempdir(),"/",basename(file),"_MODparms.txt -d",sep=""),sep=""),intern=T)
|
|
| 123 |
log=system(paste("/nobackupp1/awilso10/software/heg/bin/swtif -p ",paste(tempdir(),"/",basename(file),"_MODparms.txt -d",sep=""),sep=""),intern=T)
|
|
| 115 |
## write the gridded file and save the log including the pid of the parent process
|
|
| 116 |
# log=system(paste("( /nobackupp1/awilso10/software/heg/bin/swtif -p ",tempdir(),"/",basename(file),"_MODparms.txt -d ; echo $$)",sep=""),intern=T)
|
|
| 117 |
log=system(paste("( /nobackupp1/awilso10/software/heg/bin/swtif -p ",tempdir(),"/",basename(file),"_MODparms.txt -d ; echo $$)",sep=""),intern=T,ignore.stderr=T)
|
|
| 124 | 118 |
## clean up temporary files in working directory |
| 125 |
# file.remove(paste("filetable.temp_",pid,sep=""))
|
|
| 126 |
print(log) |
|
| 127 |
## confirm file is present |
|
| 128 |
print(paste("Confirming output file (",outfile,") is present and readable by GDAL"))
|
|
| 129 |
system(paste("gdalinfo ",outfile))
|
|
| 119 |
file.remove(list.files(pattern= |
|
| 120 |
paste("filetable.temp_",
|
|
| 121 |
as.numeric(log[length(log)]):(as.numeric(log[length(log)])+3),sep="",collapse="|"))) #Look for files with PID within 3 of parent process |
|
| 122 |
if(verbose) print(log) |
|
| 130 | 123 |
print(paste("Finished ", file))
|
| 131 | 124 |
} |
| 132 | 125 |
|
| ... | ... | |
| 146 | 139 |
Sys.setenv(GRASS_GUI="txt") |
| 147 | 140 |
|
| 148 | 141 |
### Function to extract various SDSs from a single gridded HDF file and use QA data to throw out 'bad' observations |
| 149 |
loadcloud<-function(date,fs){
|
|
| 142 |
loadcloud<-function(date,fs,ncfile){
|
|
| 150 | 143 |
tf=paste(tempdir(),"/grass", Sys.getpid(),"/", sep="") |
| 151 |
dir.create(tf) |
|
| 144 |
if(!file.exists(tf))dir.create(tf)
|
|
| 152 | 145 |
|
| 153 | 146 |
print(paste("Set up temporary grass session in",tf))
|
| 154 | 147 |
|
| 155 | 148 |
## set up temporary grass instance for this PID |
| 156 |
# initGRASS(gisBase="/nobackupp1/awilso10/software/grass-6.4.3svn",gisDbase=tf,SG=td,override=T,location="mod06",mapset="PERMANENT",home=tf,pid=Sys.getpid()) |
|
| 157 | 149 |
initGRASS(gisBase="/u/armichae/pr/grass-6.4.2/",gisDbase=tf,SG=td,override=T,location="mod06",mapset="PERMANENT",home=tf,pid=Sys.getpid()) |
| 158 |
|
|
| 159 |
system(paste("g.proj -c proj4=\"",projection(td),"\"",sep=""))
|
|
| 150 |
system(paste("g.proj -c proj4=\"",projection(td),"\"",sep=""),ignore.stdout=T,ignore.stderr=T)
|
|
| 160 | 151 |
|
| 161 | 152 |
## Define region by importing one MOD11A1 raster. |
| 162 | 153 |
print("Import one MOD11A1 raster to define grid")
|
| 163 | 154 |
execGRASS("r.in.gdal",input=paste("HDF4_EOS:EOS_GRID:\"",gridfile,"\":MODIS_Grid_Daily_1km_LST:Night_view_angl",sep=""),
|
| 164 | 155 |
output="modisgrid",flags=c("quiet","overwrite","o"))
|
| 165 |
system("g.region rast=modisgrid save=roi --overwrite")
|
|
| 156 |
system("g.region rast=modisgrid save=roi --overwrite",ignore.stdout=T,ignore.stderr=T)
|
|
| 166 | 157 |
|
| 167 | 158 |
## Identify which files to process |
| 168 | 159 |
tfs=fs$file[fs$dateid==date] |
| ... | ... | |
| 177 | 168 |
execGRASS("r.in.gdal",input=paste("HDF4_EOS:EOS_GRID:\"",file,"\":mod06:Cloud_Mask_1km_0",sep=""),
|
| 178 | 169 |
output=paste("CM1_",i,sep=""),flags=c("overwrite","o")) ; print("")
|
| 179 | 170 |
## extract cloudy and 'confidently clear' pixels |
| 180 |
|
|
| 181 | 171 |
system(paste("r.mapcalc <<EOF
|
| 182 | 172 |
CM_cloud_",i," = ((CM1_",i," / 2^0) % 2) == 1 && ((CM1_",i," / 2^1) % 2^2) == 0 |
| 183 | 173 |
CM_clear_",i," = ((CM1_",i," / 2^0) % 2) == 1 && ((CM1_",i," / 2^1) % 2^2) == 3 |
| 184 | 174 |
EOF",sep="")) |
| 185 |
|
|
| 186 | 175 |
## QA |
| 187 | 176 |
execGRASS("r.in.gdal",input=paste("HDF4_EOS:EOS_GRID:\"",file,"\":mod06:Quality_Assurance_1km_0",sep=""),
|
| 188 | 177 |
output=paste("QA_",i,sep=""),flags=c("overwrite","o")) ; print("")
|
| ... | ... | |
| 243 | 232 |
CLD_daily=int((max(",paste("if(isnull(CM_cloud_",1:nfs,"),0,CM_cloud_",1:nfs,")",sep="",collapse=","),"))*100)
|
| 244 | 233 |
EOF",sep="")) |
| 245 | 234 |
|
| 246 |
#### Write the files to a geotiff |
|
| 247 |
# execGRASS("r.out.gdal",input="CER_daily",output=paste(outdir,"/CER_",date,".tif",sep=""),nodata=-999,flags=c("quiet"))
|
|
| 248 |
# execGRASS("r.out.gdal",input="COT_daily",output=paste(outdir,"/COT_",date,".tif",sep=""),nodata=-999,flags=c("quiet"))
|
|
| 249 |
# execGRASS("r.out.gdal",input="CLD_daily",output=paste(outdir,"/CLD_",date,".tif",sep=""),nodata=99,flags=c("quiet"))
|
|
| 250 | 235 |
|
| 251 | 236 |
### Write the files to a netcdf file |
| 252 | 237 |
## create image group to facilitate export as multiband netcdf |
| 253 | 238 |
execGRASS("i.group",group="mod06",input=c("CER_daily","COT_daily","CLD_daily")) ; print("")
|
| 254 | 239 |
|
| 255 |
ncfile=paste(outdir,"/MOD06_",date,".nc",sep="") |
|
| 256 |
file.remove(ncfile) |
|
| 240 |
if(file.exists(ncfile)) file.remove(ncfile) #if it exists already, delete it |
|
| 257 | 241 |
execGRASS("r.out.gdal",input="mod06",output=ncfile,type="Int16",nodata=-32768,flags=c("quiet"),
|
| 258 |
# createopt=c("FORMAT=NC4","ZLEVEL=5","COMPRESS=DEFLATE","WRITE_GDAL_TAGS=YES","WRITE_LONLAT=NO"),format="netCDF")
|
|
| 242 |
# createopt=c("FORMAT=NC4","ZLEVEL=5","COMPRESS=DEFLATE","WRITE_GDAL_TAGS=YES","WRITE_LONLAT=NO"),format="netCDF") #for compressed netcdf
|
|
| 259 | 243 |
createopt=c("FORMAT=NC","WRITE_GDAL_TAGS=YES","WRITE_LONLAT=NO"),format="netCDF")
|
| 260 | 244 |
|
| 261 | 245 |
ncopath="/nasa/sles11/nco/4.0.8/gcc/mpt/bin/" |
| 262 | 246 |
system(paste(ncopath,"ncecat -O -u time ",ncfile," ",ncfile,sep="")) |
| 263 |
# system(paste("cdo setdate,",as.integer(fs$date[fs$dateid==date]-as.Date("2000-01-01"))," -settaxis,2000-01-01,12:00:00,1day ",ncfile," ",ncfile,sep=""))
|
|
| 264 |
# timdimf=paste(tempdir(),"/time.nc",sep="") |
|
| 265 |
# nc_dtime=ncdim_def("time","days since 2000-01-01 12:00:00",
|
|
| 266 |
# vals=as.integer(fs$date[fs$dateid==date]-as.Date("2000-01-01")),
|
|
| 267 |
# calendar="gregorian",longname="time") |
|
| 268 |
# nc_vtime=ncvar_def("time","
|
|
| 269 |
# nc=nc_create(timdimf,nc_time) |
|
| 270 | 247 |
## create temporary nc file with time information to append to MOD06 data |
| 271 | 248 |
cat(paste("
|
| 272 | 249 |
netcdf time {
|
| ... | ... | |
| 274 | 251 |
time = 1 ; |
| 275 | 252 |
variables: |
| 276 | 253 |
int time(time) ; |
| 277 |
time:units = \"days since 2000-01-01 12:00:00\" ;
|
|
| 254 |
time:units = \"days since 2000-01-01 00:00:00\" ;
|
|
| 278 | 255 |
time:calendar = \"gregorian\"; |
| 279 | 256 |
time:long_name = \"time of observation\"; |
| 280 | 257 |
data: |
| ... | ... | |
| 282 | 259 |
}"),file=paste(tempdir(),"/time.cdl",sep="")) |
| 283 | 260 |
system(paste("ncgen -o ",tempdir(),"/time.nc ",tempdir(),"/time.cdl",sep=""))
|
| 284 | 261 |
system(paste(ncopath,"ncks -A ",tempdir(),"/time.nc ",ncfile,sep="")) |
| 285 |
|
|
| 286 |
# ncwa -O -h -a record out.nc out.nc |
|
| 287 |
# ncvar_put( nc, "time", vals=as.integer(fs$date[fs$dateid==date]-as.Date("2000-01-01")), start=NA, count=NA, verbose=FALSE )
|
|
| 288 |
# system(paste(ncopath,"ncap2 -O -s 'time[time]=",as.integer(fs$date[fs$dateid==date]-as.Date("2000-01-01")),"'",ncfile," ",ncfile,sep=""))
|
|
| 289 |
# system(paste(ncopath,"ncatted -O calendar,time,c,c,\"standard\" -a long_name,time,c,c,\"time\" -a units,time,c,c,\"days since 2000-01-01 12:00:00\" ",ncfile,sep="")) |
|
| 262 |
## add other attributes |
|
| 290 | 263 |
system(paste(ncopath,"ncrename -v Band1,CER -v Band2,COT -v Band3,CLD ",ncfile,sep="")) |
| 291 | 264 |
system(paste(ncopath,"ncatted -a scale_factor,CER,o,d,0.01 -a units,CER,o,c,\"micron\" -a missing_value,CER,o,d,-32768 -a long_name,CER,o,c,\"Cloud Particle Effective Radius\" ",ncfile,sep="")) |
| 292 | 265 |
system(paste(ncopath,"ncatted -a scale_factor,COT,o,d,0.01 -a units,COT,o,c,\"none\" -a missing_value,COT,o,d,-32768 -a long_name,COT,o,c,\"Cloud Optical Thickness\" ",ncfile,sep="")) |
| ... | ... | |
| 295 | 268 |
|
| 296 | 269 |
### delete the temporary files |
| 297 | 270 |
unlink_.gislock() |
| 298 |
# system("/nobackupp1/awilso10/software/grass-6.4.3svn/etc/clean_temp")
|
|
| 299 |
system(paste("rm -rR ",tf,sep=""))
|
|
| 271 |
system("clean_temp")
|
|
| 272 |
system(paste("rm -frR ",tf,sep=""))
|
|
| 300 | 273 |
} |
| 301 | 274 |
|
| 302 | 275 |
|
| ... | ... | |
| 308 | 281 |
##################################################### |
| 309 | 282 |
## Run the gridding procedure |
| 310 | 283 |
tile_bb=tb[tb$tile==tile,] ## identify tile of interest |
| 284 |
|
|
| 285 |
# if(venezuela) tile_bb$lat_max=11.0780999176 #increase northern boundary for KT |
|
| 286 |
|
|
| 311 | 287 |
lapply(fs$path[fs$dateid==date],swath2grid,vars=vars,upleft=paste(tile_bb$lat_max,tile_bb$lon_min),lowright=paste(tile_bb$lat_min,tile_bb$lon_max)) |
| 312 | 288 |
|
| 289 |
## confirm at least one file for this date is present |
|
| 290 |
outfiles=paste(tempdir(),"/",basename(fs$path[fs$dateid==date]),sep="") |
|
| 291 |
if(!any(file.exists(outfiles))) {
|
|
| 292 |
print(paste("######################################## No gridded files for region exist for tile",tile," on date",date))
|
|
| 293 |
q("no",status=0)
|
|
| 294 |
} |
|
| 295 |
|
|
| 313 | 296 |
##################################################### |
| 314 | 297 |
## Process the gridded files |
| 315 |
|
|
| 316 |
## temporary objects to test function below |
|
| 317 |
# i=1 |
|
| 318 |
#file=paste(outdir,"/",fs$file[1],sep="") |
|
| 319 |
#date=as.Date("2000-05-23")
|
|
| 320 | 298 |
|
| 321 | 299 |
## run themod06 processing for this date |
| 322 |
loadcloud(date,fs=fs) |
|
| 300 |
ncfile=paste(outdir,"/MOD06_",tile,"_",date,".nc",sep="") #this is the 'final' daily output file |
|
| 301 |
loadcloud(date,fs=fs,ncfile=ncfile) |
|
| 302 |
|
|
| 303 |
## Confirm that the file has the correct attributes, otherwise delete it |
|
| 304 |
ntime=as.numeric(system(paste("cdo -s ntime ",ncfile),intern=T))
|
|
| 305 |
npar=as.numeric(system(paste("cdo -s npar ",ncfile),intern=T))
|
|
| 306 |
if(!ntime==1&npar>0) {
|
|
| 307 |
print(paste("File for tile ",tile," and date ",date," was not outputted correctly, deleting... "))
|
|
| 308 |
file.remove(ncfile) |
|
| 309 |
} |
|
| 310 |
|
|
| 311 |
## push file to lou and then delete it from pfe |
|
| 312 |
# system(paste("scp ",ncfile," ",ldir,sep="") )
|
|
| 313 |
# file.remove(ncfile) |
|
| 314 |
|
|
| 323 | 315 |
## print out some info |
| 324 | 316 |
print(paste(" ################################################################### Finished ",date,"
|
| 325 | 317 |
################################################################")) |
| ... | ... | |
| 329 | 321 |
##date=notdone[1] |
| 330 | 322 |
mod06(date,tile) |
| 331 | 323 |
|
| 332 |
## run it for all dates |
|
| 324 |
## run it for all dates - Use this if running on a workstation/server (otherwise use qsub)
|
|
| 333 | 325 |
#mclapply(notdone,mod06,tile,mc.cores=ncores) # use ncores/2 because system() commands can add second process for each spawned R |
| 334 | 326 |
#foreach(i=notdone[1:3],.packages=(.packages())) %dopar% mod06(i,tile) |
| 335 | 327 |
#foreach(i=1:20) %dopar% print(i) |
| 336 | 328 |
|
| 329 |
## delete old files |
|
| 330 |
#system("cleartemp")
|
|
| 331 |
|
|
| 337 | 332 |
q("no",status=0)
|
| climate/procedures/Pleiades.R | ||
|---|---|---|
| 1 | 1 |
#### Script to facilitate processing of MOD06 data |
| 2 | 2 |
|
| 3 | 3 |
setwd("/nobackupp1/awilso10/mod06")
|
| 4 |
|
|
| 4 | 5 |
library(rgdal) |
| 5 | 6 |
library(raster) |
| 6 | 7 |
|
| ... | ... | |
| 9 | 10 |
tb$tile=paste("h",sprintf("%02d",tb$ih),"v",sprintf("%02d",tb$iv),sep="")
|
| 10 | 11 |
save(tb,file="modlandTiles.Rdata") |
| 11 | 12 |
|
| 13 |
## delete temporary log file that can grow to GB |
|
| 14 |
system("rm /nobackupp1/awilso10/software/heg/TOOLKIT_MTD/runtime/LogStatus")
|
|
| 15 |
|
|
| 16 |
tile="h11v08" # Venezuela |
|
| 17 |
tile="h11v07" # Venezuela coast |
|
| 18 |
tile="h09v04" # Oregon |
|
| 19 |
|
|
| 12 | 20 |
outdir="2_daily" #directory for separate daily files |
| 13 |
outdir2="3_summary" #directory for combined daily files and summarized files |
|
| 21 |
outdir=paste("daily/",tile,"/",sep="") #directory for separate daily files
|
|
| 22 |
if(!file.exists(outdir)) dir.create(outdir) |
|
| 23 |
outdir2="summary" #directory for combined daily files and summarized files |
|
| 24 |
if(!file.exists(outdir2)) dir.create(outdir2) |
|
| 14 | 25 |
|
| 15 | 26 |
## load a MOD11A1 file to define grid |
| 16 | 27 |
gridfile=list.files("/nobackupp4/datapool/modis/MOD11A1.005/2006.01.27/",pattern=paste(tile,".*hdf$",sep=""),full=T)[1]
|
| ... | ... | |
| 20 | 31 |
|
| 21 | 32 |
### get list of files to process |
| 22 | 33 |
datadir="/nobackupp4/datapool/modis/MOD06_L2.005/" |
| 34 |
datadir="/nobackupp1/awilso10/mod06/data" #for data downloaded from |
|
| 23 | 35 |
|
| 24 | 36 |
fs=data.frame(path=list.files(datadir,full=T,recursive=T,pattern="hdf"),stringsAsFactors=F) |
| 25 | 37 |
fs$file=basename(fs$path) |
| ... | ... | |
| 38 | 50 |
|
| 39 | 51 |
#### Generate submission file |
| 40 | 52 |
## identify which have been completed |
| 41 |
done=alldates%in%substr(list.files(outdir),7,14)
|
|
| 42 |
table(done)
|
|
| 43 |
notdone=alldates[!done] #these are the dates that still need to be processed
|
|
| 53 |
#fdone=system(paste("ssh -q lou2 \"ls ",pdir," | grep \"nc$\"\"",sep=""),intern=T)
|
|
| 54 |
fdone=list.files(outdir,pattern="nc$")
|
|
| 55 |
done=alldates%in%substr(fdone,14,21)
|
|
| 44 | 56 |
|
| 45 |
if(exists("fdly")){
|
|
| 46 |
notdone=notdone[notdone%in%fdly$dateid[is.na(fdly$npar)]] |
|
| 57 |
if(exists("fdly")){ #update using table from below
|
|
| 58 |
done[alldates%in%fdly$dateid[is.na(fdly$npar)]]=F |
|
| 59 |
} |
|
| 47 | 60 |
|
| 61 |
table(done) |
|
| 62 |
notdone=alldates[!done] #these are the dates that still need to be processed |
|
| 48 | 63 |
|
| 49 |
tile="h11v08" #can move this to submit script if needed |
|
| 50 | 64 |
script="/u/awilso10/environmental-layers/climate/procedures/MOD06_L2_process.r" |
| 51 |
write.table(paste("--verbose ",script," --date ",notdone," --tile \"",tile,"\"",sep=""),file="notdone.txt",row.names=F,col.names=F,quote=F)
|
|
| 52 |
#write.table(paste("--verbose ",script," date=",notdone[1:30],sep=""),file="notdone.txt",row.names=F,col.names=F,quote=F)
|
|
| 53 |
#write.table(notdone[1:30],file="notdone.txt",row.names=F,col.names=F,quote=F) |
|
| 65 |
|
|
| 66 |
write.table(paste("--verbose ",script," --date ",notdone," --verbose T --tile \"",tile,"\"",sep=""),file=paste(tile,"_notdone.txt",sep=""),row.names=F,col.names=F,quote=F)
|
|
| 54 | 67 |
|
| 55 | 68 |
save(fs,alldates,gridfile,td,file="allfiles.Rdata") |
| 56 | 69 |
|
| 57 |
## run script |
|
| 58 |
#cat(paste("
|
|
| 59 |
##! /bin/bash |
|
| 60 |
#source ~/moduleload |
|
| 61 |
#source ~/.bashrc |
|
| 62 |
#Rscript --verbose --vanilla /u/awilso10/environmental-layers/climate/procedures/MOD06_L2_process.r date=$1 |
|
| 63 |
#Rscript --verbose --vanilla rtest |
|
| 64 |
#",sep=""),file="MOD06_process2") |
|
| 65 |
#system("chmod +x MOD06_process2")
|
|
| 66 |
|
|
| 67 |
#cat(paste("
|
|
| 68 |
#library(rgdal) |
|
| 69 |
#GDALinfo |
|
| 70 |
#",sep=""),file="rtest") |
|
| 71 |
|
|
| 72 |
|
|
| 73 |
## Submission script |
|
| 74 |
|
|
| 75 |
#cat(paste("
|
|
| 76 |
##PBS -S /bin/bash |
|
| 77 |
##PBS -l select=2:ncpus=16:model=san |
|
| 78 |
####PBS -l select=4:ncpus=8:model=neh |
|
| 79 |
###PBS -l select=1:ncpus=12:model=wes |
|
| 80 |
######## old: select=48:ncpus=8:mpiprocs=8:model=neh |
|
| 81 |
##PBS -l walltime=2:00:00 |
|
| 82 |
##PBS -j oe |
|
| 83 |
##PBS -m e |
|
| 84 |
##PBS -V |
|
| 85 |
##PBS -q devel |
|
| 86 |
##PBS -o log/log_^array_index^ |
|
| 87 |
##PBS -o log/log_DataCompile.log |
|
| 88 |
##PBS -M adam.wilson@yale.edu |
|
| 89 |
##PBS -N MOD06 |
|
| 90 |
|
|
| 91 |
## cd to working directory |
|
| 92 |
#cd /nobackupp1/awilso10/mod06 |
|
| 93 |
|
|
| 94 |
## set some memory limits |
|
| 95 |
# ulimit -d 1500000 -m 1500000 -v 1500000 #limit memory usage |
|
| 96 |
# source /usr/local/lib/global.profile |
|
| 97 |
# source /u/awilso10/.bashrc |
|
| 98 |
# source /u/awilso10/moduleload |
|
| 99 |
### export a few important variables |
|
| 100 |
# export NNODES=32 |
|
| 101 |
# export R_LIBS=\"/u/awilso10/R/x86_64-unknown-linux-gnu-library/2.15/\" |
|
| 102 |
### Run the script! |
|
| 103 |
## current version not parallelizing across nodes! |
|
| 104 |
# TMPDIR=$TMPDIR Rscript --verbose --vanilla /u/awilso10/environmental-layers/climate/procedures/MOD06_L2_process.r date=20000403 |
|
| 105 |
|
|
| 106 |
#WORKLIST=notdone.txt |
|
| 107 |
##EXE=\"Rscript\" |
|
| 108 |
#EXE="./MOD06_process2" |
|
| 109 |
#LOG=log/log_DataCompile.log |
|
| 110 |
#MQUEUE=/nobackupp4/pvotava/software/share/mqueue-eg/mqueue/mqueue |
|
| 111 |
|
|
| 112 |
#TMPDIR=$TMPDIR mpiexec -np $NNODES $MQUEUE -l $WORKLIST -p $EXE -v -v -v --random-starts 2-4 --work-analyze #> $LOG |
|
| 113 |
#exit 0 |
|
| 114 |
#",sep=""),file="MOD06_process") |
|
| 115 |
|
|
| 116 |
|
|
| 117 |
### simplified qsub script |
|
| 70 |
### qsub script |
|
| 118 | 71 |
cat(paste("
|
| 119 | 72 |
#PBS -S /bin/bash |
| 120 |
#PBS -l select=48:ncpus=8:mpiprocs=8
|
|
| 73 |
#PBS -l select=40:ncpus=8:mpiprocs=8
|
|
| 121 | 74 |
##PBS -l select=2:ncpus=4:mpiprocs=4 |
| 122 |
#PBS -l walltime=02:00:00
|
|
| 75 |
#PBS -l walltime=2:00:00 |
|
| 123 | 76 |
#PBS -j n |
| 124 | 77 |
#PBS -m be |
| 125 | 78 |
#PBS -N mod06 |
| 126 | 79 |
#PBS -q devel |
| 127 | 80 |
#PBS -V |
| 128 | 81 |
|
| 129 |
CORES=384
|
|
| 82 |
CORES=320
|
|
| 130 | 83 |
HDIR=/u/armichae/pr/ |
| 131 | 84 |
source $HDIR/etc/environ.sh |
| 132 | 85 |
source /u/awilso10/.bashrc |
| 133 | 86 |
IDIR=/nobackupp1/awilso10/mod06/ |
| 134 | 87 |
##WORKLIST=$HDIR/var/run/pxrRgrs/work.txt |
| 135 |
WORKLIST=$IDIR/notdone.txt |
|
| 88 |
WORKLIST=$IDIR/",tile,"_notdone.txt
|
|
| 136 | 89 |
EXE=Rscript |
| 137 | 90 |
LOGSTDOUT=$IDIR/log/log.stdout |
| 138 | 91 |
LOGSTDERR=$IDIR/log/log.stderr |
| 139 | 92 |
mpiexec -np $CORES pxargs -a $WORKLIST -p $EXE -v -v -v --work-analyze 1> $LOGSTDOUT 2> $LOGSTDERR |
| 140 |
"),file="mod06_qsub")
|
|
| 93 |
",sep=""),file=paste(tile,"_mod06_qsub",sep=""))
|
|
| 141 | 94 |
|
| 142 | 95 |
|
| 143 | 96 |
### Check the file |
| 144 |
system("cat mod06_qsub")
|
|
| 97 |
system(paste("cat ",tile,"_mod06_qsub",sep=""))
|
|
| 145 | 98 |
#system("cat ~/environmental-layers/climate/procedures/MOD06_L2_process.r")
|
| 146 | 99 |
|
| 147 | 100 |
## check queue status |
| ... | ... | |
| 149 | 102 |
system("/u/scicon/tools/bin/qtop.pl 492352")
|
| 150 | 103 |
|
| 151 | 104 |
## Submit it (and keep the pid)! |
| 152 |
system("qsub mod06_qsub")
|
|
| 153 |
system("/u/scicon/tools/bin/pdsh_gdb -j 568835 -d tmp -s -u awilso10")
|
|
| 105 |
system(paste("qsub ",tile,"_mod06_qsub",sep=""))
|
|
| 154 | 106 |
|
| 155 | 107 |
## work in interactive mode |
| 156 | 108 |
# system("qsub -I -l walltime=2:00:00 -lselect=2:ncpus=16:model=san -q devel")
|
| ... | ... | |
| 161 | 113 |
system(paste("/u/scicon/tools/bin/qps ",568835))
|
| 162 | 114 |
system(paste("qstat -t -x",pid))
|
| 163 | 115 |
|
| 164 |
system("qstat devel ")
|
|
| 165 |
#system("qstat | grep awilso10")
|
|
| 166 | 116 |
|
| 167 | 117 |
#################################### |
| 168 | 118 |
|
| 119 |
## move to permanent storage on lou? |
|
| 120 |
# system(paste("scp -r ",ncfile," ",pdir,sep=""))
|
|
| 121 |
file.remove( |
|
| 122 |
list.files(pattern="filetable[.]temp|GetAttrtemp|core[.]|MCFWrite[.]temp") |
|
| 123 |
) |
|
| 169 | 124 |
|
| 170 | 125 |
################################################################################ |
| 171 | 126 |
## now generate the climatologies |
| 172 | 127 |
fdly=data.frame( |
| 173 | 128 |
path=list.files(outdir,pattern="nc$",full=T), |
| 174 | 129 |
file=list.files(outdir,pattern="nc$")) |
| 175 |
fdly$dateid=substr(fdly$file,7,14)
|
|
| 176 |
fdly$date=as.Date(substr(fdly$file,7,14),"%Y%m%d")
|
|
| 130 |
fdly$dateid=substr(fdly$file,14,21)
|
|
| 131 |
fdly$date=as.Date(substr(fdly$file,14,21),"%Y%m%d")
|
|
| 177 | 132 |
fdly$month=format(fdly$date,"%m") |
| 178 | 133 |
fdly$year=format(fdly$date,"%Y") |
| 134 |
nrow(fdly) |
|
| 179 | 135 |
|
| 180 | 136 |
## check validity (via npar and ntime) of nc files |
| 181 | 137 |
for(i in 1:nrow(fdly)){
|
| 182 |
# fdly$ntime[i]<-as.numeric(system(paste("cdo sinfo ",fdly$path[i]),intern=T))
|
|
| 138 |
fdly$ntime[i]<-as.numeric(system(paste("cdo -s ntime ",fdly$path[i]),intern=T))
|
|
| 183 | 139 |
fdly$npar[i]<-as.numeric(system(paste("cdo -s npar ",fdly$path[i]),intern=T))
|
| 184 |
print(i) |
|
| 140 |
fdly$fyear[i]<-as.numeric(system(paste("cdo -s showyear ",fdly$path[i]),intern=T))
|
|
| 141 |
fdly$fmonth[i]<-as.numeric(system(paste("cdo -s showmon ",fdly$path[i]),intern=T))
|
|
| 142 |
fdly$fvar[i]<-system(paste("cdo -s showvar ",fdly$path[i]),intern=T)
|
|
| 143 |
print(paste(i," out of ",nrow(fdly)," for year ", fdly$fyear[i])) |
|
| 144 |
} |
|
| 145 |
|
|
| 146 |
### table of problematic files |
|
| 147 |
table(is.na(fdly$npar)) |
|
| 148 |
table(fdly$fmonth) |
|
| 149 |
table(fdly$fvar) |
|
| 150 |
|
|
| 151 |
fdly[is.na(fdly$npar),] |
|
| 152 |
|
|
| 153 |
## delete files that fail check? |
|
| 154 |
delete=T |
|
| 155 |
if(delete) {
|
|
| 156 |
drop=is.na(fdly$npar)|fdly$fvar!=" CER COT CLD" |
|
| 157 |
file.remove(as.character(fdly$path[drop])) |
|
| 158 |
fdly=fdly[!drop,] |
|
| 185 | 159 |
} |
| 186 | 160 |
|
| 187 | 161 |
## Combine all days within years into a single file (can't mergetime all days at once because this opens too many files) |
| 162 |
ncopath="/nasa/sles11/nco/4.0.8/gcc/mpt/bin/" |
|
| 163 |
|
|
| 164 |
library(multicore) |
|
| 165 |
|
|
| 166 |
## create temporary directory to put intermediate files (will be deleted when R quits) |
|
| 188 | 167 |
tsdir=paste(tempdir(),"/summary",sep="") |
| 189 | 168 |
dir.create(tsdir) |
| 190 |
lapply(unique(fdly$year),function(y){
|
|
| 191 |
system(paste("cdo -O mergetime ",paste(fdly$path[!is.na(fdly$npar)&fdly$year==y],collapse=" ")," ",tsdir,"/MOD09_",tile,"_",y,"_daily.nc",sep=""))
|
|
| 192 |
print(paste("Finished merging daily files for year",y))
|
|
| 193 |
}) |
|
| 194 |
## Combine the year-by-year files into a single daily file |
|
| 195 |
system(paste("cdo -O mergetime ",paste(list.files(tsdir,full=T,pattern="daily[.]nc$"),collapse=" ")," ",outdir2,"/MOD09_",tile,"_daily.nc",sep=""))
|
|
| 196 | 169 |
|
| 197 |
system(paste("cdo -O monmean ",outdir2,"/MOD09_",tile,"_daily.nc ",outdir2,"/",tile,"_monmean.nc",sep=""))
|
|
| 198 |
system(paste("cdo -O ymonmean ",outdir2,"/MOD09_",tile,"_daily.nc ",outdir2,"/",tile,"_ymonmean.nc",sep=""))
|
|
| 199 |
system(paste("cdo -O ymonstd ",outdir2,"/MOD09_",tile,"_daily.nc ",outdir2,"/",tile,"_ymonstd.nc",sep=""))
|
|
| 170 |
## create a file of daily scenes for each year |
|
| 171 |
#mclapply(unique(fdly$year),function(y){
|
|
| 172 |
# system(paste("cdo -O mergetime ",paste(fdly$path[!is.na(fdly$npar)&fdly$year==y],collapse=" ")," ",tsdir,"/MOD06_",tile,"_",y,"_daily.nc",sep=""))
|
|
| 173 |
# print(paste("Finished merging daily files for year",y))
|
|
| 174 |
#},mc.cores=5) |
|
| 175 |
|
|
| 176 |
|
|
| 177 |
## merge all daily files to create a single file with all dates |
|
| 178 |
system(paste(ncopath,"ncrcat -O ",outdir,"/*nc ",outdir2,"/MOD06_",tile,"_daily.nc",sep="")) |
|
| 179 |
|
|
| 180 |
############################## |
|
| 181 |
## Combine the year-by-year files into a single daily file in the summary directory (for archiving) |
|
| 182 |
#system(paste("cdo -O mergetime ",paste(list.files(tsdir,full=T,pattern="daily[.]nc$"),collapse=" ")," ",outdir2,"/MOD06_",tile,"_daily.nc",sep=""))
|
|
| 183 |
system(paste(ncopath,"ncatted ", |
|
| 184 |
" -a units,time,o,c,\"days since 2000-1-1 0:0:0\" ", |
|
| 185 |
" -a title,global,o,c,\"MODIS Cloud Product (MOD06) Daily Timeseries\" ", |
|
| 186 |
" -a institution,global,o,c,\"Yale University\" ", |
|
| 187 |
" -a source,global,o,c,\"MODIS Cloud Product (MOD06)\" ", |
|
| 188 |
" -a comment,global,o,c,\"Compiled by Adam M. Wilson (adam.wilson@yale.edu)\" ", |
|
| 189 |
outdir2,"/MOD06_",tile,"_daily.nc",sep="")) |
|
| 190 |
|
|
| 191 |
#system(paste("cdo -O monmean ",outdir2,"/MOD06_",tile,"_daily.nc ",tsdir,"/MOD06_",tile,"_monmean.nc",sep=""))
|
|
| 192 |
|
|
| 193 |
############################# |
|
| 194 |
## Generate the Climatologies |
|
| 195 |
myear=as.integer(max(fdly$year)) #this year will be used in all dates of monthly climatologies (and day will = 15) |
|
| 196 |
|
|
| 197 |
## Monthly means |
|
| 198 |
system(paste("cdo -O sorttimestamp -setyear,",myear," -setday,15 -ymonmean ",outdir2,"/MOD06_",tile,"_daily.nc ",tsdir,"/MOD06_",tile,"_ymonmean.nc",sep=""))
|
|
| 199 |
|
|
| 200 |
## Monthly standard deviation |
|
| 201 |
system(paste("cdo -O sorttimestamp -setyear,",myear," -setday,15 -ymonstd ",outdir2,"/MOD06_",tile,"_daily.nc ",tsdir,"/MOD06_",tile,"_ymonstd.nc",sep=""))
|
|
| 202 |
system(paste(ncopath,"ncrename -v CER,CER_sd -v CLD,CLD_sd -v COT,COT_sd ",tsdir,"/MOD06_",tile,"_ymonstd.nc",sep="")) |
|
| 203 |
system(paste(ncopath,"ncatted ", |
|
| 204 |
" -a long_name,CER_sd,o,c,\"Cloud Particle Effective Radius (standard deviation of daily observations)\" ", |
|
| 205 |
" -a long_name,CLD_sd,o,c,\"Cloud Mask (standard deviation of daily observations)\" ", |
|
| 206 |
" -a long_name,COT_sd,o,c,\"Cloud Optical Thickness (standard deviation of daily observations)\" ", |
|
| 207 |
tsdir,"/MOD06_",tile,"_ymonstd.nc",sep="")) |
|
| 208 |
|
|
| 209 |
## cer > 20 |
|
| 210 |
system(paste("cdo -O sorttimestamp -setyear,",myear," -setday,15 -ymonmean -gtc,20 -selvar,CER ",outdir2,"/MOD06_",tile,"_daily.nc ",tsdir,"/MOD06_",tile,"_ymoncer20.nc",sep=""))
|
|
| 211 |
system(paste(ncopath,"ncrename -v CER,CER20 ",tsdir,"/MOD06_",tile,"_ymoncer20.nc",sep="")) |
|
| 212 |
system(paste(ncopath,"ncatted ", |
|
| 213 |
" -a long_name,CER20,o,c,\"Proportion of Days with Cloud Particle Effective Radius > 20um\" ", |
|
| 214 |
" -a units,CER20,o,c,\"Proportion\" ", |
|
| 215 |
tsdir,"/MOD06_",tile,"_ymoncer20.nc",sep="")) |
|
| 216 |
|
|
| 217 |
## number of observations |
|
| 218 |
system(paste("cdo -O sorttimestamp -setyear,",myear," -setday,15 -nint -mulc,100 -ymonmean -eqc,9999 -setmisstoc,9999 -selvar,CER,CLD ",outdir2,"/MOD06_",tile,"_daily.nc ",tsdir,"/MOD06_",tile,"_ymonmiss.nc",sep=""))
|
|
| 219 |
system(paste(ncopath,"ncrename -v CER,CER_pmiss -v CLD,CLD_pmiss ",tsdir,"/MOD06_",tile,"_ymonmiss.nc",sep="")) |
|
| 220 |
system(paste(ncopath,"ncatted ", |
|
| 221 |
" -a long_name,CER_pmiss,o,c,\"Proportion of Days with missing data for CER\" ", |
|
| 222 |
" -a long_name,CLD_pmiss,o,c,\"Proportion of Days with missing data for CLD\" ", |
|
| 223 |
" -a scale_factor,CER_pmiss,o,d,0.01 ", |
|
| 224 |
" -a units,CER_pmiss,o,c,\"Proportion\" ", |
|
| 225 |
" -a scale_factor,CLD_pmiss,o,d,0.01 ", |
|
| 226 |
" -a units,CLD_pmiss,o,c,\"Proportion\" ", |
|
| 227 |
tsdir,"/MOD06_",tile,"_ymonmiss.nc",sep="")) |
|
| 228 |
|
|
| 229 |
## append variables to a single file |
|
| 230 |
system(paste(ncopath,"ncks -O ",tsdir,"/MOD06_",tile,"_ymonmean.nc ",tsdir,"/MOD06_",tile,"_ymon.nc",sep="")) |
|
| 231 |
system(paste(ncopath,"ncks -A ",tsdir,"/MOD06_",tile,"_ymonstd.nc ",tsdir,"/MOD06_",tile,"_ymon.nc",sep="")) |
|
| 232 |
system(paste(ncopath,"ncks -A ",tsdir,"/MOD06_",tile,"_ymoncer20.nc ",tsdir,"/MOD06_",tile,"_ymon.nc",sep="")) |
|
| 233 |
system(paste(ncopath,"ncks -A ",tsdir,"/MOD06_",tile,"_ymonmiss.nc ",tsdir,"/MOD06_",tile,"_ymon.nc",sep="")) |
|
| 234 |
|
|
| 235 |
## append sinusoidal grid from one of input files as CDO doesn't transfer all attributes |
|
| 236 |
system(paste(ncopath,"ncks -A -v sinusoidal ",list.files(tsdir,full=T,pattern="daily[.]nc$")[1]," ",tsdir,"/MOD06_",tile,"_ymon.nc",sep="")) |
|
| 237 |
|
|
| 238 |
## invert latitude so it plays nicely with gdal |
|
| 239 |
system(paste(ncopath,"ncpdq -O -a -y ",tsdir,"/MOD06_",tile,"_ymon.nc ",outdir2,"/MOD06_",tile,".nc",sep="")) |
|
| 240 |
|
|
| 241 |
## update attributes |
|
| 242 |
system(paste(ncopath,"ncatted ", |
|
| 243 |
#" -a standard_parallel,sinusoidal,o,c,\"0\" ", |
|
| 244 |
#" -a longitude_of_central_meridian,sinusoidal,o,c,\"0\" ", |
|
| 245 |
#" -a latitude_of_central_meridian,sinusoidal,o,c,\"0\" ", |
|
| 246 |
" -a units,time,o,c,\"days since 2000-1-1 0:0:0\" ", |
|
| 247 |
" -a title,global,o,c,\"MODIS Cloud Product (MOD06) Climatology\" ", |
|
| 248 |
" -a institution,global,o,c,\"Yale University\" ", |
|
| 249 |
" -a source,global,o,c,\"MODIS Cloud Product (MOD06)\" ", |
|
| 250 |
" -a comment,global,o,c,\"Compiled by Adam M. Wilson (adam.wilson@yale.edu)\" ", |
|
| 251 |
outdir2,"/MOD06_",tile,".nc",sep="")) |
|
| 252 |
|
|
| 200 | 253 |
|
| 201 | 254 |
print("Finished! %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%")
|
| 202 | 255 |
## quit R |
| ... | ... | |
| 206 | 259 |
################################################################# |
| 207 | 260 |
|
| 208 | 261 |
### copy the files back to Yale |
| 209 |
list.files("2_daily")
|
|
| 210 |
system(paste("scp ",outdir2,"/*_ymonmean.nc adamw@acrobates.eeb.yale.edu:/data/personal/adamw/projects/interp/data/modis/Venezuela/summary",sep=""))
|
|
| 262 |
system(paste("scp ",outdir2,"/MOD06_",tile,".nc adamw@acrobates.eeb.yale.edu:/data/personal/adamw/projects/interp/data/modis/mod06/summary",sep=""))
|
|
| 211 | 263 |
|
| 212 | 264 |
system("scp /tmp/Rtmp6I6tFn/MOD06_L2.A2000061.1615.051.2010273184629.hdf adamw@acrobates.eeb.yale.edu:/data/personal/adamw/projects/interp/data/modis/Venezuela")
|
| 213 | 265 |
system("scp 2_daily/MOD06_20000410.nc adamw@acrobates.eeb.yale.edu:/data/personal/adamw/projects/interp/data/modis/Venezuela")
|
Also available in: Unified diff
Identified problem in handling of missing values of MOD06 product. In some areas limiting quality control to the highest quality results in ~90% NAs.