Ajouter ou remplacer l'entité dans Azure Table Storage

Je travaille avec Windows Azure Table Storage et ont une simple exigence: ajouter une nouvelle ligne, en remplaçant la ligne existante avec qui PartitionKey/RowKey. Toutefois, en enregistrant les modifications jette toujours une exception, même si je passe dans le ReplaceOnUpdate option:

tableServiceContext.AddObject(TableName, entity);
tableServiceContext.SaveChangesWithRetries(SaveChangesOptions.ReplaceOnUpdate);

Si l'entité qui existe déjà, il lance:

System.Data.Services.Client.DataServiceRequestException: An error occurred while processing this request. ---> System.Data.Services.Client.DataServiceClientException: <?xml version="1.0" encoding="utf-8" standalone="yes"?>
<error xmlns="http://schemas.microsoft.com/ado/2007/08/dataservices/metadata">
  <code>EntityAlreadyExists</code>
  <message xml:lang="en-AU">The specified entity already exists.</message>
</error>

Dois-je vraiment une requête manuelle de la ligne existante d'abord et appeler DeleteObject sur elle? Qui semble très lent. Il y a sûrement un meilleur moyen?

OriginalL'auteur EMP | 2010-12-17

  1. 15

    Comme vous l'avez trouvé, vous ne pouvez pas ajouter un autre élément qui a la même ligne de clé et la clé de partition, de sorte que vous aurez besoin pour exécuter une requête pour vérifier si l'élément existe déjà. Dans ce cas là, je trouve qu'il est utile de regarder la Azure API REST pour voir ce qui est disponible pour le stockage de la bibliothèque du client. Vous verrez que il y a différentes méthodes pour insérer et mise à jour. Le ReplaceOnUpdate n'a d'effet que lorsque vous faites une mise à jour, pas de l'insérer.

    Alors que vous pourriez supprimer l'élément existant, puis l'ajout de la nouvelle, vous pouvez simplement mettre à jour l'existant (vous permet d'économiser un aller-retour pour le stockage). Votre code pourrait ressembler à quelque chose comme ceci:

    var existsQuery = from e
                    in tableServiceContext.CreateQuery<MyEntity>(TableName)
                    where
                    e.PartitionKey == objectToUpsert.PartitionKey
                    && e.RowKey == objectToUpsert.RowKey
                    select e;

MyEntity existingObject = existsQuery.FirstOrDefault();

if (existingObject == null)
{
    tableServiceContext.AddObject(TableName, objectToUpsert);
}
else
{
    existingObject.Property1 = objectToUpsert.Property1;
    existingObject.Property2 = objectToUpsert.Property2;

    tableServiceContext.UpdateObject(existingObject);
}

tableServiceContext.SaveChangesWithRetries(SaveChangesOptions.ReplaceOnUpdate);

    EDIT: Alors que correcte au moment de l'écriture, avec le mois de septembre 2011 mise à jour de Microsoft ont mis à jour l'Azure table API pour inclure deux upsert commandes, Insérer ou Remplacer Entité et Insérer ou de Fusion de l'Entité

    Merci, j'ai pensé à cela, mais cela signifie que ce code doit être conscient de tous les biens doit être copié (ou de l'entité elle-même a besoin d'un CopyTo méthode) et il doit être mis à jour chaque fois que le changement de propriété. Je crois que je préfère payer le prix de la supprimer et d'en être sûr.
    Eh bien, j'ai fini par faire cela, autant que j'en avais pas envie. Peu importe combien j'ai essayé de supprimer et de re-insertion de l'entité qu'elle n'a tout simplement pas de travail realiably - une fois, elle allait réussir, la prochaine fois échouer avec une erreur, la prochaine fois échouer avec l'autre.
    Je trouve cela surprenant. Étiez-vous en essayant de sauver à la fois le complément et le supprimer dans le cadre de l'un .Save() de l'appel, ou étiez-vous en train de faire .AddObject(); .Save(); .DeleteObject(); .Save();

    OriginalL'auteur knightpfhor

  2. 1

    Afin de fonctionner sur un objet existant ne sont PAS gérés par le TableContext avec les Supprimer ou les SaveChanges avec ReplaceOnUpdate options, vous devez appeler AttachTo et attacher l'objet de la TableContext, au lieu d'appeler AddObject qui indique TableContext pour tenter de l'insérer.

    http://msdn.microsoft.com/en-us/library/system.data.services.client.dataservicecontext.attachto.aspx

    Merci, mais je ne sais pas si l'entité existe déjà ou pas quand ma méthode est appelée.
    Désolé, il n'a pas lu assez attentivement le problème initial. Vous aurez besoin de faire une lecture avant de la main. N'avez pas besoin de supprimer cette ligne. Juste faire une mise à Jour en place si la ligne existe ou insérer si elle ne marche pas. Pas de l'éviter.

    OriginalL'auteur Igorek

  3. 1

    dans mon cas, il n'était pas autorisé à retirer tout d'abord, donc je fais comme ça, cela résultera en une seule transaction au serveur qui va d'abord supprimer un objet existant et que d'en ajouter de nouveaux, en supprimant le besoin de copier des valeurs de propriété

           var existing = from e in _ServiceContext.AgentTable
                       where e.PartitionKey == item.PartitionKey
                             && e.RowKey == item.RowKey
                       select e;

        _ServiceContext.IgnoreResourceNotFoundException = true;
        var existingObject = existing.FirstOrDefault();

        if (existingObject != null)
        {
            _ServiceContext.DeleteObject(existingObject);
        }

        _ServiceContext.AddObject(AgentConfigTableServiceContext.AgetnConfigTableName, item);

        _ServiceContext.SaveChangesWithRetries();
        _ServiceContext.IgnoreResourceNotFoundException = false;
    Je pense que vous pourriez avoir besoin de regarder dans ce qui se passe vraiment sous le capot. Pour autant que je suis conscient que le sous-jacent RESTE de l'API ne peut pas traiter avec ajoute et supprime en un seul appel. Ainsi, alors que vous êtes juste d'appeler .Save() une fois, ça va être l'envoi de deux appels vers le service de stockage.

    OriginalL'auteur zebra

  4. 0

    L'API de Stockage ne permettent pas plus d'une opération par entité (delete+insert) dans un groupe de transaction:

    Une entité peut apparaître qu'une seule fois dans la transaction, et seule une opération peut être faite à son encontre.

    voir MSDN: arts du Spectacle, Entité du Groupe Transactions

    Donc, en fait, vous avez besoin de lire d'abord et décider lors de l'insertion ou de mise à jour.

    OriginalL'auteur fabsenet

  5. 0

    Insérer/de Fusion ou de mise à Jour a été ajouté à l'API en septembre 2011. Voici un exemple d'utilisation de l'API de Stockage 2.0 qui est plus facile à comprendre que la façon dont c'est fait dans la 1.7 api et plus tôt.

    public void InsertOrReplace(ITableEntity entity)
    {
        retryPolicy.ExecuteAction(
            () =>
            {
                try
                {
                    TableOperation operation = TableOperation.InsertOrReplace(entity);
                    cloudTable.Execute(operation);
                }
                catch (StorageException e)
                {
                    string message = "InsertOrReplace entity failed.";

                    if (e.RequestInformation.HttpStatusCode == 404)
                    {
                        message += " Make sure the table is created.";
                    }

                    //do something with message
                }
            });
    }
    Il y a une chasse aux sorcières dans le présent code, de le faire avec la concurrence optimiste. Vous pourriez penser que "InsertOrReplace" fonctionne comme "Insérer" et "Remplacer" dans son Upsert, tant que l'enregistrement n'a pas été changé depuis la dernière vérification. Mais ce serait faux. "InsertOrReplace" signifie en fait "écraser ce record n'importe quoi, et d'ignorer les contrôles d'accès concurrentiel optimiste". Donc, si vous ne se soucient pas de l'accès concurrentiel optimiste puis une grande! Sinon, vous ne voulez probablement pas à utiliser ce que "Upsert".

    OriginalL'auteur lockwobr