2012-12-31 128 views
1

我有多个实体存储在同一个物理Azure表中。我试图从文件中插入/合并表项。我试图找到一种方法来做到这一点,没有真正序列化每个属性或创建自定义实体的事情。如何使用Windows Azure SDK 2.0插入/更新到Azure表中

在尝试下面的代码时,我想也许我可以使用泛型DynamicTableEntity。但是,我不确定它是否有助于插入操作(大多数文档是用于替换/合并操作)。

我得到的错误是 的HResult = -2146233088 消息=意外响应代码进行操作:0 源= Microsoft.WindowsAzure.Storage

任何帮助理解。

这里是我的代码的摘录

_tableClient = storageAccount.CreateCloudTableClient(); 
      _table = _tableClient.GetTableReference("CloudlyPilot"); 

      _table.CreateIfNotExists(); 


      TableBatchOperation batch = new TableBatchOperation(); 

      .... 

      foreach (var pkGroup in result.Elements("PartitionGroup")) 
      { 

       foreach (var entity in pkGroup.Elements()) 
       { 
        DynamicTableEntity tableEntity = new DynamicTableEntity(); 
        string partitionKey = entity.Elements("PartitionKey").FirstOrDefault().Value; 
        string rowKey = entity.Elements("RowKey").FirstOrDefault().Value; 
        Dictionary<string, EntityProperty> props = new Dictionary<string, EntityProperty>(); 

        //if (pkGroup.Attribute("name").Value == "CloudServices Page") 
        //{ 
        // tableEntity = new CloudServicesGroupEntity (partitionKey, rowKey); 
        //} 
        //else 
        //{ 
        // tableEntity = new CloudServiceDetailsEntity(partitionKey,rowKey); 
        //} 

        foreach (var element in entity.Elements()) 
        { 
         tableEntity.Properties[element.Name.ToString()] = new EntityProperty(element.Value.ToString()); 
        } 

        tableEntity.ETag = Guid.NewGuid().ToString(); 
        tableEntity.Timestamp = new DateTimeOffset(DateTime.Now.ToUniversalTime()); 

        //tableEntity.WriteEntity(/*WHERE TO GET AN OPERATION CONTEXT FROM?*/) 

        batch.InsertOrMerge(tableEntity); 
       } 
       _table.ExecuteBatch(batch); 

       batch.Clear(); 

      } 

回答

3

您是否尝试过使用DictionaryTableEntity?这个类允许你动态地填充实体,就好像它是一个字典(类似于DynamicTableEntity)。我想是这样你的代码,它的工作原理:

 var batch = new TableBatchOperation(); 

     var entity1 = new DictionaryTableEntity(); 
     entity1.PartitionKey = "abc"; 
     entity1.RowKey = Guid.NewGuid().ToString(); 
     entity1.Add("name", "Steve"); 
     batch.InsertOrMerge(entity1); 

     var entity2 = new DictionaryTableEntity(); 
     entity2.PartitionKey = "abc"; 
     entity2.RowKey = Guid.NewGuid().ToString(); 
     entity2.Add("name", "Scott"); 
     batch.InsertOrMerge(entity2); 

     table.ExecuteBatch(batch); 

     var entities = table.ExecuteQuery<DictionaryTableEntity>(new TableQuery<DictionaryTableEntity>()); 

最后一两件事,我看到你设置的时间戳和ETag自己。删除这两行,然后重试。

+0

有趣的是,这两个代码库(DynamicTableEntity以及DictionaryTableEntity)在基于ASP.NET的应用程序上工作,但不在Windows 8上。已打开支持请求。 – user1939211

相关问题