ealsur

Container container = cosmosClient.GetContainer("myDb", "myCollection");

// Assuming your have your data available to be inserted or read
List<Task> concurrentTasks = new List<Task>();
foreach(Item itemToInsert in ReadYourData())
{
    concurrentTasks.Add(container.CreateItemAsync(itemToInsert, new PartitionKey(itemToInsert.MyPk)));
}

await Task.WhenAll(concurrentTasks);

ealsur

CosmosClientOptions options = new CosmosClientOptions() { 
                                            AllowBulkExecution = true };

CosmosClient cosmosclient = new CosmosClient(connectionString, options);

ealsur

// To view the default settings, hold "alt" while clicking on the "Settings" button.
// For documentation on these settings, see: https://aka.ms/terminal-documentation

{
    "$schema": "https://aka.ms/terminal-profiles-schema",

    "defaultProfile": "{61c54bbd-c2c6-5271-96e7-009a87ff44bf}",

    "profiles":

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)
    {