4

我正在调用我的 DocumentDB 数据库来查询一个人。如果此人不在数据库中,我会尝试将该人插入我的集合中。

当我检查集合时,我看到正在创建新人,但我的代码似乎挂在我第二次调用以将人插入集合的位置。知道为什么我的代码挂起吗?我没有包括所有节省空间的代码,例如 GetDatabaseAsync()、GetCollectionAsync() 等都在工作。

using (client = new DocumentClient(new Uri(endPointUrl), authorizationKey))
{
   //Get the database
   var database = await GetDatabaseAsync();

   //Get the Document Collection
   var collection = await GetCollectionAsync(database.SelfLink, "People");

   string sqlQuery = "SELECT * FROM People f WHERE f.id = \"" + user.PersonId + "\"";

   dynamic doc = client.CreateDocumentQuery(collection.SelfLink, sqlQuery).AsEnumerable().FirstOrDefault();

   if (doc == null)
   {
      // User is not in the database. Add user to the database
      try
      {
         **// This is where the code is hanging. It creates the user in my collection though!**
         await client.CreateDocumentAsync(collection.DocumentsLink, user);
      }
      catch
      {
         // Handle error
      }
   }
   else
   {
      // User is already in the system.
      user = doc;
   }
}

代码是否有可能挂起,因为我试图在同一个 USING 语句中查询和插入文档。

对我来说创建一个新的客户端实例并创建一个单独的块来处理文档 INSERT 是否更好?

4

2 回答 2

6

如果对异步方法的调用挂起,通常是因为它是通过使用 .Wait() 或 .Result 而不是 await 调用来同步调用的。您还没有显示您的呼叫代码,因此请在此处包含它。

选项 1:不要同步调用你的异步方法。这是正确的做法。

选项 2:如果您同步调用此方法,则应在对 DocDB 的异步调用中使用 .ConfigureAwait(false)。尝试这个:

var database = await GetDatabaseAsync()**.ConfigureAwait(false)**;
...
var collection = await GetCollectionAsync(database.SelfLink, "People")**.ConfigureAwait(false)**;
...
await client.CreateDocumentAsync(collection.DocumentsLink, user)**.ConfigureAwait(false)**;

有关ConfigureAwait的更多详细信息

于 2015-03-15T20:36:31.073 回答
4

DocumentDB 的客户端 SDK 中似乎存在错误。尝试使用client.CreateDocumentAsync(collection.DocumentsLink, user).Wait()而不是await client.CreateDocumentAsync(collection.DocumentsLink, user)


更新:这很可能已在最新的 SDK 中修复,因为我无法再重现它。

于 2014-12-04T06:39:53.360 回答