通过

.ingest-from-storage-queued 命令（预览版）

适用于：✅Azure 数据资源管理器

该 .ingest-from-storage-queued 命令与 .list blobs 命令一起使用，以将 blob 排队以引入表中。 此命令支持批量引入整个存储容器、容器中的特定文件夹或与给定前缀和后缀匹配的所有 Blob。

注释

此引入方法适用于探索和原型制作。 请勿在生产或大容量方案中使用它。 有关引入选项的详细信息，请参阅 数据引入概述。

注释

排队引入命令在数据引入 URI 终结点 https://ingest-<YourClusterName><Region>.kusto.chinacloudapi.cn 上运行。

权限

必须至少具有 表引入器 权限才能运行此命令。

语法

.ingest-from-storage-queued into table [database（DatabaseName）.]TableName[EnableTracking=EnableTracking] [SkipBatching=SkipBatching] [CompressionFactor=CompressionFactor] [with [with （IngestionPropertyName = IngestionPropertyValue [， ...]]] <|IngestionSource

详细了解语法约定。

参数

名称 类型 必选 DESCRIPTION
数据库名称 string 要将数据引入到的数据库的名称。 如果未提供数据库名称，则使用请求的上下文数据库。
TableName string ✔️ 要将数据引入到其中的表的名称。
启用跟踪 boolean 确定是否跟踪 Blob 引入。 有关详细信息，请参阅 .show queued ingestion operations command. 默认值为 false。
SkipBatching boolean 如果设置为 true，将单独引入 blob，而不是与其他 Blob 一起批处理。 默认值是 false。
压缩因子 real 原始大小与 Blob 压缩大小之间的压缩因子（比率）。 压缩因子用于估算数据的原始大小，以便在以压缩格式提供 Blob 时进行批处理。
IngestionPropertyName，IngestionPropertyValue string 可选引入属性。 有关引入属性的详细信息，请参阅 数据引入属性。
引入Source 表 ✔️ 引入源。 源是使用 .list blob 命令返回的 blob 列表。

注释

.list blobs 命令可与 .ingest-from-storage-queued 命令一起使用，以返回要引入的 blob。 有关命令及其参数的完整列表的详细信息，请参阅 .list blobs 命令。

退货

该命令的结果是包含一行和一列的表。

名称 类型 DESCRIPTION
IngestionOperationId string 用于跟踪 blob 集的唯一 ID，无论是否启用跟踪。
ClientRequestId string 命令的客户端请求 ID。
OperationInfo string 显示要运行的命令以检索作的当前状态。
CancelationInfo string 显示要运行的命令以取消作。

注释

此命令不会修改目标表的架构。 如有必要，数据将转换为适合引入过程中表的架构。 忽略额外列，缺少的列被视为 null 值。

示例：

本节中的示例演示如何使用语法帮助你入门。

引入文件夹中的所有 Blob

以下示例使用群集的系统托管标识对文件夹中的所有 Blob 进行排队以引入。

.ingest-from-storage-queued into table database('LogDb').RawLogs
EnableTracking=true
with (
  format='csv',
  ingestionMappingReference='LogMapping',
  ignoreFirstRecord=false  
)
<|
  .list blobs (
      "https://mystorageaccount.blob.core.chinacloudapi.cn/datasets/myfolder;managed_identity=system"
  )

相关内容