Comment interroger toutes les lignes dans windows azure table storage?

Je suis en train d'essayer d'obtenir une liste de toutes les entités à l'intérieur de mon azure table.

Une idée de comment je pourrais aller sur l'écriture de cette requête?

Je suis à l'aide de c# btw. Merci.

  • Êtes-vous à l'aide de n'importe quelle langue spécifique de la bibliothèque par exemple .Net Client de Stockage de la bibliothèque?
  • Je suis à l'aide de Microsoft.WindowsAzure.De stockage de la bibliothèque
InformationsquelleAutor SKLAK | 2014-05-29
  1. 78

    Pour répondre à votre question, vous pourriez faire quelque chose comme ce qui suit:

    var acc = new CloudStorageAccount(
                         new StorageCredentials("account name", "account key"), true);
var tableClient = acc.CreateCloudTableClient();
var table = tableClient.GetTableReference("table name");
var entities = table.ExecuteQuery(new TableQuery<MyEntity>()).ToList();

    Mais s'il vous plaît gardez à l'esprit que le service à table renvoie un maximum de 1000 entités en un seul appel à elle. S'il n'y a plus de 1000 entités disponibles dans votre tableau, il renvoie une continuation token qui peut être utilisé pour récupérer le prochain ensemble d'entités. Le ExecuteQuery méthode gère en fait ce jeton de continuation en interne donc si vous voulez annuler cette opération pour une raison quelconque, vous ne pouvez pas le faire.

    Une meilleure approche serait d'utiliser ExecuteQuerySegmented méthode et votre application à traiter avec le jeton. Voici l'exemple de code pour le faire:

    var acc = new CloudStorageAccount(
                         new StorageCredentials("account name", "account key"), true);
var tableClient = acc.CreateCloudTableClient();
var table = tableClient.GetTableReference("table name");
TableContinuationToken token = null;
var entities = new List<MyEntity>();
do
{
    var queryResult = table.ExecuteQuerySegmented(new TableQuery<MyEntity>(), token);
    entities.AddRange(queryResult.Results);
    token = queryResult.ContinuationToken;
} while (token != null);
    • Je n'ai pu obtenir PartitionKey et RowKey à partir de ce. Afin d'obtenir toutes les propriétés, vous devez ajouter: "var entités = table.ExecuteQuery(nouveau TableQuery<Monmodèle>()).ToList();" (ajouter <Monmodèle>). Ce n'était pas évident pour moi 🙂
    • Dans ce cas MyEntity est notre propre classe? quels sont donc les getter ou un setter va être pour elle?
    • Peu confus quant à l'utilisation de "faux" sur les premières lignes des deux exemples de codes - pour être clair, vous êtes activement à la désactivation de HTTPS sur le lien, à droite? Pourquoi cela devrait-il être bénéfique pour le peg-retour à HTTP?
    • correct. C'est une mauvaise idée de laisser la circulation sur http. J'ai corrigé le code. Merci pour le porter à mon attention.
    InformationsquelleAutor Gaurav Mantri
  2. 0

    Éventuellement, un moyen plus efficace de paresseusement la récupération des éléments du tableau est: est-ce

        public IEnumerable<T> GetAll<T>(string tableName) where T : class
    {
        var table = this.GetCloudTable(tableName);
        TableContinuationToken token = null;
        do
        {
            var q = new TableQuery<T>();
            var queryResult = Task.Run(() => table.ExecuteQuerySegmentedAsync(q, token)).GetAwaiter().GetResult();
            foreach (var item in queryResult.Results)
            {
                yield return item;
            }
            token = queryResult.ContinuationToken;
        } while (token != null);
    }

    Si l'appelant est une boucle dans le résultat de GetAll et de trouver ce qu'ils cherchaient, ils pourraient tout break la boucle, et le GetAll méthode d'arrêter la récupération de prochains articles. Ce serait peut-être plus efficace, même si cela ne ferait pas beaucoup de différence si vous avez vraiment eu de récupérer tous les éléments.

    Si à l'aide de C# 8.0, vous pouvez rendement à l'intérieur de méthodes asynchrones:

        public async Task<IEnumerable<T>> GetAll<T>(string tableName) where T : class
    {
        var table = this.GetCloudTable(tableName);
        TableContinuationToken token = null;
        do
        {
            var q = new TableQuery<T>();
            var queryResult = await table.ExecuteQuerySegmentedAsync(q, token);
            foreach (var item in queryResult.Results)
            {
                yield return item;
            }
            token = queryResult.ContinuationToken;
        } while (token != null);
    }
    InformationsquelleAutor Alisson