Я пытаюсь получить все изменения из моей отслеживаемой базы данных в ленте изменений базы данных Cosmos, следуя приведенным ниже кодам. Я пытаюсь использовать разную продолжительность, например, изменения, происходящие сегодня, или изменения, произошедшие за последние 7 дней, или изменения, произошедшие в целом. Теперь во всех случаях я получаю все изменения в первый раз и никаких изменений во втором прогоне, если не произойдет изменений. Я хотел бы знать, что я здесь делаю не так, и если мне нужно получать изменения только за последнюю неделю при каждом запуске, как мне настроить ленту изменений, если мой приведенный ниже код неверен. Заранее спасибо
private static CosmosClient Client { get; set; }
static void Main(string[] args)
{
Task.Run(async () =>
{
Client = new CosmosClient("AccountEndpoint = https://test.documents.azure.com:443/;AccountKey=FW5yvDA==;");
var database = Client.GetDatabase("twstDatabase");
var container = database.GetContainer("TestContainer");
var leaseContainer = database.GetContainer("leases");
var cfp = container.GetChangeFeedProcessorBuilder<dynamic>("cfpLibraryDThird", ProcessChanges)
.WithLeaseContainer(leaseContainer)
.WithInstanceName("Change Feed Instance Demo")
// I change the instance name for different start time
.WithStartTime(DateTime.Today.AddDays(-7).ToUniversalTime())
//.WithStartTime(DateTime.MinValue.ToUniversalTime())
.Build();
await cfp.StartAsync();
Console.WriteLine("Started Change feed processor- press key to stop");
Console.ReadKey(true);
await cfp.StopAsync();
}).Wait();
}
static async Task ProcessChanges(IReadOnlyCollection<dynamic> docs, CancellationToken cancellationToken)
{
foreach (var doc in docs)
{
Console.WriteLine($"Document {doc.id} has changed");
}
}
}
}