...
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)chunked
: Controls the 'chunked' header (see Chunked transfer encoding). (default: true) (optional)scheduler.delay
: If you want to query in a given time-interval. The unit are milliseconds.oneDocPerCall
: If set to false, the transport handler assumes an endless stream. If set to false, assumes whole documents per call- contenttype: Set the Content-Type int he HTTP header
Example
PQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
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) /// Example for the scheduler.delay option #PARSER PQL #ADDQUERY web = ACCESS({ source='Google', wrapper='GenericPull', transport='HTTP', protocol='Document', datahandler='Document', options=[ ['uri', 'http://google.com'], ['scheduler.delay','1000'], ['oneDocPerCall','true'] ] } ) |
...