DocumentDb, оптимизирующий возобновление подачи без разбиения на разделы

Question

Я создаю нераспределенную ленту изменений, которую я хочу возобновить, например. опрос для новых изменений каждые X секунд. Переменная контрольной точки ниже содержит последний ответ продолжения ответа.

private string checkpoint; 

    private async Task ReadEvents() 
    { 
      FeedResponse<dynamic> feedResponse; 
      do 
      { 
       feedResponse = await client.ReadDocumentFeedAsync(commitsLink, new FeedOptions 
       { 
        MaxItemCount = this.subscriptionOptions.MaxItemCount, 
        RequestContinuation = checkpoint 
       }); 

       if (feedResponse.ResponseContinuation != null) 
       { 
        checkpoint = feedResponse.ResponseContinuation; 
       } 

       // Code to process docs goes here... 

      } while (feedResponse.ResponseContinuation != null); 
    } 

Обратите внимание на использование блока «if» вокруг контрольной точки. Это делается, потому что, если я оставлю это, responseContinuation получает значение null, что в основном перезапустит цикл опроса, поскольку установка продолжения запроса на нуль приведет к 1-му набору документов в фиде изменений.

Однако нижняя граница каждого цикла опроса будет воспроизводить предыдущий набор документов, а не только любые дополнительные изменения. Есть ли что-то, что я могу сделать, чтобы оптимизировать это дальше или это ограничение API-интерфейса изменения?

Answer 1

Для того, чтобы читать канал изменений, вы должны использовать CreateDocumentChangeFeedQuery (который никогда не сбрасывает ResponseContinuation), вместо ReadDocumentFeed (который устанавливает значение null, когда результатов больше нет).

См. https://docs.microsoft.com/en-us/azure/documentdb/documentdb-change-feed#working-with-the-rest-api-and-sdk для образца.