Bots From Extension: datanetwork
Data Network - Read, Write and poll data from a stream
This extension provides 3 bots.
Bot @dn:poll-stream
Bot Position In Pipeline: Source
Poll for data from specified stream in the data network. This bot usually used inside a loop.
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
Parameter Name | Type | Default Value | Description |
---|---|---|---|
name* | Text | Stream name | |
group* | Text | Data receiver group name | |
offset_reset | Text | earliest | Stream offset reset position. Valid values are 'earliest' or 'latest' |
batch_size | Text | 100 | Maximum rows to read in each batch |
batch_wait | Text | 5 | Maximum number of seconds to wait once one or more events are received. |
max_wait | Text | 30 | Maximum number of seconds to wait when no events are received. |
Bot @dn:read-stream
Bot Position In Pipeline: Source
Read data from specified stream in the data network. This bot implements an infinite loop for receiving the data.
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
Parameter Name | Type | Default Value | Description |
---|---|---|---|
name* | Text | Stream name | |
group* | Text | Data receiver (consumer) group name | |
offset_reset | Text | earliest | Stream offset reset position. Valid values are 'earliest' or 'latest' |
batch_size | Text | 100 | Maximum rows to read in each batch |
Bot @dn:write-stream
Bot Position In Pipeline: Sink
Write data to specified stream in the data network
This bot expects a Restricted CFXQL.
Each parameter may be specified using '=' operator and AND logical operation
Following are the parameters expected for this Bot
Parameter Name | Type | Default Value | Description |
---|---|---|---|
name* | Text | Stream name |