...
delimiter: The delimiter for splitting the input
skipfirstline: Skip the first line of input
SICK
Description
The SICK protocol handler allows the communication to the SICK laserscanner LMS1xx to receiver the status and the distance measurements of these sensors. The SICK protocol handler can only be used in conjunction with the SICK data handler.
Options
byteorder:
The byte order for the communication (optional)username:
The username for the administration of the laser scanner(optional)password:
The password for the administration of the laser scanner (optional)
Schema
The output of the protocol handler provides the following attributes that can be used through the schema of the access operator:
- TIMESTAMP
- VERSION
- DEVICE
- SERIAL
- STATUS
- MESSAGECOUNT
- SCANCOUNT
- POWERUPDURATION
- TRANSMISSIONDURATION
- INPUTSTATUS
- OUTPUTSTATUS
- SCANNINGFREQUENCY
- MEASUREMENTFREQUENCY
- DIST1
- RSSI1
- DIST2
- RSSI2
Example
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='lms1', wrapper='GenericPush',
transport='TCPClient',protocol='SICK',
dataHandler='SICK',options=[['host','192.168.1.20'],['port','2111']],
schema=[
['dist1','SpatialMultiPoint']
]
}) |
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
Portport: 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) |
...