Changeset 9395 for branches/OaaS/HeuristicLab.Services.Optimization.Controller/Azure

Timestamp:

04/24/13 13:40:43 (12 years ago)

Author:

fschoepp

Message:

#1888:

• Added visual extensions (dynamic JavaScript) which will be used to render additional result parameters specific to scenarios (e. g. create a graphical representation of a TSP).
• Added relationship between jobs and experiments (otherwise, it's not possible to get the job's experiment).
• Updated Admin page to allow removal/addition of visual extensions.
• Added back-end logic to store/retrieve/delete visual extensions.
• Added visual extension functionality to the JavaScript views/controllers (job.*.js).
• Added tsp.js which is a visual extension for the "Genetic Algorithm - TSP" scenario. It adds a graphical representation of the TSP (just like the C# version does) to the results.

File:

• branches/OaaS/HeuristicLab.Services.Optimization.Controller/Azure/DAL.cs (modified) (4 diffs)

branches/OaaS/HeuristicLab.Services.Optimization.Controller/Azure/DAL.cs

@@ -18 +18 @@
     public static readonly string EXPERIMENT_BLOB_CONTAINER = "experiment";
     public static readonly string VISUAL_BLOB_CONTAINER = "visualextensions";
+    public static readonly string JOB_TABLE = "Job";
     public static readonly string CLOUD_SETTINGS_KEY = "Cloudia.WindowsAzure.Storage";
 
@@ -311 +312 @@
 
     public string FindById(string algorithmId) {
-      CloudBlobContainer container = BlobClient.GetContainerReference(AzureConstants.VISUAL_BLOB_CONTAINER);
-      container.CreateIfNotExist();
-      var blob = container.GetBlobReference(algorithmId);
-      return blob.DownloadText();
+      try {
+        CloudBlobContainer container = BlobClient.GetContainerReference(AzureConstants.VISUAL_BLOB_CONTAINER);
+        container.CreateIfNotExist();
+        var blob = container.GetBlobReference(algorithmId);
+        return blob.DownloadText();
+      }
+      catch (Exception ex) {
+        Trace.TraceError(ex.ToString());
+        return null;
+      }
+    }
+
+
+    public bool Exists(string algorithmId) {
+      try {
+        CloudBlobContainer container = BlobClient.GetContainerReference(AzureConstants.VISUAL_BLOB_CONTAINER);
+        container.CreateIfNotExist();
+        var blob = container.GetBlobReference(algorithmId);
+        blob.FetchAttributes();
+        return true;
+      }
+      catch (StorageClientException ex) {
+        if (ex.ErrorCode == StorageErrorCode.ResourceNotFound) {
+          return false;
+        }
+        Trace.TraceError(ex.ToString());
+        return false;
+      }
+    }
+  }
+
+  internal sealed class JobEntity : TableServiceEntity {
+    public JobEntity() {
+    }
+
+    public JobEntity(string user, string experimentName, string experimentId, string jobId) {
+      PartitionKey = "JobPartition";
+      RowKey = user + "_" + jobId;
+      User = user;
+      ExperimentId = experimentId;
+      JobId = jobId;
+    }
+
+    public string ExperimentId { get; set; }
+
+    public string User { get; set; }
+
+    public string JobId { get; set; }
+  }
+
+  public class JobDao : IJobDao {
+    public IExperimentDao ExperimentDao { get; set; }
+    public CloudTableClient TableClient { get; set; }
+
+    public bool Add(string username, Experiment experiment, string jobId) {
+      try {
+        TableServiceContext serviceContext = TableClient.GetDataServiceContext();
+        TableClient.CreateTableIfNotExist(AzureConstants.JOB_TABLE);
+        serviceContext.AddObject(AzureConstants.JOB_TABLE,
+          new JobEntity(username, experiment.Name, experiment.Id, jobId)
+        );
+        serviceContext.SaveChangesWithRetries();
+        return true;
+      }
+      catch (Exception ex) {
+        Trace.TraceError(ex.ToString());
+        return false;
+      }
+    }
+
+    public bool Delete(string username, string jobId) {
+      try {
+        TableServiceContext serviceContext = TableClient.GetDataServiceContext();
+        TableClient.CreateTableIfNotExist(AzureConstants.JOB_TABLE);
+        var entity = (from e in serviceContext.CreateQuery<JobEntity>(AzureConstants.JOB_TABLE)
+                      where e.JobId == jobId && e.User == username
+                      select e).FirstOrDefault();
+        serviceContext.DeleteObject(entity);        
+        return true;
+      }
+      catch (Exception ex) {
+        Trace.TraceError(ex.ToString());
+        return false;
+      }
+    }
+
+    public Experiment FindByJobId(string username, string jobId) {
+      try {
+        TableServiceContext serviceContext = TableClient.GetDataServiceContext();
+        TableClient.CreateTableIfNotExist(AzureConstants.JOB_TABLE);
+        var entity = (from e in serviceContext.CreateQuery<JobEntity>(AzureConstants.JOB_TABLE)
+                      where e.JobId == jobId && e.User == username
+                      select e).FirstOrDefault();
+        return ExperimentDao.GetExperimentById(new User() { Username = username }, entity.ExperimentId);
+      }
+      catch (Exception ex) {
+        Trace.TraceError(ex.ToString());
+        return null;
+      }
     }
   }
@@ -323 +419 @@
     private IExperimentDao expDao;
     private IVisualExtensionDao visualDao;
+    private IJobDao jobDao;
 
     private CloudStorageAccount storageAccount;
@@ -377 +474 @@
       }
     }
+
+
+    public IJobDao JobDao {
+      get {
+        if (jobDao == null) {
+          jobDao = new JobDao() { ExperimentDao = ExperimentDao, TableClient = StorageAccount.CreateCloudTableClient() };
+        }
+        return jobDao;
+      }
+    }
   }
 }