Changeset 7563

Timestamp:

03/06/12 15:50:21 (8 years ago)

Author:

spimming

Message:

#1680:

• Create deployment with local configuration file
• New extension method to parallel upload a file to blob storage
• Constants for deployment packages and configuration added

Location:

branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive.CloudManager/3.3/Azure

Files:

• AzureProvider.cs (modified) (2 diffs)
• CloudBlobExtension.cs (modified) (2 diffs)
• Constants.cs (modified) (1 diff)
• IAzureProvider.cs (modified) (2 diffs)

branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive.CloudManager/3.3/Azure/AzureProvider.cs

@@ -22 +22 @@
 using System;
 using System.Collections.Generic;
+using System.IO;
 using HeuristicLab.Clients.Hive.CloudManager.Model;
 
@@ -161 +162 @@
     }
 
+    public string CreateDeployment(Subscription subscription, string serviceName, string deploymentName, string deploymentSlot, string packageUrl, FileInfo configuration, string label, int instanceCount) {
+      if (subscription == null) {
+        throw new ArgumentNullException("Subscription must not be null.", "subscription");
+      }
+      if (instanceCount <= 0) {
+        throw new ArgumentException("Instance count must be greater than zero.", "instanceCount");
+      }
+
+      string config = File.ReadAllText(configuration.FullName);
+      return ServiceManagementOperation.CreateDeployment(subscription.SubscriptionID, subscription.CertificateThumbprint, serviceName, deploymentName, deploymentSlot, packageUrl, config, label, instanceCount);
+
+    }
+
     public string DeleteHostedService(Subscription subscription, string serviceName) {
       if (subscription == null) {

branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive.CloudManager/3.3/Azure/CloudBlobExtension.cs

@@ -1 +1 @@
 
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Text;
+using System.Threading.Tasks;
 using Microsoft.WindowsAzure.StorageClient;
 namespace HeuristicLab.Clients.Hive.CloudManager.Azure {
   public static class CloudBlobExtension {
+    private class BlockTransferDetail {
+      public int StartPosition { get; set; }
+      public int BytesToRead { get; set; }
+      public string BlockId { get; set; }
+    }
+
     //check if a blob exists
     // see: http://stackoverflow.com/questions/2642919/checking-if-a-blob-exists-in-azure-storage
@@ -17 +28 @@
         }
       }
+    }
+
+    public static void UploadParallel(this CloudBlockBlob blob, string filePath) {
+      FileInfo file = new FileInfo(filePath);
+      //CloudBlockBlob blob = blobContainer.GetBlockBlobReference(file.Name);
+      blob.Properties.ContentType = "application/octet-stream";
+
+      // init
+      int blockSize = 262144;
+      long fileSize = file.Length;
+      long leftToRead = fileSize;
+      int startPosition = 0;
+
+      int blockCount = ((int)Math.Floor((double)(fileSize / blockSize))) + 1;
+      BlockTransferDetail[] transferDetails = new BlockTransferDetail[blockCount];
+      List<string> blockIdList = new List<string>();
+
+      // setup control array
+      for (int j = 0; j < transferDetails.Length; j++) {
+        int toRead = (int)(leftToRead > blockSize ? blockSize : leftToRead);
+        string blockId = Convert.ToBase64String(ASCIIEncoding.ASCII.GetBytes(string.Format("BlockId{0}", j.ToString("0000000"))));
+        transferDetails[j] = new BlockTransferDetail() { StartPosition = startPosition, BytesToRead = toRead, BlockId = blockId };
+        if (toRead > 0) {
+          blockIdList.Add(blockId);
+        }
+        startPosition += toRead;
+        leftToRead -= toRead;
+      }
+
+      // perform parallel upload
+      var result = Parallel.For(0, transferDetails.Length, j => {
+        using (FileStream fs = new FileStream(file.FullName, FileMode.Open, FileAccess.Read)) {
+          byte[] buffer = new byte[transferDetails[j].BytesToRead];
+          BinaryReader br = new BinaryReader(fs);
+          fs.Seek(transferDetails[j].StartPosition, SeekOrigin.Begin);
+          br.Read(buffer, 0, transferDetails[j].BytesToRead);
+          if (buffer.Length > 0) {
+            using (MemoryStream ms = new MemoryStream(buffer)) {
+              blob.PutBlock(transferDetails[j].BlockId, ms, null);
+            }
+          }
+        }
+      });
+      blob.PutBlockList(blockIdList);
     }
 

branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive.CloudManager/3.3/Azure/Constants.cs

@@ -92 +92 @@
     public const string DeploymentPackageUrl = "https://hivestorage.blob.core.windows.net/hiveslave/HeuristicLab.Clients.Hive.Slave.Azure.cspkg";
     public const string DeploymentConfigurationUrl = "https://hivestorage.blob.core.windows.net/hiveslave/ServiceConfiguration.Cloud.cscfg";
-    public const string DeploymentConfigurationPath = "files/ServiceConfiguration.Cloud.cscfg";
+
     public const string DeploymentLabel = "HeuristicLab.Hive.Slave";
     public const string DeploymentRoleName = "HeuristicLab.Clients.Hive.Slave.AzureClient";
+
+    public const string DeploymentConfigurationPath = "PackageFiles/ServiceConfiguration.Cloud.cscfg";
+    public const string DeploymentPackagePathSmall = "PackageFiles/HeuristicLab.Clients.Hive.Slave.Azure.Small.cspkg";
+    public const string DeploymentPackagePathMedium = "PackageFiles/HeuristicLab.Clients.Hive.Slave.Azure.Medium.cspkg";
+    public const string DeploymentPackagePathLarge = "PackageFiles/HeuristicLab.Clients.Hive.Slave.Azure.Large.cspkg";
+    public const string DeploymentPackagePathExtraLarge = "PackageFiles/HeuristicLab.Clients.Hive.Slave.Azure.ExtraLarge.cspkg";
 
     #endregion

branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive.CloudManager/3.3/Azure/IAzureProvider.cs

@@ -21 +21 @@
 
 using System.Collections.Generic;
+using System.IO;
 using HeuristicLab.Clients.Hive.CloudManager.Model;
 
@@ -37 +38 @@
     string CreateDeployment(Subscription subscription, string serviceName, string deploymentName, string deploymentSlot, string packageUrl, string configurationUrl, string label);
     string CreateDeployment(Subscription subscription, string serviceName, string deploymentName, string deploymentSlot, string packageUrl, string configurationUrl, string label, int instanceCount);
+    string CreateDeployment(Subscription subscription, string serviceName, string deploymentName, string deploymentSlot, string packageUrl, FileInfo configuration, string label, int instanceCount);
     string DeleteHostedService(Subscription subscription, string serviceName);