ETLBox
Title here
Summary here
Custom destination
This article contains example code that shows the usage of the CustomDestination component.
The custom destination allows you to process your incoming data with any C# method. If you need to process your data in batches, you can use the CustomBatchDestination instead.
Processing data in strongly typed objects
public class MyRow
{
public int Id { get; set; }
public string Value { get; set; }
}
var source = new MemorySource<MyRow>();
source.DataAsList.Add(new MyRow() { Id = 1, Value = "Test1" });
source.DataAsList.Add(new MyRow() { Id = 2, Value = "Test2" });
List<MyRow> rows = new List<MyRow>();
var dest = new CustomDestination<MyRow>();
dest.WriteAction = (row, progressCount) => rows.Add(row);
source.LinkTo(dest);
Network.Execute(source);
string json = JsonConvert.SerializeObject(rows, Formatting.Indented);
Console.WriteLine(json);
//Output
/*
[
{
"Id": 1,
"Value": "Test1"
},
{
"Id": 2,
"Value": "Test2"
}
]
*/Processing data in dynamic objects
var source = new MemorySource();
dynamic r = new ExpandoObject();
r.Id = 1; r.Value = 2;
source.DataAsList.Add(r);
List<ExpandoObject> rows = new List<ExpandoObject>();
var dest = new CustomDestination();
dest.WriteAction = (row, progressCount) => rows.Add(row);
source.LinkTo(dest);
Network.Execute(source);Processing data in arrays
var source = new MemorySource<string[]>();
source.DataAsList.Add(new string[] { "1", "Test" });
List<string[]> rows = new List<string[]>();
var dest = new CustomDestination<string[]>();
dest.WriteAction = (row, progressCount) => rows.Add(row);
source.LinkTo(dest);
Network.Execute(source);