在azure函数cosmosdb触发器中从集合中检索文档

Question

我已经创建了一个azure函数，当一个新文档被添加到一个集合中时，它会被触发。

public static void Run(IReadOnlyList<Document> input, ILogger log)
{
if (input != null && input.Count > 0)
{
    log.LogInformation("Documents modified " + input.Count);
    log.LogInformation("First document Id " + input[0].Id);
}}

是否可以从该集合中选择特定文档，然后查询所选文档中的数据？

例如，在所谓的募集服装，我有一个文件，有一个ID： 12345Tops.我想查询ID为：12345Tops的文档中找到的数据。

或者检索集合中的第一个文档，然后查询第一个选定文档

我看过带有http触发器的azure函数：https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-cosmosdb#trigger---属性

但是我需要使用cosmosdb触发器，因为当文档被添加到集合中时需要触发它。

Answer 1

我认为你不必调用CosmosDb来从CosmosDb触发器中检索完整的文档。

您应该能够获取json并反序列化为所需的类型。请参阅下面的示例函数。

只需执行ToString（）即可从传递给函数的文档列表中提取文档内容。或者可以直接将json反序列化为现有的对象。

public static class CosmosDbAuditFunction
{
    [FunctionName("CosmosDbAuditFunction")]
    public static void Run([CosmosDBTrigger(
        databaseName: "DBNAME",
        collectionName: "COLLECTIONNAME",
        ConnectionStringSetting = "CosmosDbConnectionString",
        LeaseCollectionName = "LeaseCollection",
        CreateLeaseCollectionIfNotExists = true)]IReadOnlyList<Document> input, ILogger log)
    {
        if (input != null && input.Count > 0)
        {
            var changedDocumentjson = input[0].ToString();               
        }
    }
}

Answer 2

如果我理解正确，您希望根据第一个集合上发生的更改查询第二个集合上的文档？

这当然是可行的，您需要使用Cosmos DB输入绑定并拉取DocumentClient实例。

代码看起来像：

[FunctionName("CosmosTrigger")]
public static void Run([CosmosDBTrigger(
        databaseName: "ToDoItems",
        collectionName: "Items",
        ConnectionStringSetting = "CosmosDBConnection",
        LeaseCollectionName = "leases",
        CreateLeaseCollectionIfNotExists = true)]IReadOnlyList<Document> documents, 
    [CosmosDB(
        databaseName: "ToDoItems",
        collectionName: "CollectionToQuery",
        ConnectionStringSetting = "CosmosDBConnection")] DocumentClient client,
    ILogger log)
{
    foreach (var documentInsertedOrUpdated in documents)
    {
        try
        {
            // Do a read document on another collection
            var otherDocument = await client.ReadDocumentAsync(UriFactory.CreateDocumentUri("ToDoItems", "CollectionToQuery", "some-id-maybe-taking-it-from-the-documentInsertedOrUpdated"));
        }
        catch(Exception ex)
        {
            log.LogError(ex, "Failed to process document");
        }
    }
}