ealsur

[FunctionName("Trigger")]
public static void Trigger([CosmosDBTrigger(
    databaseName: "%MonitoredDatabase%",
    collectionName: "%MonitoredCollection%",
    ConnectionStringSetting = "CosmosDB",
    LeaseCollectionPrefix = "%MonitoredDatabaseLeasePrefix%",
    LeaseCollectionName = "leases",
    CreateLeaseCollectionIfNotExists = true)] IReadOnlyList<Document> documents, 
    ILogger log)
{

ealsur

private class CosmosDBConnectionString
{
    public CosmosDBConnectionString(string connectionString)
    {
        // Use this generic builder to parse the connection string
        DbConnectionStringBuilder builder = new DbConnectionStringBuilder
        {
            ConnectionString = connectionString
        };

ealsur

private static Lazy<IRemainingWorkEstimator> remainingWorkEstimator;

public static IRemainingWorkEstimator GetRemainingWorkEstimator(
    DocumentClient monitoredCollectionClient,
    DocumentClient leaseCollectionClient)
{
    if (remainingWorkEstimator == null)
    {
        // Pull the Connection string from the environment, Environment.GetEnvironmentVariable will read the local.settings.json file or the deployed Function App configuration
        CosmosDBConnectionString cosmosDBConnectionString = new CosmosDBConnectionString(Environment.GetEnvironmentVariable("CosmosDB"));

ealsur

[FunctionName("Monitor")]
public static async Task Monitor(
    [TimerTrigger("*/1 * * * * *", RunOnStartup = true)] TimerInfo timer, // Timer will trigger every 1 second, adjust CRON expression
    [CosmosDB("%MonitoredDatabase%", "%MonitoredCollection%", ConnectionStringSetting = "CosmosDB")] DocumentClient monitoredCollectionClient, 
    [CosmosDB("%MonitoredDatabase%", "leases", ConnectionStringSetting = "CosmosDB")] DocumentClient leaseCollectionClient,
    ILogger log)
{
    var estimator = GetRemainingWorkEstimator(monitoredCollectionClient, leaseCollectionClient);
    var remainingWork = await estimator.GetEstimatedRemainingWork();
    // Send custom metric to App Insight

ealsur

{
  "version": "2.0",
  "logging": {
    "fileLoggingMode": "always",
    "logLevel": {
      "Host.Triggers.CosmosDB": "Trace"
    }
  }
}

ealsur

    public static async Task<HttpResponseMessage> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = null)] HttpRequest req, 
        [CosmosDB(databaseName: "%CosmosDBDatabase%",
            collectionName: "%CosmosDBCollection%",
            ConnectionStringSetting = "CosmosDBConnectionString",
            UseMultipleWriteLocations = true,
            PreferredLocations = "Central US"
        )] IAsyncCollector<MyClass> documentsToSave,
        ILogger log)
    {

ealsur

    public static HttpResponseMessage Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = "HttpInputBindingByIdInRoute/{id}")] HttpRequestMessage req,
        [CosmosDB(databaseName: "%CosmosDBDatabase%",
            collectionName: "%CosmosDBCollection%",
            ConnectionStringSetting = "CosmosDBConnectionString",
            UseMultipleWriteLocations = true,
            PreferredLocations = "Central US,North Central US"
            Id = "{id}")] Document document,
        ILogger log)
    {

ealsur

{
  "cosmosDB": {
    "connectionMode": "Direct",
    "protocol": "Tcp"
  }
}

ealsur

{
  "documentDB": {
    "connectionMode": "Direct",
    "protocol": "Tcp"
  }
}

ealsur

[FunctionName("Trigger1")]
public static void Run(    
[CosmosDBTrigger("<your-monitored-database>", 
  "<your-monitored-collection>", 
  ConnectionStringSetting = "<your-connectionstring-setting>"
  LeaseCollectionPrefix = "trigger1")]
IReadOnlyList<Document> input,
TraceWriter log)
{
    log.Info("Documents modified " + input.Count);