我已经使用 Python 中的 CosmosDBTrigger 设置了一个 Azure 函数,目标是一个我称为“任务”的容器。这个想法是,每次将任务添加到容器时,都会触发 Azure 函数实例,然后该实例根据提供的元数据处理该任务。
目前该功能在基本意义上正在工作 - 它正在获取更改并处理它们,但是它并没有以并行方式横向扩展和处理对容器的更改。即,当任务添加到容器中时,它们是被逐一处理的,而不是按预期通过不同的调用并行处理。有没有办法确保任务并行处理?
为了补充背景,我加入了弹性消费计划。
这个问题以前有人问过,之前的一些回答:
简而言之,并行度是由受监控容器中的物理分区定义的。更改源需要保证逻辑数据分区内的事件顺序。如果所有更改都并行交付,则该保证将被打破。