从Azure函数访问CosmosDB(没有输入绑定)

Question

我在CosmosDB中有两个集合，股票和股票价格。

股票价格集合保存所有历史价格，并不断更新。

我想创建一个Azure函数，它监听< code>StockPrices更新(< code>CosmosDBTrigger)，然后对触发器传递的每个< code >文档执行以下操作:

1. 在股票集合中查找具有匹配代码的股票
2. 在股票集合中更新股票价格

我不能用＜code＞CosmosDB（绑定仅在触发器传递单个项时有效）。

我看到它工作的唯一方法是，如果我在CosmosDBTrigger List上前行，并从我的函数体访问CosmosDB并执行上面的步骤1和2。

问题：如何从我的功能中访问CosmosDB？

Answer 1

最终接受了诺亚·斯塔尔的建议。把这个留在这里作为替代方案。

我不知道如何直接做到这一点，所以想出了一个变通办法:

< li >使用< code >队列输出绑定在< code>StockPrices集合上添加带有< code>CosmosDBTrigger的函数 < li> foreach来自触发器的< code >文档，序列化并添加到< code >队列 < li >添加带有< code>QueueTrigger、< code>CosmosDB输入绑定的函数，用于< code >股票集合(将< code>PartitionKey和< code>Id设置为< code>StockTicker)，以及< code>CosmosDB输出绑定的函数，用于< code >股票集合 < li >用< code>QueueTrigger中的值更新< code>CosmosDB输入绑定中的< code>Stock < li >将更新的< code>Stock分配给< code>CosmosDB输出绑定参数(更新数据库中的记录)

也就是说，我想听听更直接的方法来做到这一点，因为我的方法看起来像是一种黑客。

Answer 2

CosmosDB绑定形式之一是获取DocumentClient实例，该实例提供容器上的所有操作。通过这种方式，您应该能够将变更提要触发器和项目操作组合到同一个函数中，如：

[FunctionName("ProcessStockChanges")]
public async Task Run(
    [CosmosDBTrigger(/* Trigger params */)] IReadOnlyList<Document> changedItems,
    [CosmosDB(/* Client params */)] DocumentClient client,
    ILogger log)
{
    // Read changedItems, 
    // Create/read/update/delete with client
}

也可以使用。NET Core使用依赖注入为您的函数实例提供成熟的自定义服务/存储库类以与Cosmos接口。这是我首选的方法，因为我可以使用最新版本的Cosmos SDK进行验证、控制序列化等。

您可能有意这样做，但只是提到考虑将数据合并到单个容器中，例如，按记录类型（Stock/StockPrice）和标识符的组合进行分区。这简化了事情，并且相对于多个容器，可以提高成本/资源效率。