The following example demonstrates submitting a new workflow.

Assuming a model exists 'average_rainfall' with ports ['startdate', 'enddate', 'rainfall', 'average_rainfall']

Example CreateWorkflowRequest

{
"name": "A useful name for the workflow",
"description": "A detailed description...",
"organisationid": "csiro",
"groupids": ["my_group"],
"runas": { "roles": [ "my_group_role" ] }
"graph": {
"nodes" : [
{
"id" : "average_rainfall_model",
"modelid" : "average_rainfall"
},
{
"id" : "startdate_node",
"documentid" : "existing_document_datanode_id"
},
{

"id" : "enddate_node",
"value": "2017-01-01T10:00:00.0000Z"
},
{
"id" : "rainfall_node",
"streamid" : "rainfall.stream.123"
},
{
"id" : "average_rainfall_node",
"streamid" : "sensorcloud.average.rainfall.stream.id"
}]
"connections" : [
{
"source" : { "node": "startdate_node" },
"target" : { "node": "average_rainfall_model", "port": "startdate"}
},
{

"source" : { "node": "enddate_node" },
"target" : { "node": "average_rainfall_model", "port": "enddate"}
},
{
"source" : { "node": "rainfall_node" },
"target" : { "node": "average_rainfall_model", "port": "rainfall"}
},
{
"source" : { "node": "average_rainfall_model", "port": "average_rainfall"}
"target" : { "node": "average_rainfall_node" },
}]
}
}

Explanation:

• runas: provides the authorisation context for the workflow. If omitted, the requesting user's roles will be assigned to the workflow instead.* startdate_node: connects an existing document datanode by id.
• enddate_node: creates a new document datanode using the provided value.
• rainfall_node: connects an existing stream.
• average_rainfall_node: provides a destination output node for the model.

  1. NOTE: if a stream datanode already exists with the same streamid, it will reuse the existing datanode without creating a new stream datanode.

MAP Operations:

• An operator node can be 'mapped' to apply an operator to all elements of a collection, potentially in parallel.
• To 'map' an operator node, add the 'type: map' property. For the above example: { "id": "average_rainfall_model", "modelid": "average_rainfall", "type": "map" }
• For more detail, see the Analysis Service tutorial document: https://senaps.eratos.com/dashboard/pdf/analysis-api-tutorial.pdf