在 Web 环境中使用会话令牌管理 CosmosDb 会话一致性级别

Question

我的环境是 ASP.NET Core 2.x 使用 .NET SDK 访问 CosmosDb（又名 DocumentDb）。

我的收藏的默认一致性级别设置为“会话”。对于我的用例，我需要一个经过身份验证的 Web 用户在 Web 请求之间的读/写方面始终拥有一致的数据。

我有一些 CosmosDB 存储库逻辑，通过 ASP.NET Core Singleton 依赖注入可用于我的控制器逻辑：

services.AddSingleton<DocumentDBRepository, DocumentDBRepository>(x =>
                 new DocumentDBRepository(
                     WebUtil.GetMachineConfig("DOCDB_ENDPOINT", Configuration),
                     WebUtil.GetMachineConfig("DOCDB_KEY", Configuration),
                     WebUtil.GetMachineConfig("DOCDB_DB", Configuration),
                     "MyCollection",
                     maxDocDbCons));

DocumentDBRespository 像这样创建一个 cosmos 客户端：

  public DocumentDBRepository(string endpoint, string authkey, string database, string collection, int maxConnections)
        {
            _Collection = collection;
            _DatabaseId = database;
            _Client = new DocumentClient(new Uri(endpoint), authkey,
                new ConnectionPolicy()
                {
                    MaxConnectionLimit = maxConnections,
                    ConnectionMode = ConnectionMode.Direct,
                    ConnectionProtocol = Protocol.Tcp,
                    RetryOptions = new RetryOptions()
                    {
                        MaxRetryAttemptsOnThrottledRequests = 10
                    }
                });

            _Client.OpenAsync().Wait();
            CreateDatabaseIfNotExistsAsync().Wait();
            CreateCollectionIfNotExistsAsync().Wait();
        }

据我了解，这意味着每个 Web 应用服务器一个 CosmosDB 客户端。我确实有多个 Web 应用服务器，因此单个用户可能会从多个 AppServer 和不同的 CosmosDb 客户端访问 CosmosDB。

在用户与 ComosDB 交互之前，我会检查他们的会话对象是否有 CosmosDb SessionToken，如下所示：

string docDbSessionToken = HttpContext.Session.GetString("StorageSessionToken");

然后，例如，在编写文档时，该方法看起来像这样：

 public async Task<Document> CreateItemAsync<T>(T item, Ref<string> sessionTokenOut, string sessionTokenIn = null)
        {
            ResourceResponse<Document> response = null;
            if (string.IsNullOrEmpty(sessionTokenIn))
            {
                response = await _Client.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(_DatabaseId, _Collection), item);
            }
            else
            {
                response = await _Client.CreateDocumentAsync(UriFactory.CreateDocumentCollectionUri(_DatabaseId, _Collection), item, new RequestOptions() { SessionToken = sessionTokenIn });
            }

            sessionTokenOut.Value = response.SessionToken;
            Document created = response.Resource;
            return created;
        }

这个想法是，如果我们有一个会话令牌，我们传递一个并使用它。如果我们没有，只需创建文档，然后将新创建的会话令牌返回给调用者。这工作正常...

除了，我不清楚为什么当我传递一个会话令牌时，我会得到一个不同的会话令牌。也就是说，当_Client.CreateDocumentAsync返回时，response.SessionToken总是和参数sessionTokenIn不同。

这是否意味着我应该从那时起为该用户使用新的会话令牌？这是否意味着我应该忽略新的会话令牌并使用初始会话令牌？

其中一个“会话”能持续多久？它们是传统意义上的会话吗？

最终，我只需要确保同一用户始终可以读取他们的写入内容，无论他们连接到哪个 AppServer 或当前有多少其他用户正在使用数据库。

Answer 1

我想这里的困惑在于会话是什么？

在大多数场景/框架中，将会话视为静态标识符（相关性），而对于 cosmos，sessionToken 是动态的（一种书签/cosmos db 状态的表示，随写入而变化）。将其命名为“sessionToken”可能是造成混淆的根源。

在这种特定情况下，您应该使用 cosmos API 中的“returned sessiontoken”。