Cosmos DB变更馈送的多个消费者

Question

我使用Change Feed处理器库(或者Azure Functions Cosmos DB trigger)来订阅集合更新。如何为同一个集合的提要设置多个独立的(非竞争的)消费者？

一种方法是使用多个租赁集合，例如，leases1，leases2等，但这有点浪费。

有没有办法只用一个租约集合就做到这一点？(例如，通过在某处指定消费者组名称，类似于事件中心处理器)

Answer 1

我注意到直接通过变更提要处理器库使用变更提要与通过函数集成使用变更提要之间存在一些不一致。

使用变更馈送处理器库时，会生成如下文档:

{
    "id": "somegraph.documents.azure.com_obtRAA==_obtRAJvr8AU=..0",
    "_etag": "\"47006e54-0000-0000-0000-59d4fdf20000\"",
    "state": 2,
    "PartitionId": "0",
    "Owner": "CosmosChangeIngestionServiceType",
    "ContinuationToken": "\"143641\"",
    "SequenceNumber": 3322,
    "_rid": "obtRAIhO1RIFAAAAAAAAAA==",
    "_self": "dbs/obtRAA==/colls/obtRAIhO1RI=/docs/obtRAIhO1RIFAAAAAAAAAA==/",
    "_attachments": "attachments/",
    "_ts": 1507130866
}

从函数中生成的代码可疑地省略了< code>Owner属性，并将其设置为null。我的理解是，这个< code>Owner字段区分了变更提要消费者，并允许多个消费者跟踪同一个租约集合中的进度(这显然是理想的)。所以我不确定这是一个bug还是我在设置函数绑定时遗漏了什么，但是看起来目前每个租约集合只能有一个函数消费者。

刚刚与 Cosmos 团队进行了每周一次的通话，并询问了他们这个具体问题，以及其他租赁存储提供商（如表存储）的状态。他们应该在一天结束之前回复我们，并做出一些澄清。当我们取回官方信息时，我将进一步更新。

Answer 2

您可以为Azure Function Cosmos DB触发器定义leaseCollection Prefix。在Azure门户中，只需单击您的函数，然后单击集成，然后单击高级编辑器，这将打开您的function.json。在那里，您可以在触发器上定义属性，例如：

"bindings": [
    {
      "type": "cosmosDBTrigger",
      "name": "documents",
      "direction": "in",
      "leaseCollectionName": "leases",
      "connectionStringSetting": "myDatabase_DOCUMENTDB",
      "databaseName": "myDbName",
      "collectionName": "myCollectionName",
      "createLeaseCollectionIfNotExists": false,
      "leaseCollectionPrefix": "myFunctionSpecificValue"
    }

其他设置记录在文档下：

以下设置自定义内部更改馈送机制和租赁收款用途，并可在功能中进行设置。高级编辑器中的json和相应的属性名称：

< Li > < code > leasescollectionprefix :设置时，它会向在此函数的租约集合中创建的租约添加前缀，从而有效地允许两个单独的Azure函数通过使用不同的前缀来共享同一租约集合。 < li> feedPollDelay:该位置位时，它定义在清空所有当前更改后，轮询分区以查找feed上的新更改之间的延迟时间，以毫秒为单位。默认值为5000 (5秒)。 < Li > < code > lease acquire interval :设置时，它以毫秒为单位定义启动任务的间隔，以计算分区是否均匀分布在已知的主机实例中。默认值为13000 (13秒)。 < Li > < code > leaseExpirationInterval :设置时，它定义代表一个分区的租约的租用间隔，以毫秒为单位。如果在此时间间隔内没有续订租约，将导致租约到期，分区的所有权将转移到另一个实例。默认值为60000 (60秒)。 < Li > < code > lease renewinterval :设置时，它定义实例当前持有的分区的所有租约的续订间隔(以毫秒为单位)。默认值为17000 (17秒)。 < Li > < code > check point frequency :设置时，它定义租用检查点之间的间隔，以毫秒为单位。默认值总是在函数调用成功后。 < Li > < code > maxItemsPerInvocation :设置时，它自定义每次函数调用接收的最大项数。