...
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
output = SENDER({ wrapper='GenericPush', transport='TCPClient', protocol='CSV', dataHandler='Tuple', options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']] }, input) |
Available Transport Handler
TCPClient
Description
The TCPClient transport handler allows the delivery of results over TCP/IP to an arbitrary host. This transport handler can be used in both directions, connecting to a server to receive data and connect to a server to publish data.
Options
host: The host/IP of the target
port: The port of the target system
read: The size of the read buffer (optional)
write: The size of the write buffer (optional)
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8080'],['read', '10240'],['write', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']]
}, input) |
TCPServer
Description
The TCPServer transport handler allows the propagation of results over TCP/IP as a server. This transport handler can be used in both directions, other client can connect to this server to receive data and to publish data.
Options
port: The port to listen for connections
read: The size of the read buffer (optional)
write: The size of the write buffer (optional)
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='TCPServer',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '8080'],['read', '10240'],['write', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({wrapper='GenericPush',
transport='TCPServer',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '8081'],['read', '10240'],['write', '10240']]
}, input) |
UDPClient
Description
The UDPClient transport handler allows the delivery of results over UDP/IP to an arbitrary host. This transport handler can only be used in one direction, to publish data over UDP.
Options
host: The host/IP of the target
port: The port of the target system
write: The size of the write buffer (optional)
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
output = SENDER({wrapper='GenericPush',
transport='UDPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8080'],['write', '10240']]
}, input) |
UDPServer
Description
The UDPServer transport handler allows the propagation of results over UDP/IP as a server. This transport handler can only be used in one direction, other UDP clients can send data to this server to publish data.
Options
port: The port to listen for data
read: The size of the read buffer (optional)
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='UDPServer',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '8080'],['read', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
}) |
RS232
Description
The RS232 transport handler allows the communication over the RS232 standard
Options
port:
The device path/portbaud:
The baud number (default: 9600) (optional)parity:
The parity of the transfer (default: No parity) (optional)databits:
The number of databits (default: 8) (optional)stopbits:
The number of stop bits (default: 1) (optional)
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='RS232',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '/dev/ttyACM0'],['baud', '9600']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({wrapper='GenericPush',
transport='RS232',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '/dev/ttyACM0'],['baud', '9600']]
}, input) |