Class CsvSource<TOutput>
Reads data from a csv source. While reading the data from the file, data is also asnychronously posted into the targets. Data is read a as string from the source and dynamically converted into the corresponding data format.
Inheritance
Inherited Members
Namespace: ETLBox.Csv
Assembly: ETLBox.Csv.dll
Syntax
public class CsvSource<TOutput> : DataFlowStreamSource<TOutput>, IDataFlowLogging, IDataFlowStreamSource<TOutput>, IDataFlowExecutableSource<TOutput>, IDataFlowSource<TOutput>, IDataFlowStreamSource, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTask
Type Parameters
| Name | Description |
|---|---|
| TOutput | Type of outgoing data |
Examples
CsvSource<CSVData> source = new CsvSource<CSVData>("Demo.csv");
source.Configuration.Delimiter = ";";Constructors
CsvSource()
Declaration
public CsvSource()
CsvSource(string)
Declaration
public CsvSource(string uri)
Parameters
| Type | Name | Description |
|---|---|---|
| string | uri | The source csv file name or uri |
CsvSource(string, ResourceType)
Declaration
public CsvSource(string uri, ResourceType resourceType)
Parameters
| Type | Name | Description |
|---|---|---|
| string | uri | The source csv file name or uri |
| ResourceType | resourceType | Specifies if data is loaded from a file, a web endpoint or other storage types (e.g. Azure Blob Storage) |
Properties
Configuration
The CsvHelper Configuration. E.g. you can change the delimiter or the escape character here.
Declaration
public CsvConfiguration Configuration { get; set; }
Property Value
| Type | Description |
|---|---|
| CsvConfiguration |
CsvContext
Gives you access to the CsvHelper CsvContext. You can modify the context before data is read.
Declaration
public Action<CsvContext> CsvContext { get; set; }
Property Value
| Type | Description |
|---|---|
| Action<CsvContext> |
FieldHeaders
The parsed header names from the csv
Declaration
public string[] FieldHeaders { get; }
Property Value
| Type | Description |
|---|---|
| string[] |
Methods
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
CloseReader()
Declaration
protected override void CloseReader()
Overrides
InitReader()
Declaration
protected override void InitReader()
Overrides
ReadAllRecords()
Declaration
protected override void ReadAllRecords()
Overrides
ReadFieldHeaders(string)
Reads the header names using the current configuration.
Declaration
public string[] ReadFieldHeaders(string uri = null)
Parameters
| Type | Name | Description |
|---|---|---|
| string | uri | Optionally you can override the current configured Uri |
Returns
| Type | Description |
|---|---|
| string[] | An array with the header names |