DocumentDB変更フィードと保存チェックポイント

Question

ドキュメントを読んだ後、変更フィードを概念化するのが苦労しています。下のdocumentationのコードを見てみましょう。 2番目の変更フィードは、最後にチェックポイント経由で実行されたときから変更を取得しています。サマリーデータの作成に使用されているとし、問題があり、前回から再実行する必要があったとします。私は次のことを理解していません。

• チェックポイントを開始する特定の時間を指定する方法。チェックポイント辞書を保存して実行ごとに使用することができると理解していますが、X時間から変更してサマリーデータを再実行するにはどうすればよいでしょうか
• 2番目のサマリーデータを再実行し、集計された各データに使用されているので、そのデータがどこで中止されたかがわかります。レコードがそのチェックポイントの前または前にあることをどのように知っていますか？始まり、その後、最後のチェックポイントから収集から実行

コード：

Dictionary < string, string > checkpoints = await GetChanges(client, collection, new Dictionary < string, string >()); 

    await client.CreateDocumentAsync(collection, new DeviceReading { 
    DeviceId = "xsensr-201", MetricType = "Temperature", Unit = "Celsius", MetricValue = 1000 
    }); 
    await client.CreateDocumentAsync(collection, new DeviceReading { 
    DeviceId = "xsensr-212", MetricType = "Pressure", Unit = "psi", MetricValue = 1000 
    }); 

    // Returns only the two documents created above. 
    checkpoints = await GetChanges(client, collection, checkpoints); 
    // 

    private async Task < Dictionary < string, string >> GetChanges(
    DocumentClient client, 
    string collection, 
    Dictionary < string, string > checkpoints) { 
    List <PartitionKeyRange> partitionKeyRanges = new List <PartitionKeyRange>(); 
    FeedResponse <PartitionKeyRange> pkRangesResponse; 

    do { 
    pkRangesResponse = await client.ReadPartitionKeyRangeFeedAsync(collection); 
    partitionKeyRanges.AddRange(pkRangesResponse); 
    } 
    while (pkRangesResponse.ResponseContinuation != null); 

    foreach(PartitionKeyRange pkRange in partitionKeyRanges) { 
    string continuation = null; 
    checkpoints.TryGetValue(pkRange.Id, out continuation); 

    IDocumentQuery <Document> query = client.CreateDocumentChangeFeedQuery(
    collection, 
    new ChangeFeedOptions { 
     PartitionKeyRangeId = pkRange.Id, 
     StartFromBeginning = true, 
     RequestContinuation = continuation, 
     MaxItemCount = 1 
    }); 

    while (query.HasMoreResults) { 
    FeedResponse <DeviceReading> readChangesResponse = query.ExecuteNextAsync <DeviceReading>().Result; 

    foreach(DeviceReading changedDocument in readChangesResponse) { 
     Console.WriteLine(changedDocument.Id); 
    } 

    checkpoints[pkRange.Id] = readChangesResponse.ResponseContinuation; 
    } 
    } 

    return checkpoints; 
    } 

Answer 1

DocumentDBは、サーバが返す論理タイムスタンプによってのみチェックポインティングをサポートします。 X分前からすべての変更を取得する場合は、時計の時刻に対応する論理タイムスタンプ（REST APIのコレクションではETag、SDKの場合はResponseContinuation）を「覚えて」いる必要があります。変更。

変更フィードは、さまざまなサーバー/パーティションで異なる可能性があるため、時計時刻の代わりに論理時刻を使用します。時計の時間に基づいて変更フィードのサポートを確認したい場合は、/ upvoteをhttps://feedback.azure.com/forums/263030-documentdb/に提出してください。

パーティションキー/ドキュメントごとに最後のチェックポイントを保存するには、Fredのように、最後に表示されたバッチの対応するバージョンを保存するだけです（REST APIのコレクションではETag、SDKではResponseContinuation）彼の答えに示唆された。

Answer 2

チェックポイントが開始する必要があり、特定の時間を指定する方法。

ChangeFeedOptionsのRequestContinuationプロパティとしてnull値を指定する代わりに、論理バージョン/ ETag（たとえば、95488など）を指定できます。