Go to Workflow API for a detailed view of the different requests
Easy Heading Free | ||||
---|---|---|---|---|
|
The following steps will create a new workflow and then add a single Elasticsearch Publisher (In Progress) to the onPublish event.
Request
Saga_json | ||
---|---|---|
| ||
{ "description": "ES Workflow" } |
Response
Saga_json |
---|
{ "workflow": [ { "id": "9bdf3efb-c266-46ac-ab59-eb8eda87d9e9", "type": "connector", "description": "Test Workflow", "checksum": "e143d076aab367368474087d6ebf1d90377405b7c8ab227f5cb835380e6ccc4f", "templates": { "template": [ { "id": "add-static-acl", "type": "script", "description": "Add static ACLs", "ruleDescription": "Static ACL: Domain:\"${domain}\" Name:\"${name}\" Type:\"${entity}\" Access:\"${access}\"", ... }, ... ] }, "events": { "event": [ { "id": "onScan" }, { "id": "onAddUpdate" }, { "id": "onDelete" }, { "id": "onPublish" }, { "id": "onError" }, { "id": "onIdentity" }, { "id": "onIdentityError" } ] } } ] } |
Note |
---|
Notice that by default when a new Workflow is created, all templates and events are added to it so they can be used to create different sets of rules. |
Request
Saga_json | ||
---|---|---|
| ||
{
"type": "application",
"description": "Elastic",
"config": "com.accenture.aspire:aspire-elasticsearch-publisher-source",
"appType": "elasticsearch-publisher",
"appName": "Elasticsearch Publisher",
"properties": {
"elasticNoUrl": false,
"elasticUrl": "http://localhost:9200/_bulk",
"elasticIndex": "index2",
"authType": "none",
"transformType": "JSON",
"transformFile": "${component.home}/config/groovy/transform.groovy",
"processClear": true,
"deleteOnClear" : true,
"connectionTimeout": 15000,
"readTimeout": 15000,
"maxRetries": 1,
"retryDelay": 15000,
"maxRetryDelay": 200000,
"retryDelayMultiplier": 1,
"maxResults": 1000000,
"pageSize": 10000,
"idField": "hits._id",
"urlField": "hits.fields.url",
"timestampField": "hits.fields.submitTime",
"debug": false
}
} |
Response
Saga_json |
---|
{
"workflow": {
"id": "9bdf3efb-c266-46ac-ab59-eb8eda87d9e9",
"type": "connector",
"description": "Test Workflow",
"checksum": "1b45ac011d1d489a880e3700b93ec07ff2c192e15f360befd00c952e127b05a6",
"rule": {
"type": "application",
"description": "Elastic",
"config": "com.accenture.aspire:aspire-elasticsearch-publisher-source",
"appType": "elasticsearch-publisher",
"appName": "Elasticsearch_Publisher",
"properties": {
"elasticNoUrl": false,
"elasticUrl": "http://localhost:9200/_bulk",
"elasticIndex": "index2",
"authType": "none",
"transformType": "JSON",
"transformFile": "${component.home}/config/groovy/transform.groovy",
"processClear": true,
"deleteOnClear": true,
"connectionTimeout": 15000,
"readTimeout": 15000,
"maxRetries": 1,
"retryDelay": 15000,
"maxRetryDelay": 200000,
"retryDelayMultiplier": 1,
"maxResults": 1000000,
"pageSize": 10000,
"idField": "hits._id",
"urlField": "hits.fields.url",
"timestampField": "hits.fields.submitTime",
"debug": false
},
"id": "64416781-7158-4c39-a862-f075bfc61444"
}
}
} |