你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

MockAdlsClient 类

定义

模拟 Adls 客户端。 所有操作都在内存中完成。 这不是实际 adlsclient 的准确实现。 实施只是尽最大努力。

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

属性

AccountFQDN

Azure Data Lake Store 帐户名称,包括完整域名

(继承自 AdlsClient)
ClientId

客户端对象 ID

(继承自 AdlsClient)

方法

AddUserAgentSuffix(String)

添加用户代理后缀

(继承自 AdlsClient)
BulkDownload(String, String, Int32, IfExists, Boolean, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)

将目录或文件从远程服务器下载到本地。 传输目标目录下的源目录下的内容。 传输源文件并将其另存为目标路径。 此方法不会对任何条目的传输失败引发任何异常。 引用返回值 TransferStatus 以获取每个条目的转移状态/异常。 默认情况下,传输进度记录在系统的临时路径中,以便用户可以在上传崩溃时使用 resume 进行恢复。 可以使用 禁用 disableTransferLogging此进度日志记录。 强烈建议在创建 AdlsClient 的任何实例之前,将 ServicePointManager.DefaultConnectionLimit 设置为应用程序希望 SDK 使用的线程数。 默认情况下,ServicePointManager.DefaultConnectionLimit 设置为 2。

(继承自 AdlsClient)
BulkDownload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, CancellationToken)

从内存流读取数据并将其保存到本地文件

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

将目录或文件从本地上传到远程。 传输目标目录下的源目录下的内容。 传输源文件并将其另存为目标路径。 此方法不会对任何条目的传输失败引发任何异常。 引用返回值 TransferStatus 以获取每个条目的转移状态/异常。 默认情况下,传输进度记录在系统的临时路径中,以便用户可以在上传崩溃时使用 resume 进行恢复。 可以使用 禁用 disableTransferLogging此进度日志记录。 强烈建议在创建 AdlsClient 的任何实例之前,将 ServicePointManager.DefaultConnectionLimit 设置为应用程序希望 SDK 使用的线程数。 默认情况下,ServicePointManager.DefaultConnectionLimit 设置为 2。 默认情况下,文件在新的行边界上传。 但是,如果文件在 4MB 区块内没有换行符,传输将失败。 在这种情况下,需要将 true isBinary 传递给 以避免在换行符边界处上传。

(继承自 AdlsClient)
BulkUpload(String, String, Int32, IfExists, IProgress<TransferStatus>, Boolean, Boolean, Boolean, CancellationToken)

仅批量上传文件。 读取本地文件并维护条目的内存流

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

目前需要单独创建递归实体以用于模拟测试

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

目前需要单独创建递归实体以用于模拟测试

CheckAccess(String, String, CancellationToken)

检查用户/组是否具有给定路径的指定访问权限

(继承自 AdlsClient)
CheckAccessAsync(String, String, CancellationToken)

异步检查用户/组是否具有给定路径的指定访问权限

(继承自 AdlsClient)
CheckExists(String)

检查文件或目录是否存在

(继承自 AdlsClient)
ConcatenateFiles(String, List<String>, Boolean, CancellationToken)

连接源条目的内存流,并将其合并到新的内存流中

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

连接源条目的内存流,并将其合并到新的内存流中

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

同步 API,用于在服务器上执行并发追加。 发生追加的偏移量由服务器确定。 强烈建议使用小于 4MB 的数据大小调用此 API。 后端配置 4MB 原子追加。

(继承自 AdlsClient)
ConcurrentAppendAsync(String, Boolean, Byte[], Int32, Int32, CancellationToken)

异步 API,用于在服务器上执行并发追加。 发生追加的偏移量由服务器确定。 异步操作。 强烈建议使用小于 4MB 的数据大小调用此 API。 后端配置 4MB 原子追加。

(继承自 AdlsClient)
CreateDelegatingHandler(HttpClientHandler, DelegatingHandler[])

基于 Microsoft.Rest.ServiceCLient 实现。 用于模拟框架委派处理程序的 USed

(继承自 AdlsClient)
CreateDirectory(String, String, CancellationToken)

创建目录 - 为内部字典中的目录创建条目

CreateDirectoryAsync(String, String, CancellationToken)

创建目录 - 为内部字典中的目录创建条目

CreateFile(String, IfExists, String, Boolean)

为新文件创建内部字典的条目。 条目封装 AclStatus、DirectoryEntry 和内存流

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

为新文件创建内部字典的条目。 条目封装 AclStatus、DirectoryEntry 和内存流

Delete(String, CancellationToken)

从内部字典中删除条目

DeleteAsync(String, CancellationToken)

从内部字典中删除条目

DeleteRecursive(String, CancellationToken)

删除目录中的所有条目或删除文件

DeleteRecursiveAsync(String, CancellationToken)

删除目录中的所有条目或删除文件

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

使用提示和起点在帐户下搜索回收站。 这是一个长时间运行的操作,用户会定期更新进度。

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

异步获取回收站条目

EnumerateDirectory(String, UserGroupRepresentation, CancellationToken)

返回给定目录下包含的条目的列表

GetAclStatus(String, UserGroupRepresentation, CancellationToken)

仅获取文件/目录的目录) 的 ACL 条目列表、所有者 ID、组 ID、八进制权限和粘滞位 (

GetAclStatusAsync(String, UserGroupRepresentation, CancellationToken)

仅获取文件/目录的目录) 的 ACL 条目列表、所有者 ID、组 ID、八进制权限和粘滞位 (

GetAppendStream(String, CancellationToken)

返回用于追加到 mock adls 输出流中封装的文件的内存流。

GetAppendStreamAsync(String, CancellationToken)

返回用于追加到 mock adls 输出流中封装的文件的内存流。

GetContentSummary(String, Int32, CancellationToken)

目前需要单独创建递归实体以用于模拟测试

GetDirectoryEntry(String, UserGroupRepresentation, CancellationToken)

获取目录或文件信息

GetDirectoryEntryAsync(String, UserGroupRepresentation, CancellationToken)

获取目录或文件信息

GetExceptionFromResponse(OperationResponse, String)

根据服务器的响应返回 ADLS 异常

(继承自 AdlsClient)
GetFileProperties(String, Boolean, String, Boolean, Boolean, Int32, Boolean, Boolean, Int64, CancellationToken)

获取 fileproperties,conmsistentacl 始终为 true,因为这是 mock

GetHttpClientForCert()

此方法需要通过继承类来替代,以提供重用 httclient 的理想解决方案。 继承类必须释放以前的 httpclient,然后获取新的 httpclient

(继承自 AdlsClient)
GetMockClient()

返回 Mock adls 客户端实例的工厂方法

GetMockClient(String)

返回 Mock adls 客户端实例的工厂方法

GetReadStream(String, CancellationToken)

返回用于读取文件数据的内存流

GetReadStream(String, Int32, CancellationToken)

返回流以从 ADLS 中的文件读取数据的同步 API

(继承自 AdlsClient)
GetReadStreamAsync(String, CancellationToken)

返回用于读取文件数据的内存流

GetReadStreamAsync(String, Int32, CancellationToken)

返回流以从 ADLS 中的文件读取数据的异步 API

(继承自 AdlsClient)
ModifyAclEntries(String, List<AclEntry>, CancellationToken)

为给定路径添加 acl 条目

ModifyAclEntriesAsync(String, List<AclEntry>, CancellationToken)

为给定路径添加 acl 条目

RemoveAclEntries(String, List<AclEntry>, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的指定 Acl 条目。

RemoveAclEntriesAsync(String, List<AclEntry>, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的指定 Acl 条目。

RemoveAllAcls(String, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的所有 Acl 条目。

RemoveAllAclsAsync(String, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的所有 Acl 条目。

RemoveDefaultAcls(String, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的 AclScope 默认值的所有 Acl 条目。

RemoveDefaultAclsAsync(String, CancellationToken)

从内存中维护的内部 AclStatus 中删除文件或目录的 AclScope 默认值的所有 Acl 条目。

Rename(String, String, Boolean, CancellationToken)

删除源条目,并在内部字典中添加具有相同源条目元数据的新条目

RenameAsync(String, String, Boolean, CancellationToken)

删除源条目,并在内部字典中添加具有相同源条目元数据的新条目

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

同步还原回收站条目

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

异步还原回收站条目

SetAcl(String, List<AclEntry>, CancellationToken)

为给定路径设置新的 acl 条目。

SetAclAsync(String, List<AclEntry>, CancellationToken)

为给定路径设置新的 acl 条目。

SetConditionalCreateWithOverwrite(Boolean)

设置是否使用覆盖执行条件创建。 帮助解决重试的原子问题

(继承自 AdlsClient)
SetExpiryTime(String, ExpiryOption, Int64, CancellationToken)

设置文件的到期时间。

SetExpiryTimeAsync(String, ExpiryOption, Int64, CancellationToken)

设置文件的到期时间。

SetOwner(String, String, String, CancellationToken)

设置路径的所有者和组

SetOwnerAsync(String, String, String, CancellationToken)

设置路径的所有者和组

SetPermission(String, String, CancellationToken)

设置给定路径的权限字符串

SetPermissionAsync(String, String, CancellationToken)

设置给定路径的权限字符串

SetPerRequestTimeout(TimeSpan)

设置每个请求超时。 强烈建议在创建客户端后设置它。 当请求来自其他线程时,不建议设置它。

(继承自 AdlsClient)
SetToken(String)

设置身份验证令牌。

(继承自 AdlsClient)

适用于