Versions Compared

Old Version 9

changes.mady.by.user Stavros Kanarakis

Saved on

compared with

New Version Current

changes.mady.by.user Stavros Kanarakis

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Βlueprint component file can be found in

  https://gerrit.onap.org/r/gitweb?p=dcaegen2/services.git;a=blob_plain;f=components/bbs-event-processor/dpo/blueprints/k8s-bbs-event-processor.yaml-template;hb=refs/heads/masterdublin
Blueprint inputs file can be found in
  https://gerrit.onap.org/r/gitweb?p=dcaegen2/services.git;a=blob_plain;f=components/bbs-event-processor/dpo/blueprints/bbs-event-processor-input.yaml;h=f503eb823160aa7d2aae763d322818227f0f00b7;hb=refs/heads/masterdublin

Docker image metadata for component can be found in

  https://nexus3.onap.org/repository/docker.snapshot/v2/onap/org.onap.dcaegen2.services.components.bbs-event-processor/manifests/1.0.0-SNAPSHOT

Deployment Prerequisite/dependencies

...

To perform functional tests for BBS-ep, we must first populate test data to A&AI. This can be done by running the following Postman collection along with the required input file.

Postman Collection

View file
nameBBS-ep-test-data.postman_collection.json
height150

JSON Input

View file
namebbs-ep-test-data-inputs.json
height150

Import the Collection JSON file into Postman and then execute it via the Runner utility after changing appropriately the external test-data input (for example give the appropriate A&AI IP address)

...

Code Block
languagebash
themeMidnight
titleTrigger a PNF re-registration eventFetch events from DCAE_CL_OUTPUT topic
linenumberstrue
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar

CPE authentication handling

Send a triggering event to DMaaP topic 'unauthenticated.CPE_AUTHENTICATION

Before sending, make sure you have the

  • Correct DMaaP address
  • sourceName matches the 'pnf-name' in test data
  • macAddress matches the 'rgw-mac-address' in test data


Code Block
languagebash
themeMidnight
titleTrigger a PNF re-registration Published event
linenumberstrue
[
"{\"closedLoopEventClient\":\"DCAE.BBS_event_processor_mSInstance\",\"policyVersion\":\"1.0.0.5\",\"policyName\":\"Nomadic_ONT\",\"policyScope\":\"policyScope\",\"target_type\":\"VM\",\"AAI\":{\"attachmentPoint\":\"olt11-1-1\",\"service-information.hsia-cfs-service-instance-id\":\"1923eaa8-8ab7-49ef-b4c2-e185efbbe832\",\"cvlan\":\"1005\",\"svlan\":\"100\",\"remoteId\":\"some-remote-id\"},\"closedLoopAlarmStart\":1556102412,\"closedLoopEventStatus\":\"ONSET\",\"closedLoopControlName\":\"controName\",\"version\":\"1.0.2\",\"target\":\"vserver.vserver-name\",\"requestID\":\"f96abe95-fb8c-4edf-9b9a-4ad922ae5aa9\",\"from\":\"DCAE-bbs-event-processor\"}",
]


CPE authentication handling

Send a triggering event to DMaaP topic 'unauthenticated.CPE_AUTHENTICATION

Before sending, make sure you have the

  • Correct DMaaP address
  • sourceName matches the 'pnf-name' in test data
  • macAddress matches the 'rgw-mac-address' in test data


Code Block
languagebash
themeMidnight
titleTrigger a PNF re-registration event
linenumberstrue
curl -X POST http://10.133.115.190:30227/events/unauthenticated.CPE_AUTHENTICATION -H 'Content-Type: application/json' -d '{
    "event": {curl -X POST http://10.133.115.190:30227/events/unauthenticated_STAVROS_C -H 'Content-Type: application/json' -d '{
    "event": {
        "commonEventHeader": {
            "version": 7.1,
            "eventName": "StateChange_cpe_authentication",
            "domain": "stateChange",
            "eventId": "ab305d54-85b4-a31b-7db2fb6b9e546015",
            "eventType": "applicationNf",
            "sourceId": "",
            "sourceName": "pnf-11",
            "reportingEntityId": "",
            "reportingEntityName": "thirdparty-sdnc-idfromesrrequest",
            "priority": "Normal",
            "startEpochMicrosec": 1.413378172e+15,
            "lastEpochMicrosec": 1.413378172e+15,
            "sequence": 0,
            "internalHeaderFields": {},
            "vesEventListenerVersion": "",
            "timeZoneOffset": ""
        },
        "stateChangeFields"commonEventHeader": {
            "stateChangeFieldsVersionversion": 7.1,
            "oldStateeventName": "outOfServiceStateChange_cpe_authentication",
            "newStatedomain": "inServicestateChange",
            "stateInterfaceeventId": "ab305d54-85b4-a31b-7db2fb6b9e546015",
            "additionalFieldseventType": {"applicationNf",
                "macAddresssourceId": "01:02:03:04:05:06",
            "sourceName": "pnf-11",
            "swVersionreportingEntityId": "1.2.3",
            }
"reportingEntityName": "thirdparty-sdnc-idfromesrrequest",
         }
    }
}'
Code Block
languagebash
themeMidnight
titleLogs showing CPE authentication event handling
linenumberstrue
2019-04-24 10:42:09.513  INFO 1 --- [pipeline-thrd-5] o.o.b.e.p.p.ReRegistrationPipeline"priority": "Normal",
            "startEpochMicrosec": 1.413378172e+15,
       : Process next Re-Registration events
2019-04-24 10:42:09.513  INFO 1 --- [pipeline-thrd-3] o.o.b.e.p.p.CpeAuthenticationPipeline    : Process next CPE Authentication events
2019-04-24 10:42:09.514 DEBUG 1 --- [pipeline-thrd-3] t.DmaapCpeAuthenticationConsumerTaskImpl : Executing task for CPE-Authentication with name "Consume CPE Authentication DMaaP message"
2019-04-24 10:42:09.514 DEBUG 1 --- [pipeline-thrd-5] .p.t.DmaapReRegistrationConsumerTaskImpl : Executing task for Re-Registration with name "Consume Re-registration DMaaP message"
2019-04-24 10:42:09.521 TRACE 1 --- [pipeline-thrd-3] o.o.b.e.p.p.CpeAuthenticationPipeline    : Reactive CPE Authentication pipeline subscribed - Execution started
2019-04-24 10:42:09.525 TRACE 1 --- [pipeline-thrd-5] o.o.b.e.p.p.ReRegistrationPipeline "lastEpochMicrosec": 1.413378172e+15,
            "sequence": 0,
            "internalHeaderFields": {},
            "vesEventListenerVersion": "",
            "timeZoneOffset": ""
        },
        "stateChangeFields": {
            "stateChangeFieldsVersion": 1,
            "oldState": "outOfService",
            "newState": "inService",
            "stateInterface": "",
            "additionalFields": {
                "macAddress": "01:02:03:04:05:06",
                "swVersion": "1.2.3"
            }
        }
    }
}'


Code Block
languagebash
themeMidnight
titleLogs showing CPE authentication event handling
linenumberstrue
2019-04-24 10:42:09.513  INFO 1 --- [pipeline-thrd-5] o.o.b.e.p.p.ReRegistrationPipeline       : Process next Re-Registration events
2019-04-24 10:42:09.513  INFOReactive PNF Re-registration pipeline subscribed - Execution started
2019-04-24 10:42:10.301 TRACE 1 --- [ctor-http-nio-7] CpeAuthenticationDmaapConsumerJsonParser : Event from DMaaP to be parsed: 
{"event":{"commonEventHeader":{"sourceId":"","startEpochMicrosec":1.413378172E15,"eventId":"ab305d54-85b4-a31b-7db2fb6b9e546015","timeZoneOffset":"","reportingEntityId":"","internalHeaderFields":{},"eventType":"applicationNf","priority":"Normal","version":7.1,"reportingEntityName":"thirdparty-sdnc-idfromesrrequest","sequence":0,"domain":"stateChange","lastEpochMicrosec":1.413378172E15,"eventName":"StateChange_cpe_authentication","vesEventListenerVersion":"","sourceName":"pnf-11"},"stateChangeFields":{"additionalFields":{"macAddress":"01:02:03:04:05:06","swVersion":"1.2.3"},"oldState":"outOfService","stateChangeFieldsVersion":1,"stateInterface":"","newState":"inService"}}}
2019-04-24 10:42:10.304 DEBUG 1 --- [ctorpipeline-httpthrd-nio-73] o.o.b.e.p.p.CpeAuthenticationPipeline    : Process next ProcessingCPE Step: Retrieve PNF. Url: (/aai/v14/network/pnfs/pnf/pnf-11?depth=all)
2019-04-24 10:42:10.307  INFO 1 --- [ctor-http-nio-7] o.o.b.e.p.tasks.AaiClientTaskImpl        : Executing task (PNF Retrieval) for retrieving PNF objectAuthentication events
2019-04-24 10:42:09.514 DEBUG 1 --- [pipeline-thrd-3] t.DmaapCpeAuthenticationConsumerTaskImpl : Executing task for CPE-Authentication with name "Consume CPE Authentication DMaaP message"
2019-04-24 10:42:1009.307514 DEBUG 1 --- [ctorpipeline-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Will issue Reactive GET request to URL (/aai/v14/network/pnfs/pnf/pnf-11?depth=all) for object (org.onap.bbs.event.processor.model.PnfAaiObject)thrd-5] .p.t.DmaapReRegistrationConsumerTaskImpl : Executing task for Re-Registration with name "Consume Re-registration DMaaP message"
2019-04-24 10:42:1009.308521 DEBUGTRACE 1 --- [ctorpipeline-httpthrd-nio-73] o.o.b.e.p.utilitiesp.AaiReactiveClientCpeAuthenticationPipeline    : Request:Reactive GET https://10.133.115.190:30233/aai/v14/network/pnfs/pnf/pnf-11?depth=allCPE Authentication pipeline subscribed - Execution started
2019-04-24 10:42:1009.309525 DEBUGTRACE 1 --- [ctorpipeline-httpthrd-nio-75] o.o.b.e.p.utilities.AaiReactiveClientp.ReRegistrationPipeline       : X-FromAppId=bbs Reactive PNF Re-registration pipeline subscribed - Execution started
2019-04-24 10:42:10.309301 DEBUGTRACE 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Accept=application/json
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Authorization=Basic QUFJOkFBSQ==
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Content-Type=application/json
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Real-Time=true
2019-04-24 10:42:10.309CpeAuthenticationDmaapConsumerJsonParser : Event from DMaaP to be parsed: 
{"event":{"commonEventHeader":{"sourceId":"","startEpochMicrosec":1.413378172E15,"eventId":"ab305d54-85b4-a31b-7db2fb6b9e546015","timeZoneOffset":"","reportingEntityId":"","internalHeaderFields":{},"eventType":"applicationNf","priority":"Normal","version":7.1,"reportingEntityName":"thirdparty-sdnc-idfromesrrequest","sequence":0,"domain":"stateChange","lastEpochMicrosec":1.413378172E15,"eventName":"StateChange_cpe_authentication","vesEventListenerVersion":"","sourceName":"pnf-11"},"stateChangeFields":{"additionalFields":{"macAddress":"01:02:03:04:05:06","swVersion":"1.2.3"},"oldState":"outOfService","stateChangeFieldsVersion":1,"stateInterface":"","newState":"inService"}}}
2019-04-24 10:42:10.304 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilitiesp.AaiReactiveClientCpeAuthenticationPipeline    : X-TransactionId=9999 Processing Step: Retrieve PNF. Url: (/aai/v14/network/pnfs/pnf/pnf-11?depth=all)
2019-04-24 10:42:10.934307  DEBUGINFO 1 --- [ctor-http-nio-87] o.o.b.e.p.utilities.AaiReactiveClienttasks.AaiClientTaskImpl        : Response status 200 OK Executing task (PNF Retrieval) for retrieving PNF object
2019-04-24 10:42:10.937307 DEBUG 1 --- [ctor-http-nio-87] o.o.b.e.p.utilities.AaiReactiveClient    : Response body 
{"pnf-name":"pnf-11","in-maint":true,"resource-version":"1551889263181","relationship-list":{"relationship":[{"related-to":"service-instance","relationship-label":"org.onap.relationships.inventory.ComposedOf","related-link":"/aai/v14/business/customers/customer/766162a3-53a9-42b8-8fe2-ebaa2213a6dd/service-subscriptions/service-subscription/BBS-CFS11/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832","relationship-data":[{"relationship-key":"customer.global-customer-id","relationship-value":"766162a3-53a9-42b8-8fe2-ebaa2213a6dd"},{"relationship-key":"service-subscription.service-type","relationship-value":"BBS-CFS11"},{"relationship-key":"service-instance.service-instance-id","relationship-value":"1923eaa8-8ab7-49ef-b4c2-e185efbbe832"}],"related-to-property":[{"property-key":"service-instance.service-instance-name"}]},{"related-to":"logical-link","relationship-label":"org.onap.relationships.inventory.BridgedTo","related-link":"/aai/v14/network/logical-links/logical-link/olt11-11-11","relationship-data":[{"relationship-key":"logical-link.link-name","relationship-value":"olt11-11-11"}]}]}} Will issue Reactive GET request to URL (/aai/v14/network/pnfs/pnf/pnf-11?depth=all) for object (org.onap.bbs.event.processor.model.PnfAaiObject)
2019-04-24 10:42:10.308 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Request: GET https://10.133.115.190:30233/aai/v14/network/pnfs/pnf/pnf-11?depth=all
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : X-FromAppId=bbs
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Accept=application/json
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Authorization=Basic QUFJOkFBSQ==
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : Content-Type=application/json
2019-04-24 10:42:10.942309 DEBUG 1 --- [ctor-http-nio-87] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient    : Processing Step: Retrieve HSI CFS Service. Url: (/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all)Real-Time=true
2019-04-24 10:42:10.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient    : X-TransactionId=9999
2019-04-24 10:42:10.942934  INFODEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.AaiClientTaskImpl    utilities.AaiReactiveClient    : ExecutingResponse taskstatus (HSI CFS Service Instance Retrieval) for retrieving Service Instance object200 OK
2019-04-24 10:42:10.942937 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : WillResponse issue Reactive GET request to URL (/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all) for object (org.onap.bbs.event.processor.model.ServiceInstanceAaiObject)
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Request: GET https://10.133.115.190:30233/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : X-FromAppId=bbs
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Accept=application/json
2019-04-24 10:42:10.945 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Authorization=Basic QUFJOkFBSQ==
2019-04-24 10:42:10.945 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Content-Type=application/json
2019-04-24 10:42:10.947 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Real-Time=truebody 
{"pnf-name":"pnf-11","in-maint":true,"resource-version":"1551889263181","relationship-list":{"relationship":[{"related-to":"service-instance","relationship-label":"org.onap.relationships.inventory.ComposedOf","related-link":"/aai/v14/business/customers/customer/766162a3-53a9-42b8-8fe2-ebaa2213a6dd/service-subscriptions/service-subscription/BBS-CFS11/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832","relationship-data":[{"relationship-key":"customer.global-customer-id","relationship-value":"766162a3-53a9-42b8-8fe2-ebaa2213a6dd"},{"relationship-key":"service-subscription.service-type","relationship-value":"BBS-CFS11"},{"relationship-key":"service-instance.service-instance-id","relationship-value":"1923eaa8-8ab7-49ef-b4c2-e185efbbe832"}],"related-to-property":[{"property-key":"service-instance.service-instance-name"}]},{"related-to":"logical-link","relationship-label":"org.onap.relationships.inventory.BridgedTo","related-link":"/aai/v14/network/logical-links/logical-link/olt11-11-11","relationship-data":[{"relationship-key":"logical-link.link-name","relationship-value":"olt11-11-11"}]}]}}
2019-04-24 10:42:10.947942 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilitiesp.AaiReactiveClientCpeAuthenticationPipeline    : X-TransactionId=9999
2019-04-24 10:42:11.230 DEBUG 1 --- [ctor-http-Processing Step: Retrieve HSI CFS Service. Url: (/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all)
2019-04-24 10:42:10.942  INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClienttasks.AaiClientTaskImpl        : Response status 200 OK Executing task (HSI CFS Service Instance Retrieval) for retrieving Service Instance object
2019-04-24 10:42:1110.239942 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Response body 
{"service-instance-id":"Will issue Reactive GET request to URL (/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832","resource-version":"1551889260591","orchestration-status":"assigned","relationship-list":{"relationship":[{"related-to":"pnf","relationship-label":"?depth=all) for object (org.onap.relationshipsbbs.inventory.ComposedOf","related-link":"event.processor.model.ServiceInstanceAaiObject)
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Request: GET https://10.133.115.190:30233/aai/v14/networknodes/pnfs/pnf/pnf-11","relationship-data":[{"relationship-key":"pnf.pnf-name","relationship-value":"pnf-11"}]}]},"metadata":{"metadatum":[{"metaname":"cvlan","metaval":"1005","resource-version":"1551889260599"},{"metaname":"svlan","metaval":"100","resource-version":"1551889260608"},{"metaname":"oltName","metaval":"olt1","resource-version":"1551889260616"},{"metaname":"rgw-mac-address","metaval":"01:02:03:04:05:06","resource-version":"1551889260624"}]}}service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : X-FromAppId=bbs
2019-04-24 10:42:10.944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Accept=application/json
2019-04-24 10:42:1110.253945 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient    : Processing Step: Publish for PolicyAuthorization=Basic QUFJOkFBSQ==
2019-04-24 10:42:1110.253945 TRACEDEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient    : Trigger Policy event: (ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=CPE_Authentication, policyScope=policyScope, targetType=VM, aaiEnrichmentData={cpe.old-authentication-state=outOfService, cpe.new-authentication-state=inService, cpe.swVersion=1.2.3, service-information.hsia-cfs-service-instance-id=1923eaa8-8ab7-49ef-b4c2-e185efbbe832}, closedLoopAlarmStart=1556102531, closedLoopEventStatus=ONSET, closedLoopControlName=controlName, version=1.0.2, target=vserver.vserver-name, requestId=205f5550-37a0-4be7-be63-effefe181b37, originator=DCAE-bbs-event-processor})
2019-04-Content-Type=application/json
2019-04-24 10:42:10.947 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : Real-Time=true
2019-04-24 10:42:10.947 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient    : X-TransactionId=9999
2019-04-24 10:42:11.253230 DEBUG INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasksutilities.DmaapPublisherTaskImplAaiReactiveClient    : ExecutingResponse taskstatus for publishing control loop message200 OK
2019-04-24 10:42:11.254239 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.tasksutilities.DmaapPublisherTaskImplAaiReactiveClient    : CLResponse messagebody 
ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=CPE_Authentication, policyScope=policyScope, targetType=VM, aaiEnrichmentData={cpe.old-authentication-state=outOfService, cpe.new-authentication-state=inService, cpe.swVersion=1.2.3, service-information.hsia-cfs-service-instance-id=1923eaa8-8ab7-49ef-b4c2-e185efbbe832}, closedLoopAlarmStart=1556102531, closedLoopEventStatus=ONSET, closedLoopControlName=controlName, version=1.0.2, target=vserver.vserver-name, requestId=205f5550-37a0-4be7-be63-effefe181b37, originator=DCAE-bbs-event-processor}
2019-04-24 10:42:11.631  INFO{"service-instance-id":"1923eaa8-8ab7-49ef-b4c2-e185efbbe832","resource-version":"1551889260591","orchestration-status":"assigned","relationship-list":{"relationship":[{"related-to":"pnf","relationship-label":"org.onap.relationships.inventory.ComposedOf","related-link":"/aai/v14/network/pnfs/pnf/pnf-11","relationship-data":[{"relationship-key":"pnf.pnf-name","relationship-value":"pnf-11"}]}]},"metadata":{"metadatum":[{"metaname":"cvlan","metaval":"1005","resource-version":"1551889260599"},{"metaname":"svlan","metaval":"100","resource-version":"1551889260608"},{"metaname":"oltName","metaval":"olt1","resource-version":"1551889260616"},{"metaname":"rgw-mac-address","metaval":"01:02:03:04:05:06","resource-version":"1551889260624"}]}}
2019-04-24 10:42:11.253 DEBUG 1 --- [ctor-http-nio-78] o.o.b.e.p.p.CpeAuthenticationPipeline    : CPEProcessing Authentication event successfully handled. Publishing to DMaaP for Policy returned a status code of (200 OK)Step: Publish for Policy
2019-04-24 10:42:11.633253 TRACE INFO 1 --- [ctor-http-nio-78] o.o.b.e.p.p.CpeAuthenticationPipeline    : CPE Authentication processing pipeline has been completed

We can check that a new DCAE_CL_OUTPUT event has been published (make sure you target the correct DMaaP IP address)

Trigger Policy event: (ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=CPE_Authentication, policyScope=policyScope, targetType=VM, aaiEnrichmentData={cpe.old-authentication-state=outOfService, cpe.new-authentication-state=inService, cpe.swVersion=1.2.3, service-information.hsia-cfs-service-instance-id=1923eaa8-8ab7-49ef-b4c2-e185efbbe832}, closedLoopAlarmStart=1556102531, closedLoopEventStatus=ONSET, closedLoopControlName=controlName, version=1.0.2, target=vserver.vserver-name, requestId=205f5550-37a0-4be7-be63-effefe181b37, originator=DCAE-bbs-event-processor})
2019-04-24 10:42:11.253  INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.DmaapPublisherTaskImpl   : Executing task for publishing control loop message
2019-04-24 10:42:11.254 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.DmaapPublisherTaskImpl   : CL message 
ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=CPE_Authentication, policyScope=policyScope, targetType=VM, aaiEnrichmentData={cpe.old-authentication-state=outOfService, cpe.new-authentication-state=inService, cpe.swVersion=1.2.3, service-information.hsia-cfs-service-instance-id=1923eaa8-8ab7-49ef-b4c2-e185efbbe832}, closedLoopAlarmStart=1556102531, closedLoopEventStatus=ONSET, closedLoopControlName=controlName, version=1.0.2, target=vserver.vserver-name, requestId=205f5550-37a0-4be7-be63-effefe181b37, originator=DCAE-bbs-event-processor}
2019-04-24 10:42:11.631  INFO 1 --- [ctor-http-nio-7] o.o.b.e.p.p.CpeAuthenticationPipeline    : CPE Authentication event successfully handled. Publishing to DMaaP for Policy returned a status code of (200 OK)
2019-04-24 10:42:11.633  INFO 1 --- [ctor-http-nio-7] o.o.b.e.p.p.CpeAuthenticationPipeline    : CPE Authentication processing pipeline has been completed


We can check that a new DCAE_CL_OUTPUT event has been published (make sure you target the correct DMaaP IP address)

Code Block
languagebash
themeMidnight
titleFetch events from DCAE_CL_OUTPUT topic
linenumberstrue
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar


Code Block
languagebash
themeMidnight
titlePublished event
linenumberstrue
[
"{\"closedLoopEventClient\":\"DCAE.BBS_event_processor_mSInstance\",\"policyVersion\":\"1.0.0.5\",\"policyName\":\"CPE_Authentication\",\"policyScope\":\"policyScope\",\"target_type\":\"VM\",\"AAI\":{\"cpe.old-authentication-state\":\"outOfService\",\"cpe.new-authentication-state\":\"inService\",\"cpe.swVersion\":\"1.2.3\",\"service-information.hsia-cfs-service-instance-id\":\"1923eaa8-8ab7-49ef-b4c2-e185efbbe832\"},\"closedLoopAlarmStart\":1556102531,\"closedLoopEventStatus\":\"ONSET\",\"closedLoopControlName\":\"controlName\",\"version\":\"1.0.2\",\"target\":\"vserver.vserver-name\",\"requestID\":\"205f5550-37a0-4be7-be63-effefe181b37\",\"from\":\"DCAE-bbs-event-processor\"}"
]
Code Block
languagebash
themeMidnight
titleTrigger a PNF re-registration event
linenumberstrue
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar