如何在CosmosDB SDK v3.0异步查询中使用LINQ? [英] How can I use LINQ in CosmosDB SDK v3.0 async query?

问题描述

我一直在这里关注官方文档: https://docs.microsoft.com/en-us/azure/cosmos-db/sql-api-get-started#Query

I've been following the official documentation here: https://docs.microsoft.com/en-us/azure/cosmos-db/sql-api-get-started#Query

但是我不知道如何在SQL字符串上正确使用LINQ表达式.我尝试了GetItemLinqQueryable，但是我不知道使用它的正确方法.也不是异步的.

But I can't figure out how to correctly use a LINQ expression instead on an SQL string. I experimented with GetItemLinqQueryable, but I don't know if is the right way to use it. Also is not async.

var db = Client.GetDatabase(databaseId);
var container = db.GetContainer(containerId);

var q = container.GetItemLinqQueryable<Person>();
var result = q.Where(p => p.Name == "Name").ToList();

这是在Cosmos v3中使用LINQ的正确方法，以及如何使其异步吗?

Is this the right way to use LINQ with Cosmos v3, and how to make it async?

推荐答案

您将使用 FeedIterator<T>.ReadNextAsync() .

You would use ToFeedIterator() and FeedIterator<T>.ReadNextAsync().

var db = Client.GetDatabase(databaseId);
var container = db.GetContainer(containerId);

var q = container.GetItemLinqQueryable<Person>();
var iterator = q.Where(p => p.Name == "Name").ToFeedIterator();
var results = await iterator.ReadNextAsync();

这篇关于如何在CosmosDB SDK v3.0异步查询中使用LINQ?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！