Patch Time Series Operations

Create a PatchRequest instance:

• Define the Append or Delete action using the JavaScript time series API.

Create a PatchOperation instance and pass it:

• The ID of the document to patch
• The document change vector (or null)
• The PatchRequest object

Execute the PatchOperation operation by calling store.Operations.Send

NOTE:

• The server treats timestamps passed in the patch request script as UTC, no conversion is applied by the client to local time.
• Appending entries to a time series that doesn't yet exist yet will create the time series.
• No exception is thrown if the specified document does not exist.

In this example, we append a single entry to time series "HeartRates" on the specified document.

var baseTime = DateTime.UtcNow;

var patchRequest = new PatchRequest
{
    // Define the patch request using JavaScript:
    Script = "timeseries(this, $timeseries).append($timestamp, $values, $tag);",
    
    // Provide values for the parameters in the script:
    Values =
    {
        { "timeseries", "HeartRates" },
        { "timestamp", baseTime.AddMinutes(1) },
        { "values", 59d },
        { "tag", "watches/fitbit" }
    }
};

// Define the patch operation;
var patchOp = new PatchOperation("users/john", null, patchRequest);

// Execute the operation:
store.Operations.Send(patchOp);

In this example, we append 100 entries to time series "HeartRates" on the specified document.
Timestamps and values are drawn from an array and other arguments are provided in the "Values" property.

var baseTime = DateTime.UtcNow;

// Create arrays of timestamps and random values to patch
var values = new List<double>();
var timeStamps = new List<DateTime>();

for (var i = 0; i < 100; i++)
{
    values.Add(68 + Math.Round(19 * new Random().NextDouble()));
    timeStamps.Add(baseTime.AddMinutes(i));
}

var patchRequest = new PatchRequest
{
    Script = @"var i = 0;
               for (i = 0; i < $values.length; i++) {
                   timeseries(id(this), $timeseries).append (
                       $timeStamps[i],
                       $values[i],
                       $tag);
               }",
    Values =
    {
        { "timeseries", "HeartRates" },
        { "timeStamps", timeStamps },
        { "values", values },
        { "tag", "watches/fitbit" }
    }
};

var patchOp = new PatchOperation("users/john", null, patchRequest);
store.Operations.Send(patchOp);

In this example, we delete a range of 50 entries from time series "HeartRates" on the specified document.

store.Operations.Send(new PatchOperation("users/john", null,
    new PatchRequest
    {
        Script = "timeseries(this, $timeseries).delete($from, $to);",
        Values =
        {
            { "timeseries", "HeartRates" },
            { "from", baseTime },
            { "to", baseTime.AddMinutes(49) }
        }
    }));

The detailed syntax of PatchOperation is listed under this syntax section.

The detailed syntax of PatchRequest is listed under this syntax section.

The available JavaScript API methods are detailed in the time series JavaScript support article.

In order to patch time series data on multiple documents, you need to:

• Define a query that retrieves the set of documents to be patched (can be a dynamic or an index query).
• Define the patching action that will be executed on the matching documents.

This is achieved by defining a string, or creating an instance of IndexQuery that contains such string,
with the following two parts:

• The query: provide an RQL code snippet to filter the documents you want to patch.
• The patching script: use the JavaScript time series API to define the patching action.

Create a PatchByQueryOperation instance and pass it the IndexQuery object, or the defined string.

Execute the PatchByQueryOperation by calling store.Operations.Send.

• The patch operation will be executed only on documents that match the query.
• This type of operation can be awaited for completion. Learn more in Manage length operations.

NOTE:

• The server treats timestamps passed in the patch request script as UTC, no conversion is applied.
• No exception is thrown if any of the documents no longer exist during patching.

In this example, we append an entry to time series "HeartRates" on ALL documents in the "Users" collection.

var indexQuery = new IndexQuery
{
    // Define the query and the patching action that follows the 'update' keyword:
    Query = @"from Users as u 
              update
              {
                  timeseries(u, $name).append($time, $values, $tag)
              }",
    
    // Provide values for the parameters in the script:
    QueryParameters = new Parameters
    {
        { "name", "HeartRates" },
        { "time", baseline.AddMinutes(1) },
        { "values", new[] {59d} },
        { "tag", "watches/fitbit" }
    }
};

// Define the patch operation:
var patchByQueryOp = new PatchByQueryOperation(indexQuery);

// Execute the operation:
store.Operations.Send(patchByQueryOp);

In this example, we delete the "HeartRates" time series from documents that match the query criteria.

PatchByQueryOperation deleteByQueryOp = new PatchByQueryOperation(new IndexQuery
{
    Query = @"from Users as u
              where u.Age < 30
              update
              {
                  timeseries(u, $name).delete($from, $to)
              }",
    
    QueryParameters = new Parameters
            {
                { "name", "HeartRates" },
                { "from", DateTime.MinValue },
                { "to", DateTime.MaxValue }
            }
});

// Execute the operation: 
// Time series "HeartRates" will be deleted for all users with age < 30
store.Operations.Send(deleteByQueryOp);

In this example, for each document in the "Users" collection, we patch a document field with data retrieved from its time series entries. The document's time series data itself is Not patched. The document NumberOfUniqueTagsInTS field will be updated with the number of unique tags in the user's "HeartRates" time series. To do this, we use the JavaScript get method to get all the time series entries for each document
and extract each entry's tag.

PatchByQueryOperation patchNumberOfUniqueTags = new PatchByQueryOperation(new IndexQuery
{
    Query = @"
        declare function patchDocumentField(doc) {
            var differentTags = [];
            var entries = timeseries(doc, $name).get($from, $to);

            for (var i = 0; i < entries.length; i++) {
                var e = entries[i];

                if (e.Tag !== null) {
                    if (!differentTags.includes(e.Tag)) {
                        differentTags.push(e.Tag);
                    }
                }
            }

            doc.NumberOfUniqueTagsInTS = differentTags.length;
            return doc;
        }

        from Users as u
        update {
            put(id(u), patchDocumentField(u))
        }",

    QueryParameters = new Parameters
    {
        { "name", "HeartRates" },
        { "from", DateTime.MinValue },
        { "to", DateTime.MaxValue }
    }
});

// Execute the operation and Wait for completion:
var result = store.Operations.Send(patchNumberOfUniqueTags).WaitForCompletion();

The detailed syntax of PatchByQueryOperation is listed under this syntax section.

The available JavaScript API methods are detailed in the time series JavaScript support article.