MockAdlsClient Classe

Définition

Espace de noms:

Microsoft.Azure.DataLake.Store.MockAdlsFileSystem

Assembly:

Microsoft.Azure.DataLake.Store.dll

Paquet:

Microsoft.Azure.DataLake.Store v1.1.24

Client Adls fictif. Toutes les opérations sont effectuées en mémoire. Il ne s’agit pas d’une implémentation exacte d’adlsclient réel. Les implémentations sont du meilleur effort uniquement.

public sealed class MockAdlsClient : Microsoft.Azure.DataLake.Store.AdlsClient

type MockAdlsClient = class
    inherit AdlsClient

Public NotInheritable Class MockAdlsClient
Inherits AdlsClient

Héritage

Object

AdlsClient

MockAdlsClient

Propriétés

AccountFQDN	Nom du compte Azure Data Lake Store, y compris le nom de domaine complet (Hérité de AdlsClient)
ClientId	ID d’objet client (Hérité de AdlsClient)

Méthodes

AddUserAgentSuffix(String)	Ajoute le suffixe de l’agent utilisateur (Hérité de AdlsClient)
BulkDownload(String, String, Int32, IfExists, Boolean, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)	Téléchargez le répertoire ou le fichier du serveur distant vers le fichier local. Transfère le contenu sous le répertoire source sous le répertoire de destination. Transfère le fichier source et l’enregistre en tant que chemin d’accès de destination. Cette méthode ne lève aucune exception en cas d’échec de transfert d’une entrée. Reportez-vous à la valeur TransferStatus de retour pour obtenir le status/exception du transfert de chaque entrée. Par défaut, journalise la progression du transfert dans le chemin d’accès temporaire du système, afin que l’utilisateur puisse récupérer en utilisant resume si le chargement s’est bloqué. Cette journalisation de progression peut être désactivée à l’aide de disableTransferLogging. Il est vivement recommandé de définir ServicePointManager.DefaultConnectionLimit sur le nombre de threads que l’application doit utiliser par le sdk avant de créer une instance d’AdlsClient. Par défaut, ServicePointManager.DefaultConnectionLimit a la valeur 2. (Hérité de AdlsClient)
BulkDownload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)	Lit les données du flux de mémoire et les enregistre dans un fichier local
BulkUpload(String, String, Int32, IfExists, Boolean, IProgress<TransferStatus>, Boolean, Boolean, Boolean, CancellationToken)	Chargez le répertoire ou le fichier du local vers le fichier distant. Transfère le contenu sous le répertoire source sous le répertoire de destination. Transfère le fichier source et l’enregistre en tant que chemin d’accès de destination. Cette méthode ne lève aucune exception en cas d’échec de transfert d’une entrée. Reportez-vous à la valeur TransferStatus de retour pour obtenir le status/exception du transfert de chaque entrée. Par défaut, journalise la progression du transfert dans le chemin d’accès temporaire du système, afin que l’utilisateur puisse récupérer en utilisant resume si le chargement s’est bloqué. Cette journalisation de progression peut être désactivée à l’aide de disableTransferLogging. Il est vivement recommandé de définir ServicePointManager.DefaultConnectionLimit sur le nombre de threads que l’application doit utiliser par le sdk avant de créer une instance d’AdlsClient. Par défaut, ServicePointManager.DefaultConnectionLimit a la valeur 2. Par défaut, les fichiers sont chargés aux nouvelles limites de ligne. Toutefois, si les fichiers n’ont pas de nouvelle ligne dans des blocs de 4 Mo, le transfert échoue. Dans ce cas, il est nécessaire de passer true à isBinary pour éviter les chargements aux limites de nouvelle ligne. (Hérité de AdlsClient)
BulkUpload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, Boolean, CancellationToken)	Charge le fichier en bloc uniquement. Lit un fichier local et gère le flux de mémoire de l’entrée
ChangeAcl(String, List<AclEntry>, RequestedAclType, Int32)	Actuellement, les entités récursives doivent être créées séparément pour les tests fictifs
ChangeAcl(String, List<AclEntry>, RequestedAclType, Int32, IProgress<AclProcessorStats>, CancellationToken)	Actuellement, les entités récursives doivent être créées séparément pour les tests fictifs
CheckAccess(String, String, CancellationToken)	Vérifie si l’utilisateur/groupe a spécifié l’accès au chemin donné (Hérité de AdlsClient)
CheckAccessAsync(String, String, CancellationToken)	Vérifie de façon asynchrone si l’utilisateur/groupe a spécifié l’accès au chemin donné (Hérité de AdlsClient)
CheckExists(String)	Vérifie si le fichier ou le répertoire existe (Hérité de AdlsClient)
ConcatenateFiles(String, List<String>, Boolean, CancellationToken)	Concats le flux de mémoire des entrées sources et les fusionne dans un nouveau flux de mémoire
ConcatenateFilesAsync(String, List<String>, Boolean, CancellationToken)	Concats le flux de mémoire des entrées sources et les fusionne dans un nouveau flux de mémoire
ConcurrentAppend(String, Boolean, Byte[], Int32, Int32)	API synchrone pour effectuer l’ajout simultané sur le serveur. Le décalage auquel l’ajout se produira est déterminé par le serveur. Il est vivement recommandé d’appeler cette API avec une taille de données inférieure à 4 Mo. Le back-end génère des ajouts atomiques de 4 Mo. (Hérité de AdlsClient)
ConcurrentAppendAsync(String, Boolean, Byte[], Int32, Int32, CancellationToken)	API asynchrone pour effectuer l’ajout simultané sur le serveur. Le décalage auquel l’ajout se produira est déterminé par le serveur. Opération asynchrone. Il est vivement recommandé d’appeler cette API avec une taille de données inférieure à 4 Mo. Le back-end génère des ajouts atomiques de 4 Mo. (Hérité de AdlsClient)
CreateDelegatingHandler(HttpClientHandler, DelegatingHandler[])	Basé sur l’implémentation de Microsoft.Rest.ServiceCLient. USed pour le gestionnaire de délégation de l’infrastructure factice (Hérité de AdlsClient)
CreateDirectory(String, String, CancellationToken)	Crée un répertoire : crée une entrée pour le répertoire dans le dictionnaire interne
CreateDirectoryAsync(String, String, CancellationToken)	Crée un répertoire : crée une entrée pour le répertoire dans le dictionnaire interne
CreateFile(String, IfExists, String, Boolean)	Crée une entrée dans le dictionnaire interne pour le nouveau fichier. L’entrée encapsule AclStatus, DirectoryEntry et un flux de mémoire
CreateFileAsync(String, IfExists, String, Boolean, CancellationToken)	Crée une entrée dans le dictionnaire interne pour le nouveau fichier. L’entrée encapsule AclStatus, DirectoryEntry et un flux de mémoire
Delete(String, CancellationToken)	Supprimer une entrée du dictionnaire interne
DeleteAsync(String, CancellationToken)	Supprimer une entrée du dictionnaire interne
DeleteRecursive(String, CancellationToken)	Supprime toutes les entrées d’un répertoire ou supprime un fichier
DeleteRecursiveAsync(String, CancellationToken)	Supprime toutes les entrées d’un répertoire ou supprime un fichier
EnumerateDeletedItems(String, String, Int32, IProgress<EnumerateDeletedItemsProgress>, CancellationToken)	Recherchez dans la corbeille sous un compte avec un indicateur et un point de départ. Il s’agit d’une opération de longue durée, et l’utilisateur est mis à jour régulièrement avec la progression.
EnumerateDeletedItemsAsync(String, String, Int32, IProgress<EnumerateDeletedItemsProgress>, CancellationToken)	Obtient de manière asynchrone les entrées de la corbeille
EnumerateDirectory(String, UserGroupRepresentation, CancellationToken)	Retourne une liste d’entrées contenues dans le répertoire donné
GetAclStatus(String, UserGroupRepresentation, CancellationToken)	Obtient la liste d’entrée ACL, l’ID de propriétaire, l’ID de groupe, l’autorisation octal et le bit collant (uniquement pour un répertoire) du fichier/répertoire
GetAclStatusAsync(String, UserGroupRepresentation, CancellationToken)	Obtient la liste d’entrée ACL, l’ID de propriétaire, l’ID de groupe, l’autorisation octal et le bit collant (uniquement pour un répertoire) du fichier/répertoire
GetAppendStream(String, CancellationToken)	Retourne le flux de mémoire à ajouter au fichier encapsulé dans le flux de sortie adls fictif.
GetAppendStreamAsync(String, CancellationToken)	Retourne le flux de mémoire à ajouter au fichier encapsulé dans le flux de sortie adls fictif.
GetContentSummary(String, Int32, CancellationToken)	Actuellement, les entités récursives doivent être créées séparément pour les tests fictifs
GetDirectoryEntry(String, UserGroupRepresentation, CancellationToken)	Obtenir des informations sur le répertoire ou le fichier
GetDirectoryEntryAsync(String, UserGroupRepresentation, CancellationToken)	Obtenir des informations sur le répertoire ou le fichier
GetExceptionFromResponse(OperationResponse, String)	Retourne une exception ADLS en fonction de la réponse du serveur (Hérité de AdlsClient)
GetFileProperties(String, Boolean, String, Boolean, Boolean, Int32, Boolean, Boolean, Int64, CancellationToken)	Obtient fileproperties, conmsistentacl est toujours vrai, car il s’agit d’une simulation
GetHttpClientForCert()	Cette méthode doit être remplacée par l’héritage de la classe pour fournir une solution idéale de réutilisation de httclients. L’héritage de la classe doit supprimer le httpclient précédent, puis obtenir un nouveau httpclient (Hérité de AdlsClient)
GetMockClient()	Méthode de fabrique qui retourne une instance de client adls mock
GetMockClient(String)	Méthode de fabrique qui retourne une instance de client adls mock
GetReadStream(String, CancellationToken)	Retourne un flux de mémoire pour la lecture des données du fichier
GetReadStream(String, Int32, CancellationToken)	API synchrone qui retourne le flux pour lire les données à partir d’un fichier dans ADLS (Hérité de AdlsClient)
GetReadStreamAsync(String, CancellationToken)	Retourne un flux de mémoire pour la lecture des données du fichier
GetReadStreamAsync(String, Int32, CancellationToken)	API asynchrone qui retourne le flux pour lire les données du fichier dans ADLS (Hérité de AdlsClient)
ModifyAclEntries(String, List<AclEntry>, CancellationToken)	Ajoute des entrées acl pour un chemin d’accès donné
ModifyAclEntriesAsync(String, List<AclEntry>, CancellationToken)	Ajoute des entrées acl pour un chemin d’accès donné
RemoveAclEntries(String, List<AclEntry>, CancellationToken)	Supprime les entrées Acl spécifiées pour un fichier ou un répertoire de l’AclStatus interne conservé en mémoire.
RemoveAclEntriesAsync(String, List<AclEntry>, CancellationToken)	Supprime les entrées Acl spécifiées pour un fichier ou un répertoire de l’AclStatus interne conservé en mémoire.
RemoveAllAcls(String, CancellationToken)	Supprime toutes les entrées Acl d’un fichier ou d’un répertoire de l’AclStatus interne conservé en mémoire.
RemoveAllAclsAsync(String, CancellationToken)	Supprime toutes les entrées Acl d’un fichier ou d’un répertoire de l’AclStatus interne conservé en mémoire.
RemoveDefaultAcls(String, CancellationToken)	Supprime toutes les entrées Acl d’AclScope par défaut pour un fichier ou un répertoire de l’AclStatus interne conservé en mémoire.
RemoveDefaultAclsAsync(String, CancellationToken)	Supprime toutes les entrées Acl d’AclScope par défaut pour un fichier ou un répertoire de l’AclStatus interne conservé en mémoire.
Rename(String, String, Boolean, CancellationToken)	Supprime l’entrée source et ajoute une nouvelle entrée dans le dictionnaire interne avec les mêmes métadonnées que l’entrée source
RenameAsync(String, String, Boolean, CancellationToken)	Supprime l’entrée source et ajoute une nouvelle entrée dans le dictionnaire interne avec les mêmes métadonnées que l’entrée source
RestoreDeletedItems(String, String, String, String, CancellationToken)	Restaure de façon synchrone l’entrée de la corbeille
RestoreDeletedItemsAsync(String, String, String, String, CancellationToken)	Restaure de manière asynchrone l’entrée de la corbeille
SetAcl(String, List<AclEntry>, CancellationToken)	Définit de nouvelles entrées acl pour le chemin d’accès donné.
SetAclAsync(String, List<AclEntry>, CancellationToken)	Définit de nouvelles entrées acl pour le chemin d’accès donné.
SetConditionalCreateWithOverwrite(Boolean)	Définit s’il faut effectuer une création conditionnelle avec remplacement. Aide à résoudre les problèmes atomiques liés aux nouvelles tentatives (Hérité de AdlsClient)
SetExpiryTime(String, ExpiryOption, Int64, CancellationToken)	Définit l’heure d’expiration du fichier.
SetExpiryTimeAsync(String, ExpiryOption, Int64, CancellationToken)	Définit l’heure d’expiration du fichier.
SetOwner(String, String, String, CancellationToken)	Définit le propriétaire et le groupe du chemin d’accès
SetOwnerAsync(String, String, String, CancellationToken)	Définit le propriétaire et le groupe du chemin d’accès
SetPermission(String, String, CancellationToken)	Définit la chaîne d’autorisation pour le chemin d’accès donné
SetPermissionAsync(String, String, CancellationToken)	Définit la chaîne d’autorisation pour le chemin d’accès donné
SetPerRequestTimeout(TimeSpan)	Définit le délai d’expiration par requête. Nous vous recommandons vivement de le définir après la création du client. Il n’est pas recommandé de la définir pendant que les demandes sont en cours à partir d’un thread différent. (Hérité de AdlsClient)
SetToken(String)	Définit le jeton d’authentification. (Hérité de AdlsClient)