...

• 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

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

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

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

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

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/port
• baud: 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

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)

...