The HTTP transport handler allows the communication over the HTTP standard
Options
uri:
The URImethod
: The HTTP method, one of: GET, POST, PUT, DELETE, HEAD (default: GET) (optional)body
: The content for POST and PUT requests when using this transport handler for a source (optional)
Example
PQL
Code Block |
---|
theme | Eclipse |
---|
language | javascript |
---|
title | HTTP Transport Handler |
---|
linenumbers | true |
---|
|
input = ACCESS({source='Source',
wrapper='GenericPull',
transport='HTTP',
protocol='CSV',
dataHandler='Tuple',
options=[['uri', 'http://www.example.com'], ['method', 'get']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='HTTP',
protocol='CSV',
dataHandler='Tuple',
options=[['uri', 'http://www.example.com'], ['method', 'post']]
}, input) |
CQL
Code Block |
---|
theme | Eclipse |
---|
language | sql |
---|
title | HTTP Transport Handler |
---|
linenumbers | true |
---|
|
CREATE STREAM source (id Double, data STRING)
WRAPPER 'GenericPush'
PROTOCOL 'CSV'
TRANSPORT 'HTTP'
DATAHANDLER 'Tuple'
OPTIONS ( 'uri' 'http://www.example.com' 'method' 'get')
CREATE SINK sink (id Double, data STRING)
WRAPPER 'GenericPush'
PROTOCOL 'CSV'
TRANSPORT 'HTTP'
DATAHANDLER 'Tuple'
OPTIONS ( 'uri' 'http://www.example.com' 'method' 'post')
|