Compartir a través de


MockAdlsClient Clase

Definición

Simulación de cliente de Adls. Todas las operaciones se realizan en memoria. Esto no es una implementación precisa de adlsclient real. Las inmplementaciones son solo el mejor esfuerzo.

public sealed class MockAdlsClient : Microsoft.Azure.DataLake.Store.AdlsClient
type MockAdlsClient = class
    inherit AdlsClient
Public NotInheritable Class MockAdlsClient
Inherits AdlsClient
Herencia
MockAdlsClient

Propiedades

AccountFQDN

Nombre de la cuenta del almacén de Azure Data Lake, incluido el nombre de dominio completo

(Heredado de AdlsClient)
ClientId

Id. de objeto de cliente

(Heredado de AdlsClient)

Métodos

AddUserAgentSuffix(String)

Agrega el sufijo del agente de usuario

(Heredado de AdlsClient)
BulkDownload(String, String, Int32, IfExists, Boolean, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)

Descargue el directorio o el archivo del servidor remoto a local. Transfiere el contenido en el directorio de origen en el directorio de destino. Transfiere el archivo de origen y lo guarda como ruta de acceso de destino. Este método no produce ninguna excepción para el error de transferencia de ninguna entrada. Consulte el valor TransferStatus devuelto para obtener el estado o la excepción de la transferencia de cada entrada. De forma predeterminada, registra el progreso de la transferencia en la ruta de acceso temporal del sistema para que el usuario pueda recuperarse mediante resume si la carga se ha bloqueado. Este registro de progreso se puede deshabilitar mediante disableTransferLogging. Se recomienda encarecidamente establecer ServicePointManager.DefaultConnectionLimit en el número de subprocesos que la aplicación quiere que use el SDK antes de crear cualquier instancia de AdlsClient. De forma predeterminada, ServicePointManager.DefaultConnectionLimit está establecido en 2.

(Heredado de AdlsClient)
BulkDownload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)

Lee los datos de la secuencia de memoria y los guarda en el archivo local.

BulkUpload(String, String, Int32, IfExists, Boolean, IProgress<TransferStatus>, Boolean, Boolean, Boolean, CancellationToken)

Cargue el directorio o el archivo de local a remoto. Transfiere el contenido en el directorio de origen en el directorio de destino. Transfiere el archivo de origen y lo guarda como ruta de acceso de destino. Este método no produce ninguna excepción para el error de transferencia de ninguna entrada. Consulte el valor TransferStatus devuelto para obtener el estado o la excepción de la transferencia de cada entrada. De forma predeterminada, registra el progreso de la transferencia en la ruta de acceso temporal del sistema para que el usuario pueda recuperarse mediante resume si la carga se ha bloqueado. Este registro de progreso se puede deshabilitar mediante disableTransferLogging. Se recomienda encarecidamente establecer ServicePointManager.DefaultConnectionLimit en el número de subprocesos que la aplicación quiere que use el SDK antes de crear cualquier instancia de AdlsClient. De forma predeterminada, ServicePointManager.DefaultConnectionLimit está establecido en 2. De forma predeterminada, los archivos se cargan en nuevos límites de línea. Sin embargo, si los archivos no tienen nueva línea dentro de fragmentos de 4 MB, se producirá un error en la transferencia. En ese caso, es necesario pasar true para isBinary evitar cargas en límites de nueva línea.

(Heredado de AdlsClient)
BulkUpload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, Boolean, CancellationToken)

Carga masiva solo el archivo. Lee un archivo local y mantiene la secuencia de memoria de la entrada.

ChangeAcl(String, List<AclEntry>, RequestedAclType, Int32)

Actualmente, las entidades recursivas deben crearse por separado para pruebas simuladas.

ChangeAcl(String, List<AclEntry>, RequestedAclType, Int32, IProgress<AclProcessorStats>, CancellationToken)

Actualmente, las entidades recursivas deben crearse por separado para pruebas simuladas.

CheckAccess(String, String, CancellationToken)

Comprueba si el usuario o grupo ha especificado el acceso de la ruta de acceso especificada.

(Heredado de AdlsClient)
CheckAccessAsync(String, String, CancellationToken)

Comprueba de forma asincrónica si el usuario o grupo ha especificado el acceso de la ruta de acceso especificada.

(Heredado de AdlsClient)
CheckExists(String)

Comprueba si existe un archivo o directorio.

(Heredado de AdlsClient)
ConcatenateFiles(String, List<String>, Boolean, CancellationToken)

Concats el flujo de memoria de las entradas de origen y los combina en una nueva secuencia de memoria.

ConcatenateFilesAsync(String, List<String>, Boolean, CancellationToken)

Concats el flujo de memoria de las entradas de origen y los combina en una nueva secuencia de memoria.

ConcurrentAppend(String, Boolean, Byte[], Int32, Int32)

API sincrónica para realizar la anexión simultánea en el servidor. El desplazamiento en el que se producirá la anexión viene determinado por el servidor. Se recomienda llamar a esta API con un tamaño de datos inferior a 4 MB. Gurantees de back-end 4 MB anexiones atómicas.

(Heredado de AdlsClient)
ConcurrentAppendAsync(String, Boolean, Byte[], Int32, Int32, CancellationToken)

API asincrónica para realizar la anexión simultánea en el servidor. El desplazamiento en el que se producirá la anexión viene determinado por el servidor. Operación asincrónica. Se recomienda llamar a esta API con un tamaño de datos inferior a 4 MB. Gurantees de back-end 4 MB anexiones atómicas.

(Heredado de AdlsClient)
CreateDelegatingHandler(HttpClientHandler, DelegatingHandler[])

Basado en la implementación de Microsoft.Rest.ServiceCLient. USed para el controlador de delegación del marco ficticio

(Heredado de AdlsClient)
CreateDirectory(String, String, CancellationToken)

Crea un directorio: crea una entrada para el directorio en el diccionario interno.

CreateDirectoryAsync(String, String, CancellationToken)

Crea un directorio: crea una entrada para el directorio en el diccionario interno.

CreateFile(String, IfExists, String, Boolean)

Crea una entrada en el diccionario interno para el nuevo archivo. La entrada encapsula AclStatus, DirectoryEntry y una secuencia de memoria.

CreateFileAsync(String, IfExists, String, Boolean, CancellationToken)

Crea una entrada en el diccionario interno para el nuevo archivo. La entrada encapsula AclStatus, DirectoryEntry y una secuencia de memoria.

Delete(String, CancellationToken)

Eliminar una entrada del diccionario interno

DeleteAsync(String, CancellationToken)

Eliminar una entrada del diccionario interno

DeleteRecursive(String, CancellationToken)

Elimina todas las entradas de un directorio o elimina un archivo.

DeleteRecursiveAsync(String, CancellationToken)

Elimina todas las entradas de un directorio o elimina un archivo.

EnumerateDeletedItems(String, String, Int32, IProgress<EnumerateDeletedItemsProgress>, CancellationToken)

Busque la papelera en una cuenta con sugerencia y un punto de partida. Se trata de una operación de larga duración y el usuario se actualiza periódicamente con el progreso.

EnumerateDeletedItemsAsync(String, String, Int32, IProgress<EnumerateDeletedItemsProgress>, CancellationToken)

Obtiene asincrónicamente las entradas de la papelera

EnumerateDirectory(String, UserGroupRepresentation, CancellationToken)

Devuelve una lista de entradas contenidas en el directorio especificado.

GetAclStatus(String, UserGroupRepresentation, CancellationToken)

Obtiene la lista de entradas de ACL, el identificador de propietario, el identificador de grupo, el permiso octal y el bit pegajoso (solo para un directorio) del archivo o directorio.

GetAclStatusAsync(String, UserGroupRepresentation, CancellationToken)

Obtiene la lista de entradas de ACL, el identificador de propietario, el identificador de grupo, el permiso octal y el bit pegajoso (solo para un directorio) del archivo o directorio.

GetAppendStream(String, CancellationToken)

Devuelve el flujo de memoria para anexar al archivo encapsulado en el flujo de salida de adls ficticio.

GetAppendStreamAsync(String, CancellationToken)

Devuelve el flujo de memoria para anexar al archivo encapsulado en el flujo de salida de adls ficticio.

GetContentSummary(String, Int32, CancellationToken)

Actualmente, las entidades recursivas deben crearse por separado para pruebas simuladas.

GetDirectoryEntry(String, UserGroupRepresentation, CancellationToken)

Obtener información de directorio o archivo

GetDirectoryEntryAsync(String, UserGroupRepresentation, CancellationToken)

Obtener información de directorio o archivo

GetExceptionFromResponse(OperationResponse, String)

Devuelve una excepción de ADLS basada en la respuesta del servidor.

(Heredado de AdlsClient)
GetFileProperties(String, Boolean, String, Boolean, Boolean, Int32, Boolean, Boolean, Int64, CancellationToken)

Obtiene fileproperties, conmsistentacl siempre es true, ya que esto es ficticio.

GetHttpClientForCert()

Este método debe invalidarse heredando la clase para proporcionar una solución ideal de reutilización de httclientes. La clase heredada tiene que eliminar el httpclient anterior y, a continuación, obtener un nuevo httpclient

(Heredado de AdlsClient)
GetMockClient()

Método factory que devuelve una instancia de cliente de adls simulado

GetMockClient(String)

Método factory que devuelve una instancia de cliente de adls simulado

GetReadStream(String, CancellationToken)

Devuelve un flujo de memoria para leer datos del archivo.

GetReadStream(String, Int32, CancellationToken)

API sincrónica que devuelve la secuencia para leer datos del archivo en ADLS

(Heredado de AdlsClient)
GetReadStreamAsync(String, CancellationToken)

Devuelve un flujo de memoria para leer datos del archivo.

GetReadStreamAsync(String, Int32, CancellationToken)

API asincrónica que devuelve la secuencia para leer datos del archivo en ADLS

(Heredado de AdlsClient)
ModifyAclEntries(String, List<AclEntry>, CancellationToken)

Agrega entradas de acl para una ruta de acceso determinada

ModifyAclEntriesAsync(String, List<AclEntry>, CancellationToken)

Agrega entradas de acl para una ruta de acceso determinada

RemoveAclEntries(String, List<AclEntry>, CancellationToken)

Quita las entradas de Acl especificadas para un archivo o directorio del AclStatus interno mantenido en memoria.

RemoveAclEntriesAsync(String, List<AclEntry>, CancellationToken)

Quita las entradas de Acl especificadas para un archivo o directorio del AclStatus interno mantenido en memoria.

RemoveAllAcls(String, CancellationToken)

Quita todas las entradas de Acl de un archivo o directorio del AclStatus interno mantenido en memoria.

RemoveAllAclsAsync(String, CancellationToken)

Quita todas las entradas de Acl de un archivo o directorio del AclStatus interno mantenido en memoria.

RemoveDefaultAcls(String, CancellationToken)

Quita todas las entradas de Acl Del valor predeterminado de AclScope para un archivo o directorio del AclStatus interno mantenido en la memoria.

RemoveDefaultAclsAsync(String, CancellationToken)

Quita todas las entradas de Acl Del valor predeterminado de AclScope para un archivo o directorio del AclStatus interno mantenido en la memoria.

Rename(String, String, Boolean, CancellationToken)

Quita la entrada de origen y agrega una nueva entrada en el diccionario interno con los mismos metadatos de la entrada de origen.

RenameAsync(String, String, Boolean, CancellationToken)

Quita la entrada de origen y agrega una nueva entrada en el diccionario interno con los mismos metadatos de la entrada de origen.

RestoreDeletedItems(String, String, String, String, CancellationToken)

Restaura de forma sincrónica la entrada de papelera

RestoreDeletedItemsAsync(String, String, String, String, CancellationToken)

Restaura asincrónicamente la entrada de papelera

SetAcl(String, List<AclEntry>, CancellationToken)

Establece nuevas entradas de acl para la ruta de acceso especificada.

SetAclAsync(String, List<AclEntry>, CancellationToken)

Establece nuevas entradas de acl para la ruta de acceso especificada.

SetConditionalCreateWithOverwrite(Boolean)

Establece si se va a realizar la creación condicional con sobrescritura. Ayuda a resolver problemas atómicos con reintentos

(Heredado de AdlsClient)
SetExpiryTime(String, ExpiryOption, Int64, CancellationToken)

Establece la hora de expiración del archivo.

SetExpiryTimeAsync(String, ExpiryOption, Int64, CancellationToken)

Establece la hora de expiración del archivo.

SetOwner(String, String, String, CancellationToken)

Establece el propietario y el grupo de la ruta de acceso.

SetOwnerAsync(String, String, String, CancellationToken)

Establece el propietario y el grupo de la ruta de acceso.

SetPermission(String, String, CancellationToken)

Establece la cadena de permiso para la ruta de acceso especificada.

SetPermissionAsync(String, String, CancellationToken)

Establece la cadena de permiso para la ruta de acceso especificada.

SetPerRequestTimeout(TimeSpan)

Establece el tiempo de espera por solicitud. Se recomienda encarecidamente establecerlo después de crear el cliente. No se recomienda establecerlo mientras las solicitudes están en curso desde un subproceso diferente.

(Heredado de AdlsClient)
SetToken(String)

Establece el token de autenticación.

(Heredado de AdlsClient)

Se aplica a