MonitorCosmosDB.cs 1.1 KB

123456789101112131415161718192021222324252627282930313233343536
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Net.Http;
  4. using System.Threading.Tasks;
  5. using Microsoft.Azure.Documents;
  6. using Microsoft.Azure.WebJobs;
  7. using Microsoft.Azure.WebJobs.Host;
  8. using Microsoft.Extensions.Logging;
  9. namespace TEAMModelFunction
  10. {
  11. public class MonitorCosmosDB
  12. {
  13. private readonly IHttpClientFactory _clientFactory;
  14. public MonitorCosmosDB( IHttpClientFactory clientFactory)
  15. {
  16. _clientFactory = clientFactory;
  17. }
  18. [FunctionName("School")]
  19. public async Task School([CosmosDBTrigger(
  20. databaseName: "TEAMModelOS",
  21. collectionName: "School",
  22. ConnectionStringSetting = "CosmosConnection",
  23. LeaseCollectionName = "leases")]IReadOnlyList<Document> input, ILogger log)
  24. {
  25. if (input != null && input.Count > 0)
  26. {
  27. log.LogInformation("Documents modified " + input.Count);
  28. log.LogInformation("First document Id " + input[0].Id);
  29. }
  30. //_clientFactory.CreateClient().
  31. }
  32. }
  33. }