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

CosmosDatabase.GetContainerQueryStreamIterator 方法

参考

定义

命名空间:: Azure.Cosmos

程序集:: Azure.Cosmos.dll

包:: Azure.Cosmos v4.0.0-preview3

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

重载

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions, CancellationToken)	此方法使用 SQL 语句为数据库下的容器创建查询。它返回 FeedIterator。有关使用参数化值准备 SQL 语句的详细信息，请参阅 QueryDefinition 重载。
GetContainerQueryStreamIterator(String, String, QueryRequestOptions, CancellationToken)	此方法使用 SQL 语句为数据库下的容器创建查询。它返回 FeedIterator。有关使用参数化值准备 SQL 语句的详细信息，请参阅 QueryDefinition 重载。

GetContainerQueryStreamIterator(QueryDefinition, String, QueryRequestOptions, CancellationToken)

此方法使用 SQL 语句为数据库下的容器创建查询。它返回 FeedIterator。有关使用参数化值准备 SQL 语句的详细信息，请参阅 QueryDefinition 重载。

public abstract System.Collections.Generic.IAsyncEnumerable<Azure.Response> GetContainerQueryStreamIterator (Azure.Cosmos.QueryDefinition queryDefinition, string continuationToken = default, Azure.Cosmos.QueryRequestOptions requestOptions = default, System.Threading.CancellationToken cancellationToken = default);

abstract member GetContainerQueryStreamIterator : Azure.Cosmos.QueryDefinition * string * Azure.Cosmos.QueryRequestOptions * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Azure.Response>

Public MustOverride Function GetContainerQueryStreamIterator (queryDefinition As QueryDefinition, Optional continuationToken As String = Nothing, Optional requestOptions As QueryRequestOptions = Nothing, Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of Response)

参数

queryDefinition: QueryDefinition

cosmos SQL 查询定义。

continuationToken: String

Azure Cosmos DB 服务中的延续令牌。

requestOptions: QueryRequestOptions

(可选) 容器请求的选项 QueryRequestOptions

cancellationToken: CancellationToken

(表示请求取消的可选) CancellationToken 。

IAsyncEnumerable<Response>

用于遍历容器的迭代器

示例

这将为使用 queryDefinition 作为输入的容器创建流馈送迭代器。

string queryText = "SELECT * FROM c where c.id like '%testId%'";
QueryDefinition queryDefinition = new QueryDefinition(queryText);
await foreach(Response response in this.cosmosDatabase.GetContainerQueryStreamIterator(queryDefinition))
{
    using (StreamReader sr = new StreamReader(response.Content))
    using (JsonTextReader jtr = new JsonTextReader(sr))
    {
        JObject result = JObject.Load(jtr);
    }
}

适用于

GetContainerQueryStreamIterator(String, String, QueryRequestOptions, CancellationToken)