RedisSource<TOutput>
Class RedisSource<TOutput>
A data flow source for Redis. Redis is a key/value store.
You can define a different scan pattern to describe which keys should be retrieved. (Default pattern
is * which retrieves all key).
By default, the stored values will be deserialized using Newtonsoft.Json and JsonConvert. This
works only if your values contain json - for other values you can define your own serialization function.
Inherited Members
Namespace: ETLBox.Redis
Assembly: ETLBox.Redis.dll
Syntax
Type Parameters
Name | Description |
---|---|
TOutput | Type of outgoing data. |
Constructors
RedisSource()
Declaration
Properties
ConnectionString
If you provide a connection string, this component will create a new ConnectionMultiplexer object to connect with redis. If you already have a connection object instantiated in your application, use RedisConnection instead to pass it to the component.
Declaration
Property Value
Type | Description |
---|---|
string |
DatabaseNumber
Use the database number to store your data (redis databases are numbered from 0 to 15) The default database is 0.
Declaration
Property Value
Type | Description |
---|---|
int |
DeserializationFunc
Define your own deserialization function to read the stored data into your object.
Declaration
Property Value
Type | Description |
---|---|
Func<string, TOutput> |
DeserializerSettings
The JsonSerializerSettings used to serialize or deserialize your object into json. By default, this component assumes your stored value is a json and tries to deserialize using JsonConvert. Use DeserializationFunc if you want to define your own deserialization function.
Declaration
Property Value
Type | Description |
---|---|
JsonSerializerSettings |
RedisConnection
An existing ConnectionMultiplexer that holds a redis connection.
Declaration
Property Value
Type | Description |
---|---|
ConnectionMultiplexer |
ScanCountSize
This will modify the count size used for the scan. Default is 1000.
Declaration
Property Value
Type | Description |
---|---|
int |
ScanPattern
The scan pattern that describes which keys should be retrieved. The default is , which retrieves all keys from a database. Use e.g. ke to retrieve all keys that start with "ke".
Declaration
Property Value
Type | Description |
---|---|
string |
Methods
CheckParameter()
Declaration
Overrides
CleanUpOnFaulted(Exception)
Declaration
Parameters
Type | Name | Description |
---|---|---|
Exception | e |