summaryrefslogtreecommitdiffstats
path: root/dpo
diff options
context:
space:
mode:
Diffstat (limited to 'dpo')
-rw-r--r--dpo/commands17
-rw-r--r--dpo/dmaap.json18
-rw-r--r--dpo/tcaInput.json14
-rw-r--r--dpo/tcaOutput.json63
-rw-r--r--dpo/tcaSpec.json223
5 files changed, 335 insertions, 0 deletions
diff --git a/dpo/commands b/dpo/commands
new file mode 100644
index 0000000..29e8507
--- /dev/null
+++ b/dpo/commands
@@ -0,0 +1,17 @@
+unset http_proxy; unset https_proxy
+
+dcae_cli data_format add --update tcaInput.json
+dcae_cli data_format add --update tcaOutput.json
+dcae_cli component add --update tcaSpec.json
+dcae_cli component run --dmaap-file dmaap.json --force --additional-user USER cdap.tca.hi.lo.app
+
+# publish
+dcae_cli data_format publish "TCA Alert Definition"
+
+# to un-deploy
+dcae_cli component undeploy cdap.tca.hi.lo.app
+
+# to inspect
+dcae_cli component show cdap.tca.hi.lo.app
+dcae_cli component list
+dcae_cli component list --deployed \ No newline at end of file
diff --git a/dpo/dmaap.json b/dpo/dmaap.json
new file mode 100644
index 0000000..8bb4dd5
--- /dev/null
+++ b/dpo/dmaap.json
@@ -0,0 +1,18 @@
+{
+ "tca_handle_in": {
+ "aaf_username": "USER",
+ "aaf_password": "PASSWORD",
+ "type": "message_router",
+ "dmaap_info": {
+ "topic_url": "https://HOSTNAME:3905/events/com.att.dcae.dmaap.mtnje2.DcaeTestVESSub"
+ }
+ },
+ "tca_handle_out": {
+ "aaf_username": "USER",
+ "aaf_password": "PASSWORD",
+ "type": "message_router",
+ "dmaap_info": {
+ "topic_url": "https://HOSTNAME:3905/events/com.att.dcae.dmaap.mtnje2.DcaeTestVESPub"
+ }
+ }
+}
diff --git a/dpo/tcaInput.json b/dpo/tcaInput.json
new file mode 100644
index 0000000..0d5a81a
--- /dev/null
+++ b/dpo/tcaInput.json
@@ -0,0 +1,14 @@
+{
+ "self": {
+ "name": "Common Event Format Definition",
+ "version": "25.0.0",
+ "description": "Common Event Format Definition"
+
+ },
+ "dataformatversion": "1.0.0",
+ "reference": {
+ "name": "Common Event Format",
+ "format": "JSON",
+ "version": "25.0.0"
+ }
+} \ No newline at end of file
diff --git a/dpo/tcaOutput.json b/dpo/tcaOutput.json
new file mode 100644
index 0000000..03c836f
--- /dev/null
+++ b/dpo/tcaOutput.json
@@ -0,0 +1,63 @@
+{
+ "self": {
+ "name": "TCA Alert Definition",
+ "version": "1.0.0",
+ "description": "The format of the output event from TCA"
+ },
+ "dataformatversion": "1.0.0",
+ "jsonschema": {
+ "name": "TCA Alert",
+ "version": "1.0.0",
+ "properties": {
+ "closedLoopControlame": {
+ "type": "string"
+ },
+ "version": {
+ "type": "string"
+ },
+ "requestID": {
+ "type": "string"
+ },
+ "closedLoopAlarmStart": {
+ "type": "string"
+ },
+ "closedLoopEventClient": {
+ "type": "string"
+ },
+ "target_type": {
+ "type": "string",
+ "enum": [ "VNF", "VM" ]
+ },
+ "target": {
+ "type": "string",
+ "enum": [ "generic-vnf.vnf-id", "vserver.vserver-name" ]
+ },
+ "AAI": {"anyOf": [
+ {"generic-vnf.vnf-id": {
+ "type": "string"
+ }},
+ {"vserver.vserver-name" : {
+ "type": "string"
+ }}]
+ },
+ "from": {
+ "type": "string",
+ "enum": [ "DCAE" ]
+ },
+ "policyScope": {
+ "type": "string"
+ },
+ "policyName": {
+ "type": "string"
+ },
+ "policyVersion": {
+ "type": "string"
+ },
+ "closedLoopEventStatus": {
+ "type": "string",
+ "enum": [ "ONSET" ]
+ }
+
+ }
+ }
+} \ No newline at end of file
diff --git a/dpo/tcaSpec.json b/dpo/tcaSpec.json
new file mode 100644
index 0000000..4b3a5c9
--- /dev/null
+++ b/dpo/tcaSpec.json
@@ -0,0 +1,223 @@
+{
+ "self": {
+ "name": "cdap.tca.hi.lo.app",
+ "version": "1.0.2",
+ "description": "cdap tca hi lo application",
+ "component_type": "cdap"
+ },
+ "streams": {
+ "subscribes": [{
+ "config_key": "tca_handle_in",
+ "format": "Common Event Format Definition",
+ "version": "25.0.0",
+ "type": "message router"
+ }
+ ],
+ "publishes": [{
+ "config_key": "tca_handle_out",
+ "format": "TCA Alert Definition",
+ "version": "1.0.0",
+ "type": "message router"
+ }
+ ]
+ },
+ "services": {
+ "calls": [],
+ "provides": []
+ },
+ "auxilary": {
+ "streamname": "TCASubscriberOutputStream",
+ "artifact_name": "dcae-analytics-tca",
+ "artifact_version": "1.1.0",
+ "programs": [{
+ "program_type": "flows",
+ "program_id": "TCAVESCollectorFlow"
+ }, {
+ "program_type": "workers",
+ "program_id": "TCADMaaPMRSubscriberWorker"
+ }, {
+ "program_type": "workers",
+ "program_id": "TCADMaaPMRPublisherWorker"
+ }
+ ],
+ "namespace": "cdap_tca_hi_lo"
+ },
+ "artifacts": [{
+ "uri": "${nexusproxy}/repository/dcae-dev-raw/jar_files/dcae-analytics-tca-1.1.0.jar",
+ "type": "jar"
+ }
+ ],
+ "parameters": {
+ "app_config": [{
+ "name": "appName",
+ "description": "",
+ "value": "dcae-tca"
+ }, {
+ "name": "appDescription",
+ "description": "",
+ "value": "DCAE Analytics Threshold Crossing Alert Application"
+ }, {
+ "name": "tcaSubscriberOutputStreamName",
+ "description": "",
+ "value": "TCASubscriberOutputStream"
+ }, {
+ "name": "thresholdCalculatorFlowletInstances",
+ "description": "",
+ "value": 2
+ }, {
+ "name": "tcaVESMessageStatusTableName",
+ "description": "",
+ "value": "TCAVESMessageStatusTable"
+ }, {
+ "name": "tcaVESMessageStatusTableTTLSeconds",
+ "description": "",
+ "value": 86400
+ }, {
+ "name": "tcaVESAlertsTableName",
+ "description": "",
+ "value": "TCAVESAlertsTable"
+ }, {
+ "name": "tcaVESAlertsTableTTLSeconds",
+ "description": "",
+ "value": 1728000
+ }
+ ],
+ "app_preferences": [{
+ "name": "subscriberContentType",
+ "description": "",
+ "value": "application/json"
+ }, {
+ "name": "subscriberConsumerId",
+ "description": "",
+ "value": "c12"
+ }, {
+ "name": "subscriberConsumerGroup",
+ "description": "",
+ "value": "OpenDCAE-c12"
+ }, {
+ "name": "subscriberTimeoutMS",
+ "description": "",
+ "value": -1
+ }, {
+ "name": "subscriberMessageLimit",
+ "description": "",
+ "value": -1
+ }, {
+ "name": "subscriberPollingInterval",
+ "description": "",
+ "value": 20000
+ }, {
+ "name": "publisherContentType",
+ "description": "",
+ "value": "application/json"
+ }, {
+ "name": "publisherMaxBatchSize",
+ "description": "",
+ "value": 10
+ }, {
+ "name": "publisherMaxRecoveryQueueSize",
+ "description": "",
+ "value": 100000
+ }, {
+ "name": "publisherPollingInterval",
+ "description": "",
+ "value": 20000
+ }, {
+ "name": "tca_policy",
+ "description": "",
+ "value":
+ "'{\"domain\":\"measurementsForVfScaling\",\"metricsPerFunctionalRole\":[{\"functionalRole\":\"vFirewall\",\"policyScope\":\"resource=vFirewall;type=configuration\",\"policyName\":\"configuration.dcae.microservice.tca.xml\",\"policyVersion\":\"v0.0.1\",\"thresholds\":[{\"closedLoopControlName\":\"CL-FRWL-LOW-TRAFFIC-SIG-d925ed73-8231-4d02-9545-db4e101f88f8\",\"version\":\"1.0.2\",\"fieldPath\":\"$.event.measurementsForVfScalingFields.vNicUsageArray[*].bytesIn\",\"thresholdValue\":4000,\"direction\":\"LESS_OR_EQUAL\",\"severity\":\"MAJOR\"},{\"closedLoopControlName\":\"CL-FRWL-HIGH-TRAFFIC-SIG-EA36FE84-9342-5E13-A656-EC5F21309A09\",\"version\":\"1.0.2\",\"fieldPath\":\"$.event.measurementsForVfScalingFields.vNicUsageArray[*].bytesIn\",\"thresholdValue\":20000,\"direction\":\"GREATER_OR_EQUAL\",\"severity\":\"CRITICAL\"}]},{\"functionalRole\":\"vLoadBalancer\",\"policyScope\":\"resource=vLoadBalancer;type=configuration\",\"policyName\":\"configuration.dcae.microservice.tca.xml\",\"policyVersion\":\"v0.0.1\",\"thresholds\":[{\"closedLoopControlName\":\"CL-LBAL-LOW-TRAFFIC-SIG-FB480F95-A453-6F24-B767-FD703241AB1A\",\"version\":\"1.0.2\",\"fieldPath\":\"$.event.measurementsForVfScalingFields.vNicUsageArray[*].packetsIn\",\"thresholdValue\":500,\"direction\":\"LESS_OR_EQUAL\",\"severity\":\"MAJOR\"},{\"closedLoopControlName\":\"CL-LBAL-LOW-TRAFFIC-SIG-0C5920A6-B564-8035-C878-0E814352BC2B\",\"version\":\"1.0.2\",\"fieldPath\":\"$.event.measurementsForVfScalingFields.vNicUsageArray[*].packetsIn\",\"thresholdValue\":5000,\"direction\":\"GREATER_OR_EQUAL\",\"severity\":\"CRITICAL\"}]}]}'"
+ }
+ ],
+ "program_preferences": [],
+
+ "policy_parameters": [{
+ "name": "domain",
+ "description": "",
+ "type": "string",
+ "value": "measurementsForVfScaling",
+ "constraints":
+ [{
+ "equal": "measurementsForVfScaling"
+ }
+ ]
+ }, {
+ "name": "metricsPerFunctionalRole",
+ "description": "",
+ "type": "list",
+ "entry_schema":
+ [{
+ "name": "functionalRole",
+ "description": "Function of the event source e.g., eNodeB, MME, PCRF",
+ "type": "string",
+ "value": ""
+ }, {
+ "name": "policyScope",
+ "description": "Policy Scope associated with this event.For example-resource=vFirewall;type=configuration",
+ "type": "string",
+ "value": ""
+ }, {
+ "name": "policyName",
+ "description": "Policy name/ID for this event",
+ "type": "string",
+ "value": "configuration.dcae.microservice.tca.xml"
+ }, {
+ "name": "policyVersion",
+ "description": "Policy Version",
+ "type": "string",
+ "value": "v0.0.1"
+ }, {
+ "name": "thresholds",
+ "description": "",
+ "type": "list",
+ "entry_schema":
+ [{
+ "name": "closedLoopControlName",
+ "description": "A UNIQUE string identifying the Closed Loop ID this event is for.",
+ "type": "string",
+ "value": ""
+ }, {
+ "name": "version",
+ "description": "Version for the closed loop message",
+ "type": "string",
+ "value": ""
+ }, {
+ "name": "fieldPath",
+ "description": "",
+ "type": "string",
+ "value": ""
+ }, {
+ "name": "thresholdValue",
+ "description": "",
+ "type": "number",
+ "value": ""
+ }, {
+ "name": "direction",
+ "description": "",
+ "type": "string",
+ "value": "",
+ "constraints":
+ [{
+ "valid_value":
+ ["LESS", "LESS_OR_EQUAL", "GREATER", "GREATER_OR_EQUAL"]
+ }
+ ]
+ }, {
+ "name": "severity",
+ "description": "event severity or priority",
+ "value": "",
+ "type": "string",
+ "constraints":
+ [{
+ "valid_value":
+ ["CRITICAL", "MAJOR", "MINOR", "WARNING", "NORMAL"]
+ }
+ ]
+ }
+ ]
+ }
+ ]
+ }
+ ]
+ }
+}