Azure Cosmos DB + Functions Cookbook - live migration run.csx

run.csx

#r "Microsoft.Azure.Documents.Client"
using System;
using System.Collections.Generic;
using Microsoft.Azure.Documents;

public static async Task Run(IReadOnlyList<Document> input, IAsyncCollector<Document> docsToSave)
{
    foreach(var doc in input){
      // work with the document, process or create a new one
      await docsToSave.AddAsync(doc);
    }
}