AFListData.UpdateValues Method (IList(AFValue), AFUpdateOption, AFBufferOption)

public static AFErrors<AFValue> UpdateValues(
	IList<AFValue> values,
	AFUpdateOption option,
	AFBufferOption bufferOption
)

// This example demonstrates how to update values to attributes with PIPoint data reference from different PIServers through AFListData.
// Note: For successful write through Buffer, PI Buffer Subsystem needs to be correctly pre-configured with PI Buffer Manager. 

// Get the Database and UOMs
PISystems myPISystems = new PISystems();
PISystem myPISystem = myPISystems.DefaultPISystem;
AFDatabase myDB = myPISystem.Databases.DefaultDatabase;
UOM uomFoot = myPISystem.UOMDatabase.UOMs["foot"];
UOM uomYard = myPISystem.UOMDatabase.UOMs["yard"];

// Create Attributes and their new values
AFAttributeList attrList = new AFAttributeList();
AFTime newStartTime = new AFTime("T-1d", CultureInfo.CurrentCulture);
List<AFValue> newValues = new List<AFValue>();
Random randomValues = new Random();

// Create Dynamic Attributes to a PIPoint (from different PIServers if possible) to Update
List<PIServer> piServers = new List<PIServer>();
piServers.Add(PIServers.GetPIServers().DefaultPIServer);
//ToDo: change "jcncpi390" to a valid (and accessible) piserver name available in KST, that is different than the default piserver
PIServer secondServer = PIServers.GetPIServers()["jcncpi390"];
if (secondServer != null && String.Compare(secondServer.Name, piServers[0].Name, StringComparison.OrdinalIgnoreCase) != 0)
    piServers.Add(secondServer);
int dataCount = 5; //Create 5 new values to update
AFTime newTime = newStartTime;
foreach(PIServer piServer in piServers)
{
    newTime = newStartTime;
    PIPoint point;
    if (!PIPoint.TryFindPIPoint(piServer, "MyTestPoint#1", out point))
    {
        point = piServer.CreatePIPoint("MyTestPoint#1");
    }
    AFAttribute myAttribute = new AFAttribute(String.Format(CultureInfo.InvariantCulture, @"\\{0}\{1}", piServer.Name, point.Name));
    myAttribute.DefaultUOM = uomFoot;
    myAttribute.ConfigString += ";ReadOnly=False";
    attrList.Add(myAttribute);
    for (int i = 0; i < dataCount; i++)
    {
        AFValue newValue = new AFValue(myAttribute, randomValues.NextDouble(), newTime, uomYard);
        newValues.Add(newValue);
        newTime = newTime.LocalTime.AddMinutes(10);
    }
}
AFTime newEndTime = newTime;

// Get the Recorded Values for the Attributes
int totalRecordedValuesCount = 0;
foreach (AFAttribute myAttribute in attrList)
{
    AFValues recordedValues = myAttribute.Data.RecordedValues(new AFTimeRange(newStartTime, newEndTime), AFBoundaryType.Inside,
        myAttribute.DefaultUOM, null, false);
    Console.WriteLine("Recorded Values:");
    foreach (AFValue value in recordedValues)
    {
        Console.WriteLine("  {0}: '{1} {2}' at '{3}'",
            value.Attribute, value.Value, value.UOM, value.Timestamp);
    }
    totalRecordedValuesCount += recordedValues.Count;
}

// Get the Buffer Option
// Note: If not specified in AFSDK.config, the buffer option is defaulted to "BufferIfPossible". 
Console.WriteLine("Current Buffer Option: {0}", AFData.BufferOption);

// Set the Buffer Option to "Buffer" if it is not already, which will be valid throughout this client instance.
if (AFData.BufferOption != AFBufferOption.Buffer)
{
    AFData.BufferOption = AFBufferOption.Buffer;
    Console.WriteLine("Current Buffer Option for this instance has been changed to: {0}", AFData.BufferOption);
}

//1. Update the Attribute Values and Display any Errors
AFErrors<AFValue> errorsWithBuffer =
    AFListData.UpdateValues(newValues, AFUpdateOption.InsertNoCompression); //Insert or InsertNoCompression
Thread.Sleep(1000);

if (errorsWithBuffer != null && errorsWithBuffer.HasErrors)
{
    Console.WriteLine("\nErrors returned from AFListData.UpdateValues:");

    // Display Value errors
    if (errorsWithBuffer.Errors != null && errorsWithBuffer.Errors.Count > 0)
    {
        foreach (var item in errorsWithBuffer.Errors)
        {
            Console.WriteLine("  AFValue '{0}': {1}", item.Key, item.Value);
        }
    }

    // Display error from the PI Data Archive
    if (errorsWithBuffer.PIServerErrors != null && errorsWithBuffer.PIServerErrors.Count > 0)
    {
        foreach (var item in errorsWithBuffer.PIServerErrors)
        {
            Console.WriteLine("  AFValue '{0}': {1}", item.Key, item.Value);
        }
    }

    // Display PI System errors
    if (errorsWithBuffer.PISystemErrors != null && errorsWithBuffer.PISystemErrors.Count > 0)
    {
        foreach (var item in errorsWithBuffer.PISystemErrors)
        {
            Console.WriteLine("  AFValue '{0}': {1}", item.Key, item.Value);
        }
    }
}


//2. Alternatively, one can specify buffer option in the UpdateValues method
AFErrors<AFValue> errorsWithBufferIfPossible =
    AFListData.UpdateValues(newValues, AFUpdateOption.InsertNoCompression, AFBufferOption.BufferIfPossible);
Thread.Sleep(1000);

// Get the Updated Recorded Values for the Attributes
int totalRecordedValuesCountUpdated = 0;
foreach (AFAttribute myAttribute in attrList)
{
    AFValues recordedValuesUpdated = myAttribute.Data.RecordedValues(new AFTimeRange(newStartTime, newEndTime), AFBoundaryType.Inside,
        myAttribute.DefaultUOM, null, false);
    Console.WriteLine("\nUpdated Recorded Values:");
    foreach (AFValue value in recordedValuesUpdated)
    {
        Console.WriteLine("  {0}: '{1} {2}' at '{3}'",
            value.Attribute, value.Value, value.UOM, value.Timestamp);
    }
    totalRecordedValuesCountUpdated += recordedValuesUpdated.Count;
}