1    public class Album : TableServiceEntity 2     {        3     } 4     public class PhotoAlbumDataContext : TableServiceContext 5     { 6       public PhotoAlbumDataContext() 7             : this(CloudStorageAccount.FromConfigurationSetting("DataConnectionString")) 8         { 9         }10 11         public PhotoAlbumDataContext(Microsoft.WindowsAzure.CloudStorageAccount account)12             : base(account.TableEndpoint.ToString(), account.Credentials)13         {14             if (!initialized)15             {16                 lock (initializationLock)17                 {18                     if (!initialized)19                     {20                         this.CreateTables();21                         initialized = true;22                     }23                 }24             }25     26      }27       //getlist28       var context = new PhotoAlbumDataContext();29       var list=context.Albums.AsTableServiceQuery().AsEnumerable()30       31       32       //add33       context.AddObject("Alblum_TableName", new Album());34       //context.SaveChanges();35       context.SaveChanges(SaveChangesOptions.ContinueOnError);36       37       38        //get delete39         var album = context.Albums40                .Where(a => a.AlbumId == albumName && a.PartitionKey == owner.ToLowerInvariant()).AsTableServiceQuery()41                .Single();42 43          context.DeleteObject(album);44          context.SaveChanges();45         46         //delete47          context.AttachTo("TableName", photoRow, "*");48          context.DeleteObject(photoRow);49          context.SaveChanges();50              51          52          53          //update54           var albumRow = new Album(album);55          // attach and update the photo row56          context.AttachTo("TableName", albumRow, "*");57          context.UpdateObject(albumRow);58          context.SaveChanges();59          60          61          62          

 1        public class Subscriber : TableEntity 2       { 3         [Required] 4         [Display(Name = "List Name")] 5         public string ListName 6         { 7             get 8             { 9                 return this.PartitionKey; //分区键10             }11             set12             {13                 this.PartitionKey = value;14             }15         }16 17         [Required]18         [Display(Name = "Email Address")]19         public string EmailAddress20         {21             get22             {23                 return this.RowKey;24             }25             set26             {27                 this.RowKey = value;28             }29         }30 31         public string SubscriberGUID { get; set; }32 33         public bool? Verified { get; set; }34     }35 }36 37 38    39    40    var storageAccount = CloudStorageAccount.Parse(ConfigurationManager.ConnectionStrings["StorageConnectionString"].ConnectionString);41    var tableClient = storageAccount.CreateCloudTableClient();42    var mailingListTable = tableClient.GetTableReference("mailinglist");43        mailingListTable.CreateIfNotExists();44        45    46    //获取Get47    var retrieveOperation = TableOperation.Retrieve<T>(_partitionKey, _rowKey);48    var retrievedResult = mailingListTable.Execute(retrieveOperation);49    return retrievedResult.Result as T;50    51    //GetList52      string filter = TableQuery.CombineFilters(53                 TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, _partitionKey),54                 TableOperators.And,55                 TableQuery.GenerateFilterCondition("SubscriberGUID", QueryComparisons.Equal, subscriberGUID));56             var query = new TableQuery<Subscriber>().Where(filter);57             var subscribers = mailingListTable.ExecuteQuery(query).ToList();58             59             60    //添加 Add61     var insertOperation = TableOperation.Insert(newSubscriber);62     mailingListTable.Execute(insertOperation);63     64     //Update Or Insert65     var upsertOperation = TableOperation.InsertOrReplace(emailRowInTable);66     mailingListTable.Execute(upsertOperation);67     68     69     //Update70      replaceOperation = TableOperation.Replace(emailRowInTable);71      mailingListTable.Execute(replaceOperation);72         73     //Delete74       var deleteOperation = TableOperation.Delete(emailRowToDelete);75       mailingListTable.Execute(deleteOperation);

 1   var storageAccount = CloudStorageAccount.Parse(ConfigurationManager.ConnectionStrings["StorageConnectionString"].ConnectionString); 2   var queueClient = storageAccount.CreateCloudQueueClient(); 3   foreach(var q in queueClient.ListQueues()){//所有队列 4        var msg = q.GetMessage(); 5        var id = msg.Id; 6        var name=q.Name; //队列名字:azuremailsubscribequeue 7   } 8    9   10   subscribeQueue = queueClient.GetQueueReference("azuremailsubscribequeue");11   subscribeQueue.CreateIfNotExists();12   13   14   subscribeQueue.AddMessage(new CloudQueueMessage(newSubscriber.SubscriberGUID + "," + newSubscriber.ListName));15   16   msg = subscribeQueue.GetMessage();17   18   subscribeQueue.DeleteMessage(msg);19   20   21   public class WorkerRole : RoleEntryPoint22   {23   24   }

 1 using System.Net; 2 using System.Net.Mail; 3 using Microsoft.WindowsAzure.Diagnostics; 4 using Microsoft.WindowsAzure.ServiceRuntime; 5 using Microsoft.WindowsAzure.Storage.Blob; 6 using Microsoft.WindowsAzure.Storage.Queue; 7 using Microsoft.WindowsAzure.Storage.Table;  8 using SendGridMail; 9 using SendGridMail.Transport;10 11   var storageAccount=CloudStorageAccount.FromConfigurationSetting("DataConnectionString");12   13 14         private static void SendSubscribeEmail(string subscriberGUID, Subscriber subscriber, MailingList mailingList)15         {16             var email = SendGrid.GenerateInstance();17             email.From = new MailAddress(mailingList.FromEmailAddress);18             email.AddTo(subscriber.EmailAddress);19             string subscribeURL = RoleEnvironment.GetConfigurationSettingValue("AzureMailServiceURL") +20                 "/subscribe?id=" + subscriberGUID + "&listName=" + subscriber.ListName;21             email.Html = String.Format("<p>Click the link below to subscribe to {0}. " +22                 "If you don‘t confirm your subscription, you won‘t be subscribed to the list.</p>" +23                 "<a href=http://www.mamicode.com/"{1}\">Confirm Subscription</a>", mailingList.Description, subscribeURL);24             email.Text = String.Format("Copy and paste the following URL into your browser in order to subscribe to {0}. " +25                 "If you don‘t confirm your subscription, you won‘t be subscribed to the list.\n" +26                 "{1}", mailingList.Description, subscribeURL);27             email.Subject = "Subscribe to " + mailingList.Description;28             var credentials = new NetworkCredential(RoleEnvironment.GetConfigurationSettingValue("SendGridUserName"), RoleEnvironment.GetConfigurationSettingValue("SendGridPassword"));29             var transportREST = REST.GetInstance(credentials);30             transportREST.Deliver(email);31         }32         33         34         private string GetBlobText(string blogRef)35         {36             var blob = blobContainer.GetBlockBlobReference(blogRef);37             blob.FetchAttributes();38             var blobSize = blob.Properties.Length;39             using (var memoryStream = new MemoryStream((int)blobSize))40             {41                 blob.DownloadToStream(memoryStream);42                 return System.Text.Encoding.UTF8.GetString(memoryStream.ToArray());43             }44         }45         46         47         //upload image (stream)48         var blob = container.GetBlobReference(file);49             blob.Properties.ContentType = mimeType;50             blob.UploadFromStream(binary);51             52             53        //down image54          var client = this.storageAccount.CreateCloudBlobClient();55          var container = client.GetContainerReference(owner);56 57          using (var ms = new MemoryStream())58          {59               container.GetBlobReference(file).DownloadToStream(ms);60               var image = Image.FromStream(ms); 61          }62          63       64          // save it off to blob storage65           using (var thumbStream = new MemoryStream())66           {67                  thumb.Save(68                      thumbStream,69                      System.Drawing.Imaging.ImageFormat.Jpeg);70 71                    thumbStream.Position = 0; // reset;72 73                    var thumbBlob = container.GetBlobReference(Path.Combine("thumb", file));74                    thumbBlob.Properties.ContentType = "image/jpeg";75                    thumbBlob.UploadFromStream(thumbStream);76            }77            78            79            //use image80            var blobUri = client.GetContainerReference(owner).GetBlobReference(file).Uri.ToString();81            var thumbUri = client.GetContainerReference(owner).GetBlobReference(Path.Combine("thumb", file)).Uri.ToString();82            83          84          85            //delete 86             87            var blobGone = container.GetBlobReference(filename).DeleteIfExists();  88            var thumbGone = container.GetBlobReference(thumbname).DeleteIfExists();