1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
function launch_etl_jobs($server, $project, $name, $variables)
{
$serverstring='http://' . $server . ':7775/etlserver/services/ETL-Server?wsdl';
try
{
$server = @new SoapClient($serverstring, array('exceptions' => true) );
$type = "jobs";
$locator = "$project.$type.$name";
// Check wether the job is already queued
$p = array("project" => $project, "type" => $type, "name" => $name, "after" => doubleval(0), "before" => doubleval(0), "status" => "0");
$response = $server->getExecutionHistory($p);
$return = $response->return;
if(count($return) > 0)
{
echo "Job is already queued!";
}
else
{
// Check wether job is already running
$p = array("project" => $project, "type" => $type, "name" => $name, "after" => doubleval(0), "before" => doubleval(0), "status" => "5");
$response = $server->getExecutionHistory($p);
$return = $response->return;
if(count($return) > 0) {
echo "Job is running!";
}
else
{
// Everything ok - add and start job
$response = $server->addExecution(array('locator' => $locator, 'variables' => $variables));
$return = $response->return;
// Check whether there was an error on job initialisation
$valid = $return->valid;
if (!$valid)
{
echo $return->errorMessage;
}
$id = $return->id;
// Execute job
$response = $server->runExecution(array('id' => $id));
$return = $response->return;
// Check wether there was an error on execution
$p = array("project" => $project, "type" => $type, "name" => $name, "after" => doubleval(0), "before" => doubleval(0), "status" => "40");
$response = $server->getExecutionHistory($p);
$return = $response->return;
echo $return;
}
}
}
catch (SoapFault $fault)
{
echo "SOAP Fault: (faultcode: {$fault->faultcode}, faultstring: {$fault->faultstring})";
}
catch (Exception $e)
{
echo $e->getMessage();
}
}
|