[
https://issues.apache.org/jira/browse/EAGLE-1046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085195#comment-16085195
]
ASF GitHub Bot commented on EAGLE-1046:
---------------------------------------
Github user asfgit closed the pull request at:
https://github.com/apache/eagle/pull/963
> Eagle supports policies import to a new site from a policy prototype
> --------------------------------------------------------------------
>
> Key: EAGLE-1046
> URL: https://issues.apache.org/jira/browse/EAGLE-1046
> Project: Eagle
> Issue Type: New Feature
> Affects Versions: v0.6.0
> Reporter: Zhao, Qingwen
> Assignee: Jilin, Jiang
>
> 0. policy prototype entity
> {code}
> String name
> PolicyDefinition definition
> List<String> alertPublishmentIds
> {code}
> 1. load a list of policies to new site "sandbox" from policy prototypes by
> {{POST /rest/policyProto/export/sandbox}}
> {code}
> [ { "definition": {
> "name": "JobRpcThroughput",
> "description": "Policy for
> MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "inputStreams": [
> "MAP_REDUCE_JOB_STREAM"
> ],
> "outputStreams": [
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT"
> ],
> "siteId": null,
> "definition": {
> "type": "siddhi",
> "value": "from MAP_REDUCE_JOB_STREAM[mapOpsPerSecond >
> 1000 or reduceOpsPerSecond > 1000 or avgOpsPerMapTask > 50 or
> avgOpsPerReduceTask > 50] select * insert into
> MAP_REDUCE_JOB_STREAM_RPC_THROUGHPUT_OUT;",
> "handlerClass": null,
> "properties": {},
> "inputStreams": [],
> "outputStreams": []
> },
> "stateDefinition": null,
> "policyStatus": "DISABLED",
> "alertDefinition": {
> "templateType": "TEXT",
> "subject": "$site job rpc",
> "body": "$site job rpc throughput",
> "severity": "WARNING",
> "category": "JPM"
> },
> "alertDeduplications": [
> {
> "outputStreamId":
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "dedupIntervalMin": "0",
> "dedupFields": []
> }
> ],
> "partitionSpec": [
> {
> "streamId": "MAP_REDUCE_JOB_STREAM_SANDBOX",
> "type": "SHUFFLE",
> "columns": [],
> "sortSpec": null
> }
> ],
> "dedicated": false,
> "parallelismHint": 5,
> "alertSeverity": "WARNING",
> "alertCategory": "JPM"
> },
> "alertPublishmentIds": []
> }
> ]
> {code}
> 2. create a new policy prototype with an existing policy by {{ POST
> /rest/policyProto/import}}
> {code}
> { "definition": {
> "name": "JobRpcThroughput",
> "description": "Policy for
> MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "inputStreams": [
> "MAP_REDUCE_JOB_STREAM_SANDBOX"
> ],
> "outputStreams": [
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT"
> ],
> "siteId": "sandbox",
> "definition": {
> "type": "siddhi",
> "value": "from MAP_REDUCE_JOB_STREAM_SANDBOX[mapOpsPerSecond >
> 1000 or reduceOpsPerSecond > 1000 or avgOpsPerMapTask > 50 or
> avgOpsPerReduceTask > 50] select * insert into
> MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT;",
> "handlerClass": null,
> "properties": {},
> "inputStreams": [],
> "outputStreams": []
> },
> "stateDefinition": null,
> "policyStatus": "DISABLED",
> "alertDefinition": {
> "templateType": "TEXT",
> "subject": "$site job rpc",
> "body": "$site job rpc throughput",
> "severity": "WARNING",
> "category": "JPM"
> },
> "alertDeduplications": [
> {
> "outputStreamId":
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "dedupIntervalMin": "0",
> "dedupFields": []
> }
> ],
> "partitionSpec": [
> {
> "streamId": "MAP_REDUCE_JOB_STREAM_SANDBOX",
> "type": "SHUFFLE",
> "columns": [],
> "sortSpec": null
> }
> ],
> "dedicated": false,
> "parallelismHint": 5,
> "alertSeverity": "WARNING",
> "alertCategory": "JPM"
> },
> "alertPublishmentIds": []
> }
> {code}
> 3. update or create a policy prototype by by {{ POST /rest/policyProto}}
> {code}
> {
> "policyProto": {
> "name": "JobRpcThroughput",
> "description": "Policy for
> MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "inputStreams": [
> "MAP_REDUCE_JOB_STREAM"
> ],
> "outputStreams": [
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT"
> ],
> "siteId": null,
> "definition": {
> "type": "siddhi",
> "value": "from MAP_REDUCE_JOB_STREAM[mapOpsPerSecond > 1000
> or reduceOpsPerSecond > 1000 or avgOpsPerMapTask > 50 or avgOpsPerReduceTask
> > 50] select * insert into MAP_REDUCE_JOB_STREAM_RPC_THROUGHPUT_OUT;",
> "handlerClass": null,
> "properties": {},
> "inputStreams": [],
> "outputStreams": []
> },
> "stateDefinition": null,
> "policyStatus": "DISABLED",
> "alertDefinition": {
> "templateType": "TEXT",
> "subject": "$site job rpc",
> "body": "$site job rpc throughput",
> "severity": "WARNING",
> "category": "JPM"
> },
> "alertDeduplications": [
> {
> "outputStreamId":
> "MAP_REDUCE_JOB_STREAM_SANDBOX_RPC_THROUGHPUT_OUT",
> "dedupIntervalMin": "0",
> "dedupFields": []
> }
> ],
> "partitionSpec": [
> {
> "streamId": "MAP_REDUCE_JOB_STREAM_SANDBOX",
> "type": "SHUFFLE",
> "columns": [],
> "sortSpec": null
> }
> ],
> "dedicated": false,
> "parallelismHint": 5,
> "alertSeverity": "WARNING",
> "alertCategory": "JPM"
> },
> "alertPublishmentIds": []
> }
> {code}
> 4. get all policy prototypes by {{GET /rest/policyProto}}
> 5. delete a policy prototype by {{ DELETE /rest/policyProto/\{uuid\} }}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
