Server
Overview
Provides web service calls related to servers, such as allocating sockets and ports, getting the list of slaves and registering them, and displaying the initial Carte page.
Provides web service calls related to servers, such as allocating sockets and ports, getting the list of slaves and registering them, and displaying the initial Carte page.
You will need to modify the example URLs if you are working with the PDI server instead of a standalone Carte server.
The following resources are applicable:
- /
- /kettle/allocateSocket
- /kettle/listSocket
- /kettle/nextSequence
- /kettle/registerSlave
- /kettle/getSlaves
- /kettle/status
/
Overview
Displays initial Carte page.
GET
Displays initial Carte page.
Example Request:
GET /
Response Body
element: | (custom) |
media types: | text/html |
HTML response containing content of initial page is returned.
Example Response:
<html> <head><title>Kettle slave server</title> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/> </head> <body> <h2>Slave server menu</h2> <p><a href="/kettle/status">Show status</a><br><p> </body> </html>
Status Codes
code | description |
---|---|
200 | Request was processed. |
500 | Internal server error occurs during request processing. |
/kettle/allocateSocket
Overview
Allocates port for client to use.
GET
Allows any client to ask for a port number to use. This is necessary several slaves can be run on the same host. The method ensures the port number is unique for host name provided and makes sure the slaves are using valid port numbers. Data communication across a cluster of Carte servers happens through TCP/IP sockets. Slave transformations sometimes open (or listen to) tens to hundreds of sockets. When you want to allocate the port numbers for data communication between slave transformation in a kettle clustering run, you need unique combinations of all the parameters below. port number
will be returned in the Response object. If an error occurred you'll receive html output describing the problem. HTTP status code of such response is 500.
Example Request:
GET /kettle/allocateSocket/?xml=Y&rangeStart=100&host=locahost&id=clust&trans=my_trans&sourceSlave=slave_1 &sourceStep=200&sourceCopy=1&targetSlave=slave_2&targetStep=50&targetCopy=1
Parameters
name | description | type |
---|---|---|
xml | Boolean flag set to either Y or N describing if xml or html reply should be produced. | boolean, optional |
rangeStart | Port number to start looking from. | integer |
host | Port's host. | query |
id | Carte container id. | query |
trans | Running transformation id. | query |
sourceSlave | Name of the source slave server. | query |
sourceStep | Port number step used on source slave server. | integer |
sourceCopy | Number of copies of the step on source server. | integer |
targetSlave | Name of the target slave server. | query |
targetStep | Port number step used on target slave server. | integer |
targetCopy | Number of copies of the step on target server. | integer |
Response Body
element: | (custom) |
media types: | text/xml, text/html |
Response wraps port number that was allocated or error stack trace if an error occurred. Response HTTP code is 200 if there were no errors. Otherwise it is 500.
Example Response:
<port>100</port>
/kettle/listSocket
Overview
Gets list of ports for specified host.
GET
Gets list of ports for specified host. Method is used for listing all or just open ports for specified host. Response contains port number, which transformation it is (was) used for, current status of the port and last date time used.
Example Request:
GET /kettle/listSocket/?host=127.0.0.1
Parameters
name | description | type |
---|---|---|
host | Host to get ports for. | query |
onlyOpen | Boolean flag that indicates whether all or only open ports should be returned. Set it to Y to get the list of only currently open ports. | boolean, optional |
Response Body
text: | HTML |
media types: | text/html |
Response is HTML document listing the ports requested.
Example Response:
<html> <head><title>List of server sockets on server '127.0.0.1'</title></head> <body> </Found 5 ports for host '127.0.0.1'> <p>8088 : Transformation=dummy-trans, crt/Dummy (do nothing) 2.0 --> sll/Dummy (do nothing).0 id=b20bcd03-9682-4327-8c42-b129faabbfe1, allocated=false time=Mon Nov 17 09:31:15 BRT 2014 8089 : Transformation=dummy-trans, crt/Dummy (do nothing) 2.0 --> sll/Dummy (do nothing).1 id=b20bcd03-9682-4327-8c42-b129faabbfe1, allocated=false time=Mon Nov 17 09:31:15 BRT 2014 8090 : Transformation=dummy-trans, crt/Dummy (do nothing) 2.0 --> sll/Dummy (do nothing).2 id=b20bcd03-9682-4327-8c42-b129faabbfe1, allocated=false time=Mon Nov 17 09:31:15 BRT 2014 8091 : Transformation=dummy-trans, crt/Dummy (do nothing) 2.0 --> sll/Dummy (do nothing).3 id=b20bcd03-9682-4327-8c42-b129faabbfe1, allocated=false time=Mon Nov 17 09:31:15 BRT 2014 8092 : Transformation=dummy-trans, crt/Dummy (do nothing) 2.0 --> sll/Dummy (do nothing).4 id=b20bcd03-9682-4327-8c42-b129faabbfe1, allocated=false time=Mon Nov 17 09:31:15 BRT 2014</p> </body>> </html>>
/kettle/nextSequence
Overview
Increments specified pre-configured sequence.
GET
Increments specified pre-configured sequence. Method is used for reserving a number of IDs and incrementing a sequence pre-configured in Carte server configuration by specified amount. If no increment value provided 10000 is used by default.
Example Request:
GET /kettle/nextSequence?name=test_seq
Parameters
name | description | type |
---|---|---|
name | Name of the sequence specified in Carte configuration file. | query |
increment | Parameter used for incrementing sequence. If no parameter specified 10000 is used by default. | integer, optional |
Response Body
text: | HTML |
media types: | text/xml |
Response XML containing sequence value and the increment value used.
Example Response:
<seq><value>570000</value><increment>10000</increment></seq>
/kettle/registerSlave
Overview
Registers slave server in the master.
POST
Registers slave server in the master. The method is used to add or update information of slave server.
Example Request:
POST /kettle/registerSlave/
Request body should contain xml containing slave server description.
Response Body
element: | (custom) |
media types: | text/xml |
Response contains slave server name or error stack trace if an error occurred. Response has result
OK if there were no errors. Otherwise it returns ERROR.
Example Response:
<SlaveServerDetection> <slaveserver> <name>Dynamic slave</name> <hostname>localhost</hostname> <port>901</port> <webAppName/> <username>cluster</username> <password>Encrypted 2be98afc86aa7f2e4cb1aa265cd86aac8</password> <proxy_hostname/> <proxy_port/> <non_proxy_hosts/> <master>N</master> </slaveserver> <active>Y</active> <last_active_date/> <last_inactive_date/> </SlaveServerDetection>
/kettle/getSlaves
Overview
Gets list of slave servers.
GET
Gets list of slave servers. Retrieves list of slave servers which are known to specific server.
Example Request:
GET /kettle/getSlaves
Response Body
element: | (custom) |
media types: | text/xml |
Response contains list of slave servers.
Example Response:
<slaveserverdetections> <slaveserverdetection> <slaveserver> <name>Dynamic slave [localhost:909]</name><hostname>localhost</hostname><port>909</port> <webappname/><username>cluster</username><password>Encrypted 2be98afc86aa7f2e4cb1aa265cd86aac8</password> <proxy_hostname/><proxy_port/><non_proxy_hosts/><master>N</master> </slaveserver> <active>Y</active> <last_active_date>2014/11/17 06:42:28.043</last_active_date> <last_inactive_date>2014/11/17 06:42:27.372</last_inactive_date> </slaveserverdetection> </slaveserverdetections>
/kettle/status
Overview
Retrieves server status.
GET
Retrieves server status. The status contains information about the server itself (OS, memory, etc) and information about jobs and transformations present on the server.
Example Request:
GET /kettle/status/?xml=Y
Parameters
name | description | type |
---|---|---|
xml | Boolean flag which defines output format Y forces XML output to be generated. HTML is returned otherwise. | boolean, optional |
Response Body
element: | (custom) |
media types: | text/xml, text/html |
Response XML or HTML response containing details about the transformation specified. If an error occurs during method invocation result
field of the response will contain ERROR
status.
Example Response:
<serverstatus> <statusdesc>Online</statusdesc> <memory_free>229093440</memory_free> <memory_total>285736960</memory_total> <cpu_cores>4</cpu_cores> <cpu_process_time>7534848300</cpu_process_time> <uptime>68818403</uptime> <thread_count>45</thread_count> <load_avg>-1.0</load_avg> <os_name>Windows 7</os_name> <os_version>6.1</os_version> <os_arch>amd64</os_arch> <transstatuslist> <transstatus> <transname>Row generator test</transname> <id>56c93d4e-96c1-4fae-92d9-d864b0779845</id> <status_desc>Waiting</status_desc> <error_desc/> <paused>N</paused> <stepstatuslist> </stepstatuslist> <first_log_line_nr>0</first_log_line_nr> <last_log_line_nr>0</last_log_line_nr> <logging_string><![CDATA[]]></logging_string> </transstatus> <transstatus> <transname>dummy-trans</transname> <id>c56961b2-c848-49b8-abde-76c8015e29b0</id> <status_desc>Stopped</status_desc> <error_desc/> <paused>N</paused> <stepstatuslist> </stepstatuslist> <first_log_line_nr>0</first_log_line_nr> <last_log_line_nr>0</last_log_line_nr> <logging_string><![CDATA[]]></logging_string> </transstatus> </transstatuslist> <jobstatuslist> <jobstatus> <jobname>dummy_job</jobname> <id>abd61143-8174-4f27-9037-6b22fbd3e229</id> <status_desc>Stopped</status_desc> <error_desc/> <logging_string><![CDATA[]]></logging_string> <first_log_line_nr>0</first_log_line_nr> <last_log_line_nr>0</last_log_line_nr> </jobstatus> </jobstatuslist> </serverstatus>
Status Codes
code | description |
---|---|
200 | Request was processed. |
500 | Internal server error occurs during request processing. |