test/testGrapleR.R

In GRAPLE/GRAPLEr: Distributed Computing Made Easy for Lake Ecology Modeling

library(httr)
library(RCurl)
library(jsonlite)
library(GRAPLEr)

# Default SubmissionURL is set to http://graple.acis.ufl.edu, use setSubmissionURL method to change submissionURL
graple <- new("Graple")

#The result of the method call is stored in the object itself
graple <- GrapleCheckService(graple)
cat(graple@StatusMsg)
graple <- GrapleListPostProcessFilters(graple)
cat(graple@StatusMsg)
graple <- GrapleChkVersionCompatibility(graple)
cat(graple@StatusMsg)

#Batch Experiment
#
#Start a new experiment and setup parameters
#Retention specifies the number of days to retain results on server. Set to 10 if not specified. 0 denotes that results be deleted after first download
#Set APIKey parameters to readLines from the key file. If you're a registered user, your default email will be used 
grapleExp1 <- new("Graple", APIKey = readLines("D:/GRAPLE/grapleKey.txt"), Retention = 5, ExpRootDir = "D:/GRAPLE/ExpRoot/Exp1", ResultsDir = "D:/GRAPLE/Results/Exp1", TempDir = tempdir())
grapleExp1 <- setExpName(grapleExp1, "BatchExperiment1")

# Change SubmissionURL
# grapleExp1 <- setSubmissionURL(grapleExp1, "http://10.244.37.4:5000")

# Change directories
#grapleExp1 <- setExperimentDir(grapleExp1, "C:/ExpRoot/Exp1")
#grapleExp1 <- setResultsDir(grapleExp1, "C:/ExpRoot/Results/Exp1")
#grapleExp1 <- setTempDir(grapleExp1, "C:/TempDir")
#grapleExp1 <- setAPIKey(grapleExp1, 'C:/APIKey.txt')

#Run the experiment
grapleExp1 <- GrapleRunExperiment(grapleExp1);
cat(grapleExp1@StatusMsg)

#check on status and wait until it is ready
grapleExp1 <- GrapleCheckExperimentCompletion(grapleExp1)
while (grapleExp1@StatusMsg != '100.0% complete') {
  Sys.sleep(5);
  grapleExp1 <- GrapleCheckExperimentCompletion(grapleExp1) 
  cat(grapleExp1@StatusMsg);
}

#get the experiment results. Extracted to results dir you specified
grapleExp1 <- GrapleGetExperimentResults(grapleExp1);
cat(grapleExp1@StatusMsg);

#
##Batch Experiment w/ Filter
#
filterName <- "ExtractVariables"
grapleExp2 <- new("Graple", APIKey = readLines("D:/GRAPLE/grapleKey.txt"), Retention = 0, ExpRootDir = "D:/GRAPLE/ExpRoot/Exp2", ResultsDir = "D:/GRAPLE/Results/Exp2", TempDir = tempdir())
grapleExp2 <- GrapleRunExperiment(grapleExp2, filterName);
cat(grapleExp2@StatusMsg);
grapleExp2 <- GrapleCheckExperimentCompletion(grapleExp2);
grapleExp2 <- GrapleGetExperimentResults(grapleExp2);

#
#Multiple Sweep Experiments at once
#Set Email field to get an email notification
#GrapleRunSweepExperiment(grapleObject, "FilterName")
#Set email parameter to override default email
grapleExp3 <- new("Graple", APIKey = readLines("D:/GRAPLE/grapleKey.txt"), Email = "example@mail.com", ExpRootDir = "D:/GRAPLE/ExpRoot/Exp3", ResultsDir = "D:/GRAPLE/Results/Exp3", TempDir = tempdir())
grapleExp4 <- new("Graple", Email = "example@mail.com", Retention = 0, ExpRootDir = "D:/GRAPLE/ExpRoot/Exp4", ResultsDir = "D:/GRAPLE/Results/Exp4", TempDir = tempdir())
grapleExp3 <- setExpName(grapleExp3, "SweepExperiment3")
grapleExp4 <- setExpName(grapleExp4, "SweepExperiment4")
grapleExp3 <- GrapleRunSweepExperiment(grapleExp3, "ExtractVariables")
cat(grapleExp3@StatusMsg)
grapleExp4 <- GrapleRunSweepExperiment(grapleExp4, "CCC_ALH_7May2016")
cat(grapleExp4@StatusMsg)

grapleExp3 <- GrapleCheckExperimentCompletion(grapleExp3)
grapleExp4 <- GrapleCheckExperimentCompletion(grapleExp4)
while (grapleExp3@StatusMsg != '100.0% complete' && grapleExp4@StatusMsg != '100.0% complete') {
  Sys.sleep(10);
  grapleExp3 <- GrapleCheckExperimentCompletion(grapleExp3)
  cat(paste(grapleExp3@ExpName, grapleExp3@StatusMsg, sep=":"))

  grapleExp4 <- GrapleCheckExperimentCompletion(grapleExp4)
  cat(paste(grapleExp4@ExpName, grapleExp4@StatusMsg, sep = ":"))
}

grapleExp3 <- GrapleGetExperimentResults(grapleExp3)
cat(grapleExp3@StatusMsg)
grapleExp4 <- GrapleGetExperimentResults(grapleExp4)
cat(grapleExp4@StatusMsg)