通过Sitecore SDK查询资产仅返回10000条，如何获取更多数据？

通过Sitecore SDK执行查询时，仅能检索到10000个资产，遍历结果迭代器后循环直接退出，无法获取超过10000条的数据。当前使用的查询和初始化代码如下：

查询构建代码 #

var query = Query.CreateQuery(entities => (from e in entities
                                          where e.DefinitionName == "M.Asset"
                                            && e.Parent("ContentRepositoryToAsset") == 734
                                            && e.Parent("AssetTypeToAsset").In(6303943, 6303948, 6303946, 6305026, 6303942, 6305024, 12822834, 6303949, 6305025)
                                            && e.Property("DigitalAssetClass") == "IKEAO.DigitalAssetCall.Image"
                                            && e.Parent("FinalLifeCycleStatusToAsset") == 544
                                            && e.Property("ReleaseDate") < DateTime.Now
                                          select e));

MClient与迭代器初始化代码 #

IWebMClient MClient = MClientFactory.CreateMClient(Constants.endpoint,Constants.oauth);

var result = MClient.Querying.CreateEntityIterator(query);

Sitecore SDK默认限制单次查询返回10000条记录，要获取全部数据，需手动实现分页逻辑，以下是具体方案：

• 分页查询（Skip/Take）核心实现
  在原查询基础上，通过Skip()和Take()分批请求数据，每次获取固定数量的记录，直到返回空批次为止。为避免数据重复或遗漏，必须添加稳定排序规则（比如按资产ID排序）：

  int batchSize = 1000; // 可根据API性能调整批次大小
  int skipCount = 0;
  bool hasMoreData = true;
  
  while (hasMoreData)
  {
      var paginatedQuery = Query.CreateQuery(entities => (from e in entities
                                                          where e.DefinitionName == "M.Asset"
                                                            && e.Parent("ContentRepositoryToAsset") == 734
                                                            && e.Parent("AssetTypeToAsset").In(6303943, 6303948, 6303946, 6305026, 6303942, 6305024, 12822834, 6303949, 6305025)
                                                            && e.Property("DigitalAssetClass") == "IKEAO.DigitalAssetCall.Image"
                                                            && e.Parent("FinalLifeCycleStatusToAsset") == 544
                                                            && e.Property("ReleaseDate") < DateTime.Now
                                                          select e)
                                                          .OrderBy(e => e.Id) // 稳定排序，避免数据重复/遗漏
                                                          .Skip(skipCount)
                                                          .Take(batchSize));
  
      var iterator = MClient.Querying.CreateEntityIterator(paginatedQuery);
      var batchAssets = iterator.ToList();
  
      if (batchAssets.Count == 0)
      {
          hasMoreData = false;
          continue;
      }
  
      // 替换为你的数据处理逻辑
      ProcessAssetBatch(batchAssets);
  
      skipCount += batchSize;
  }
  

• 检查SDK配置上限（可选）
  部分Sitecore SDK版本允许通过配置调整单次查询的最大返回条数，可检查MClient初始化时的配置参数，查看是否有MaxResults或类似设置。但即使调高该值，通常仍有平台级上限，分页仍是最可靠的方案。

• 异步分页优化（可选）
  处理超大量数据时，建议使用异步方法提升性能，避免阻塞主线程：

  async Task FetchAllAssetsAsync()
  {
      int batchSize = 1000;
      int skipCount = 0;
      bool hasMore = true;
  
      while (hasMore)
      {
          var paginatedQuery = Query.CreateQuery(entities => (from e in entities
                                                              where e.DefinitionName == "M.Asset"
                                                                && e.Parent("ContentRepositoryToAsset") == 734
                                                                && e.Parent("AssetTypeToAsset").In(6303943, 6303948, 6303946, 6305026, 6303942, 6305024, 12822834, 6303949, 6305025)
                                                                && e.Property("DigitalAssetClass") == "IKEAO.DigitalAssetCall.Image"
                                                                && e.Parent("FinalLifeCycleStatusToAsset") == 544
                                                                && e.Property("ReleaseDate") < DateTime.Now
                                                              select e)
                                                              .OrderBy(e => e.Id)
                                                              .Skip(skipCount)
                                                              .Take(batchSize));
  
          var iterator = MClient.Querying.CreateEntityIterator(paginatedQuery);
          var batch = await iterator.ToListAsync();
  
          if (batch.Count == 0)
          {
              hasMore = false;
              continue;
          }
  
          // 异步处理批次数据
          await ProcessAssetBatchAsync(batch);
          skipCount += batchSize;
      }
  }
  

内容的提问来源于stack exchange，提问作者Dhanush S