在多区域 Azure Cosmos DB 中更改提要读取区域
Change feed read region in multi-region Azure Cosmos DB
我正在使用 Cosmos DB 多区域(单区域写入)帐户。目前它在美国东部和美国西部启用。写入区域是美国西部。更改提要侦听器部署在美国东部和美国西部。
鉴于此设置,我想了解更改源如何工作?
- 更改提要侦听器是否从他们部署的区域接收更改提要。示例 - 东方的听众从东方朗读,西方的听众从西方朗读。
或
- 他们从写入区域读取。以我为例,美国西部。
我正在使用更改提要处理器库来读取更改提要,代码是:
var feedCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.CosmosDb.DatabaseId,
CollectionName = configurations.CosmosDb.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey
};
var leaseCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.LeaseCollection.DatabaseId,
CollectionName = configurations.LeaseCollection.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey
};
var builder = new ChangeFeedProcessorBuilder();
var processor = builder
.WithHostName(hostName)
.WithFeedCollection(feedCollection)
.WithLeaseCollection(leaseCollection)
.WithObserverFactory(observerFactory)
.BuildAsync().Result;
默认情况下,将从写入区域(美国西部)读取更改。如果你想从另一个区域读取更改,你可以简单地使用 DocumentCollectionInfo
中的 ConnectionPolicy
设置,如下所示:
ConnectionPolicy regionalPolicy = new ConnectionPolicy();
regionalPolicy.PreferredLocations.Add("East US");
var feedCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.CosmosDb.DatabaseId,
CollectionName = configurations.CosmosDb.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey,
ConnectionPolicy = regionalPolicy
};
我正在使用 Cosmos DB 多区域(单区域写入)帐户。目前它在美国东部和美国西部启用。写入区域是美国西部。更改提要侦听器部署在美国东部和美国西部。
鉴于此设置,我想了解更改源如何工作?
- 更改提要侦听器是否从他们部署的区域接收更改提要。示例 - 东方的听众从东方朗读,西方的听众从西方朗读。
或
- 他们从写入区域读取。以我为例,美国西部。
我正在使用更改提要处理器库来读取更改提要,代码是:
var feedCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.CosmosDb.DatabaseId,
CollectionName = configurations.CosmosDb.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey
};
var leaseCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.LeaseCollection.DatabaseId,
CollectionName = configurations.LeaseCollection.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey
};
var builder = new ChangeFeedProcessorBuilder();
var processor = builder
.WithHostName(hostName)
.WithFeedCollection(feedCollection)
.WithLeaseCollection(leaseCollection)
.WithObserverFactory(observerFactory)
.BuildAsync().Result;
默认情况下,将从写入区域(美国西部)读取更改。如果你想从另一个区域读取更改,你可以简单地使用 DocumentCollectionInfo
中的 ConnectionPolicy
设置,如下所示:
ConnectionPolicy regionalPolicy = new ConnectionPolicy();
regionalPolicy.PreferredLocations.Add("East US");
var feedCollection = new DocumentCollectionInfo()
{
DatabaseName = configurations.CosmosDb.DatabaseId,
CollectionName = configurations.CosmosDb.CollectionId,
Uri = new Uri(configurations.CosmosDb.EndpointUri),
MasterKey = configurations.CosmosDb.AuthKey,
ConnectionPolicy = regionalPolicy
};