...
Β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
Deployment Prerequisite/dependencies
...
Uninstall running component and delete deployment
Code Block language bash theme Midnight title Uninstall component linenumbers true cfy uninstall bbs-ep
Delete blueprint
Code Block language bash theme Midnight title Delete blueprint linenumbers true cfy blueprints delete bbs-ep
Deployment steps for VES-Mapper
...
Validate blueprint
Code Block | ||||
---|---|---|---|---|
| ||||
cfy blueprints validate /blueprints/k8s-vesmapper.yaml-template.yaml |
Upload validated blueprint
Code Block | ||||
---|---|---|---|---|
| ||||
cfy blueprints upload -b ves-mapper /blueprints/k8s-vesmapper.yaml-template.yaml |
Create Cloudify Deployment
Code Block | ||||
---|---|---|---|---|
| ||||
cfy deployments create -b ves-mapper ves-mapper |
Deploy component
Code Block | ||||
---|---|---|---|---|
| ||||
cfy executions start -d ves-mapper install |
...
Uninstall component
Code Block | ||||
---|---|---|---|---|
| ||||
cfy uninstall ves-mapper |
Delete blueprint
Code Block | ||||
---|---|---|---|---|
| ||||
cfy blueprints delete ves-mapper |
Initial Validation
After deployment, we can check if BBS-ep POD is running correctly
...
language | bash |
---|---|
theme | Midnight |
title | Verify BBS-ep is running |
linenumbers | true |
...
Initial Validation
After deployment, we can check if BBS-ep POD is running correctly
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
root@cluster-admin:~# kubectl -n onap get pods | grep -i bbs
dep-bbs-event-processor-6b6df75d94-g7jw8 2/2 Running 0 1d
|
And then check the logs to see if it can connect to DMaaP, polling for events. Even in the absence of events, we can at least verify that there is nothing to consume for both PNF re-registration messages and CPE authentication messages.
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
kubectl -n onap logs dep-bbs-event-processor-6b6df75d94-g7jw8 -c bbs-event-processor 2019-04-10 09:37:58.151 INFO 1 --- [pipeline-thrd-4] o.o.b.e.p.p.ReRegistrationPipeline : Process next Re-Registration events 2019-04-10 09:37:58.152 INFO 1 --- [pipeline-thrd-1] o.o.b.e.p.p.CpeAuthenticationPipeline : Process next CPE Authentication events 2019-04-10 09:38:07.680 INFO 1 --- [tor-http-nio-10] o.o.b.e.p.p.CpeAuthenticationPipeline : Nothing to consume from DMaaP 2019-04-10 09:38:07.681 INFO 1 --- [tor-http-nio-10] o.o.b.e.p.p.CpeAuthenticationPipeline : CPE Authentication processing pipeline has been completed 2019-04-10 09:38:07.681 INFO 1 --- [tor-http-nio-10] o.o.b.e.p.p.ReRegistrationPipeline : Nothing to consume from DMaaP 2019-04-10 09:38:07.681 INFO 1 --- [tor-http-nio-10] o.o.b.e.p.p.ReRegistrationPipeline : PNF Re-Registration processing pipeline has been completed 2019-04-10 09:38:28.151 INFO 1 --- [pipeline-thrd-4] o.o.b.e.p.p.ReRegistrationPipeline : Process next Re-Registration events |
Initial Validation for VES-Mapper
After Cloudify deployment,
...
Code Block | ||||
---|---|---|---|---|
| ||||
kubectl get pods -n onap | grep mapper
dep-s36f1a2fadd614a42872bd680516e271a-dcaegen2-svc-mapper-l2cms 1/1 Running 0 1d |
Check the logs. Here are some important log statements that could be looked for.
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
kubectl logs -n onap dep-s36f1a2fadd614a42872bd680516e271a-dcaegen2-svc-mapper-l2cms | more
11:10:12.078 [main] INFO debugLogger - Triggering controller's start url
11:10:12.078 [main] INFO debugLogger - Running curl command for url:http://localhost:8085/start
11:10:12.186 [http-nio-8085-exec-1] INFO o.a.c.c.C.[Tomcat].[localhost].[/] - Initializing Spring DispatcherServlet 'dispatcherServlet'
11:10:12.186 [http-nio-8085-exec-1] INFO o.s.web.servlet.DispatcherServlet - Initializing Servlet 'dispatcherServlet'
11:10:12.200 [http-nio-8085-exec-1] INFO o.s.web.servlet.DispatcherServlet - Completed initialization in 14 ms
11:10:12.243 [http-nio-8085-exec-1] INFO metricsLogger - UniversalVesAdapter Application starting...
11:10:12.243 [http-nio-8085-exec-1] INFO debugLogger - Creating Subcriber and Publisher with creator.............
...
...
...
11:10:13.219 [http-nio-8085-exec-1] INFO debugLogger - Created scriber topic:unauthenticated.DCAE_RCC_OUTPUTpublisher topic:unauthenticated.VES_PNFREG_OUTPUT
11:10:13.230 [rcc-notification] INFO metricsLogger - fetch and publish from and to Dmaap started:rcc-notification
...
...
...
11:10:13.322 [http-nio-8085-exec-1] INFO debugLogger - Created scriber topic:unauthenticated.ONAP-COLLECTOR-SNMPTRAPpublisher topic:unauthenticated.SEC_FAULT_OUTPUT
11:10:13.326 [snmp-notification] INFO metricsLogger - fetch and publish from and to Dmaap started:snmp-notification
...
...
...
11:13:11.873 [snmp-notification] DEBUG debugLogger - number of messages to be converted :0
11:13:13.044 [rcc-notification] DEBUG debugLogger - number of messages to be converted :0 |
Feed test data
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.
...
View file | ||||
---|---|---|---|---|
|
...
View file | ||||
---|---|---|---|---|
|
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)
Populated objects inside A&AI are:
- New business customer
- New HSIA CFS service instance
- New logical-link
- New PNF related to logical-link and to the HSIA CFS service instance
Please note that new UUIDs for the test objects are automatically generated by the script.
Functional tests
With the test data successfully inside A&AI, we can perform two functional tests for BBS-ep
PNF re-registration handling
Send a triggering event to DMaaP topic 'unauthenticated.PNF_UPDATE
Before sending, make sure you have the
- Correct DMaaP address
- correlationId matches the 'pnf-name' in test data
- attachment-point is different than the one found in test-data (otherwise it will not be considered as a true ONU relocation
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X POST http://10.133.115.190:30227/events/unauthenticated.PNF_UPDATE -H 'Content-Type: application/json' -d '{
"nf-role":"gNB",
"equip-type":"Unit-type-3",
"equip-vendor":"Nokia",
"equip-model":"SN-1",
"serial-number":"",
"sw-version":"SW-version-2",
"correlationId":"pnf-11",
"additionalFields": {
"attachment-point": "olt11-1-1",
"cvlan": "1005",
"svlan": "100",
"remote-id": "some-remote-id"
}
}' |
...
language | bash |
---|---|
theme | Midnight |
title | Logs showing PNF re-registration event handling |
linenumbers | true |
...
Feed test data
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 |
| ||||||
---|---|---|---|---|---|---|---|
JSON Input |
|
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)
Populated objects inside A&AI are:
- New business customer
- New HSIA CFS service instance
- New logical-link
- New PNF related to logical-link and to the HSIA CFS service instance
Please note that new UUIDs for the test objects are automatically generated by the script.
Functional tests
With the test data successfully inside A&AI, we can perform two functional tests for BBS-ep
PNF re-registration handling
Send a triggering event to DMaaP topic 'unauthenticated.PNF_UPDATE
Before sending, make sure you have the
- Correct DMaaP address
- correlationId matches the 'pnf-name' in test data
- attachment-point is different than the one found in test-data (otherwise it will not be considered as a true ONU relocation
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X POST http://10.133.115.190:30227/events/unauthenticated.PNF_UPDATE -H 'Content-Type: application/json' -d '{
"nf-role":"gNB",
"equip-type":"Unit-type-3",
"equip-vendor":"Nokia",
"equip-model":"SN-1",
"serial-number":"",
"sw-version":"SW-version-2",
"correlationId":"pnf-11",
"additionalFields": {
"attachment-point": "olt11-1-1",
"cvlan": "1005",
"svlan": "100",
"remote-id": "some-remote-id"
}
}' |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
2019-04-24 10:40:10.334 TRACE 1 --- [ctor-http-nio-8] .u.ReRegistrationDmaapConsumerJsonParser : Event from DMaaP to be parsed: {"nf-role":"gNB","equip-type":"Unit-type-3","equip-vendor":"Nokia","equip-model":"SN-1","additionalFields":{"remote-id":"some-remote-id","attachment-point":"olt11-1-1","cvlan":"1005","svlan":"100"},"serial-number":"","sw-version":"SW-version-2","correlationId":"pnf-11"} 2019-04-24 10:40:10.342 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : Processing Step: Retrieve PNF. Url: (/aai/v14/network/pnfs/pnf/pnf-11?depth=all) 2019-04-24 10:40:10.343 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.AaiClientTaskImpl : Executing task (PNF Retrieval) for retrieving PNF object 2019-04-24 10:40:10.343 DEBUG 1 --- [ctor-http-nio-8] 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) 2019-04-24 10:40:10.469 DEBUG 1 --- [ctor-http-nio-8] 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:40:10.485 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : X-FromAppId=bbs 2019-04-24 10:40:10.488 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Accept=application/json 2019-04-24 10:40:10.489 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Authorization=Basic QUFJOkFBSQ== 2019-04-24 10:40:10.492 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Content-Type=application/json 2019-04-24 10:40:10.493 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Real-Time=true 2019-04-24 10:40:10.493 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : X-TransactionId=9999 2019-04-24 10:40:11.961 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:40:12.079 DEBUG 1 --- [ctor-http-nio-8] 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"}]}]}} 2019-04-24 10:40:12.198 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : Processing Step: Retrieve HSI CFS PNFService. Url: (/aai/v14/networknodes/pnfs/pnf/pnf-11service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all) 2019-04-24 10:40:1012.343198 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.AaiClientTaskImpl : Executing task (PNFHSI CFS Service Instance Retrieval) for retrieving Service PNFInstance object 2019-04-24 10:40:1012.343198 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Will issue Reactive GET request to URL (/aai/v14/networknodes/pnfs/pnf/pnf-11service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all) for object (org.onap.bbs.event.processor.model.PnfAaiObjectServiceInstanceAaiObject) 2019-04-24 10:40:1012.469200 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-11service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all 2019-04-24 10:40:1012.485200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : X-FromAppId=bbs 2019-04-24 10:40:1012.488200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Accept=application/json 2019-04-24 10:40:1012.489200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Authorization=Basic QUFJOkFBSQ== 2019-04-24 10:40:1012.492200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Content-Type=application/json 2019-04-24 10:40:1012.493201 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Real-Time=true 2019-04-24 10:40:1012.493201 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : X-TransactionId=9999 2019-04-24 10:40:1112.961495 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:40:12.079500 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response body {"pnfservice-instance-nameid":"pnf-111923eaa8-8ab7-49ef-b4c2-e185efbbe832","inresource-maintversion":true"1551889260591","resourceorchestration-versionstatus":"1551889263181assigned","relationship-list":{"relationship":[{"related-to":"service-instancepnf","relationship-label":"org.onap.relationships.inventory.ComposedOf","related-link":"/aai/v14/businessnetwork/customerspnfs/customerpnf/766162a3-53a9-42b8-8fe2-ebaa2213a6dd/service-subscriptions/service-subscription/BBS-CFS11/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832pnf-11","relationship-data":[{"relationship-key":"pnf.pnf-name","relationship-datavalue":[{"relationship-keypnf-11"}]}]},"metadata":"customer.global-customer-id","relationship-value":"766162a3-53a9-42b8-8fe2-ebaa2213a6dd"},{"relationship-key":"service-subscription.service-type","relationship-value":"BBS-CFS11{"metadatum":[{"metaname":"cvlan","metaval":"1005","resource-version":"1551889260599"},{"relationship-keymetaname":"service-instance.service-instance-idsvlan","relationship-valuemetaval":"1923eaa8-8ab7-49ef-b4c2-e185efbbe832"}]100","relatedresource-to-propertyversion":["1551889260608"},{"property-keymetaname":"service-instance.service-instance-name"}]},{"related-tooltName","metaval":"logical-linkolt1","relationshipresource-labelversion":"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"}]}]}}1551889260616"},{"metaname":"rgw-mac-address","metaval":"01:02:03:04:05:06","resource-version":"1551889260624"}]}} 2019-04-24 10:40:12.198523 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : Processing Step: RetrievePublish HSIfor CFS Service. Url: (/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all) Policy 2019-04-24 10:40:12.198525 INFOTRACE 1 --- [ctor-http-nio-8] o.o.b.e.p.tasksp.AaiClientTaskImplReRegistrationPipeline : Trigger ExecutingPolicy task (HSI CFS Service Instance Retrieval) for retrieving Service Instance object 2019-04-24 10:40:12.198 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Will 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:40:12.200 DEBUGevent: (ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=Nomadic_ONT, policyScope=policyScope, targetType=VM, aaiEnrichmentData={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, originator=DCAE-bbs-event-processor}) 2019-04-24 10:40:12.541 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.utilitiestasks.AaiReactiveClientDmaapPublisherTaskImpl : Request: GET https://10.133.115.190:30233/aai/v14/nodes/service-instances/service-instance/1923eaa8-8ab7-49ef-b4c2-e185efbbe832?depth=all Executing task for publishing control loop message 2019-04-24 10:40:12.200546 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilitiestasks.AaiReactiveClientDmaapPublisherTaskImpl : X-FromAppId=bbs 2019-04-24 10:40:12.200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Accept=application/json 2019-04-24 10:40:12.200 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Authorization=Basic QUFJOkFBSQ==CL message ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=Nomadic_ONT, policyScope=policyScope, targetType=VM, aaiEnrichmentData={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, originator=DCAE-bbs-event-processor} 2019-04-24 10:40:12.200940 DEBUGINFO 1 --- [ctor-http-nio-8] o.o.b.e.p.utilitiesp.AaiReactiveClientReRegistrationPipeline : PNF Content-Type=application/jsonRe-Registration event successfully handled. Publishing to DMaaP for Policy returned a status code of (200 OK) 2019-04-24 10:40:12.201940 DEBUGINFO 1 --- [ctor-http-nio-8] o.o.b.e.p.utilitiesp.AaiReactiveClientReRegistrationPipeline : Real-Time=truePNF Re-Registration processing pipeline has been completed 2019-04-24 10:40:1219.201263 DEBUGINFO 1 --- [ctor-http-nio-87] o.o.b.e.p.utilitiesp.AaiReactiveClientCpeAuthenticationPipeline : X-TransactionId=9999 Nothing to consume from DMaaP 2019-04-24 10:40:1219.495264 DEBUGINFO 1 --- [ctor-http-nio-87] o.o.b.e.p.utilitiesp.AaiReactiveClientCpeAuthenticationPipeline : ResponseCPE statusAuthentication 200processing OK 2019-04-24 10:40:12.500 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response body {"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:40:12.523 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : Processing Step: Publish for Policy 2019-04-24 10:40:12.525 TRACE 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : Trigger Policy event: (ControlLoopPublisherDmaapModel{closedLoopEventClient=DCAE.BBS_event_processor_mSInstance, policyVersion=1.0.0.5, policyName=Nomadic_ONT, policyScope=policyScope, targetType=VM, aaiEnrichmentData={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, originator=DCAE-bbs-event-processor}) 2019-04-24 10:40:12.541 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasks.DmaapPublisherTaskImpl : Executing task for publishing control loop message 2019-04-24 10:40:12.546 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=Nomadic_ONT, policyScope=policyScope, targetType=VM, aaiEnrichmentData={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, originator=DCAE-bbs-event-processor} 2019-04-24 10:40:12.940 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : PNF Re-Registration event successfully handled. Publishing to DMaaP for Policy returned a status code of (200 OK) 2019-04-24 10:40:12.940 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.p.ReRegistrationPipeline : PNF Re-Registration processing pipeline has been completed 2019-04-24 10:40:19.263 INFO 1 --- [ctor-http-nio-7] o.o.b.e.p.p.CpeAuthenticationPipeline : Nothing to consume from DMaaP 2019-04-24 10:40:19.264 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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
[
"{\"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
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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
[
"{\"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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X POST http://10.133.115.190:30227/events/unauthenticated.CPE_AUTHENTICATION -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": {
"stateChangeFieldsVersion": 1,
"oldState": "outOfService",
"newState": "inService",
"stateInterface": "",
"additionalFields": {
"macAddress": "01:02:03:04:05:06",
"swVersion": "1.2.3"
}
}
}
}' |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X POST http://10.133.115.190:30227/events/unauthenticated.CPE_AUTHENTICATION -H 'Content-Type: application/json' -d '{2019-04-24 10:42:09.513 INFO 1 --- [pipeline-thrd-5] o.o.b.e.p.p.ReRegistrationPipeline "event": {Process next Re-Registration events 2019-04-24 10:42:09.513 INFO "commonEventHeader": { 1 --- [pipeline-thrd-3] o.o.b.e.p.p.CpeAuthenticationPipeline : Process next CPE Authentication events "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": { "stateChangeFieldsVersion": 1, "oldState": "outOfService", "newState": "inService", "stateInterface": "", "additionalFields": { "macAddress": "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 : Reactive 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 --- } [ctor-http-nio-7] o.o.b.e.p.p.CpeAuthenticationPipeline : Processing Step: }Retrieve PNF. } }' | ||||||||
Code Block | ||||||||
| ||||||||
Url: (/aai/v14/network/pnfs/pnf/pnf-11?depth=all) 2019-04-24 10:42:0910.513307 INFO 1 --- [pipelinector-http-thrdnio-57] o.o.b.e.p.ptasks.ReRegistrationPipelineAaiClientTaskImpl : ProcessExecuting next Re-Registration events 2019-04-24 task (PNF Retrieval) for retrieving PNF object 2019-04-24 10:42:0910.513307 DEBUG INFO 1 --- [pipelinector-http-thrdnio-37] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient : Process next CPE Authentication events 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:0910.514308 DEBUG 1 --- [pipelinector-http-thrdnio-37] t.DmaapCpeAuthenticationConsumerTaskImpl : Executing task for CPE-Authentication with name "Consume CPE Authentication DMaaP message" 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:0910.514309 DEBUG 1 --- [pipelinector-http-thrdnio-57] o.o.b.e.p.tutilities.DmaapReRegistrationConsumerTaskImplAaiReactiveClient : Executing task for: ReX-Registration with name "Consume Re-registration DMaaP message" 2019-04-24 10FromAppId=bbs 2019-04-24 10:42:0910.521309 TRACEDEBUG 1 --- [pipelinector-http-thrdnio-37] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient : Reactive CPE Authentication pipeline subscribed - Execution started Accept=application/json 2019-04-24 10:42:0910.525309 TRACEDEBUG 1 --- [pipelinector-http-thrdnio-57] o.o.b.e.p.putilities.ReRegistrationPipelineAaiReactiveClient : Reactive PNF Re-registration pipeline subscribed - Execution startedAuthorization=Basic QUFJOkFBSQ== 2019-04-24 10:42:10.301309 TRACEDEBUG 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 --- [ctor-http-nio-7] o.o.b.e.p.p.CpeAuthenticationPipeline : Processing 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 object 2019-04-24 10:42:10.307 DEBUG 1 --- [ctor-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) 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 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.309 DEBUG 1 --- [ctor-http-nio-7] o.o.b.e.p.utilities.AaiReactiveClient : X-TransactionId=9999 2019-04-24 10:42:10.934 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:42:10.937 DEBUG 1 --- [ctor-http-nio-8] 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"}]}]}} 2019-04-24 10:42:10.309942 DEBUG 1 --- [ctor-http-nio-78] o.o.b.e.p.utilities.AaiReactiveClient : Accept=application/jsonp.CpeAuthenticationPipeline : 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.309942 DEBUGINFO 1 --- [ctor-http-nio-78] o.o.b.e.p.utilitiestasks.AaiReactiveClientAaiClientTaskImpl : 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: Executing task (HSI CFS Service Instance Retrieval) for retrieving Service Instance object 2019-04-24 10:42:10.309942 DEBUG 1 --- [ctor-http-nio-78] o.o.b.e.p.utilities.AaiReactiveClient : 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.934 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:42:10.937 DEBUG 1 --- [ctor-http-nio-8] 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"}]}]}} 2019-04-24 10:42:10.942 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.p.CpeAuthenticationPipeline : 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.tasks.AaiClientTaskImpl : Executing task (HSI CFS Service Instance Retrieval) for retrieving Service Instance object 2019-04-24 10:42:10.942 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Will 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=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.230 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:42:11.239 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response body {"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"}]}}Will 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:1110.253944 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient : Processing Step: Publish for Policy 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:1110.253944 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})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 INFO 1 --- [ctor-http-nio-8] o.o.b.e.p.tasksutilities.DmaapPublisherTaskImplAaiReactiveClient : Executing task for publishing control loop messageAuthorization=Basic QUFJOkFBSQ== 2019-04-24 10:42:1110.254945 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.tasksutilities.DmaapPublisherTaskImplAaiReactiveClient : 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}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:1110.631947 INFODEBUG 1 --- [ctor-http-nio-78] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient : CPE Authentication event successfully handled. Publishing to DMaaP for Policy returned a status code of (200 OK) X-TransactionId=9999 2019-04-24 10:42:11.230 DEBUG 1 --- [ctor-http-nio-8] o.o.b.e.p.utilities.AaiReactiveClient : Response status 200 OK 2019-04-24 10:42:11.633239 DEBUG INFO 1 --- [ctor-http-nio-78] o.o.b.e.p.putilities.CpeAuthenticationPipelineAaiReactiveClient : CPEResponse Authenticationbody 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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
[
"{\"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\"}"
] |
Functional testing of VES-Mapper individually
...
Code Block | ||||
---|---|---|---|---|
| ||||
curl -v -k -H 'Content-Type:application/json' -POST http://message-router.onap.svc.cluster.local:3904/events/unauthenticated.DCAE_RCC_OUTPUT -d @rcc_noti.json |
...
Code Block | ||||
---|---|---|---|---|
| ||||
curl -X GET 'http://message-router.onap.svc.cluster.local:3904/events/unauthenticated.VES_PNFREG_OUTPUT/grp2/con2?timeout=1600' |
PNF_registration_VES_event.json
VES-Mapper Logs
Code Block | ||||
---|---|---|---|---|
| ||||
12:35:27.886 [rcc-notification] DEBUG debugLogger - number of messages to be converted :1 12:35:27.889 [rcc-notification] INFO debugLogger - Retrieved JsonArray from Collector Config File 12:35:27.889 [rcc-notification] INFO debugLogger - returning identifier array from Collector Config 12:35:27.890 [rcc-notification] DEBUG debugLogger - Using Default Mapping file as Mapping file is not available for Enterprise Id / identifer ID:2541256 12:35:28.075 [rcc-notification] INFO debugLogger - Transforming incoming json 12:35:28.114 [rcc-notification] INFO debugLogger - Context created 12:35:28.125 [rcc-notification] DEBUG debugLogger - consversion successful to VES Event 12:35:28.125 [rcc-notification] INFO debugLogger - Incoming json transformed to VES format successfully:rcc-notification 12:35:28.137 [rcc-notification] INFO debugLogger - Serialized VES json 12:35:28.138 [rcc-notification] DEBUG debugLogger - Batch Queue capacity exceeds messages size. Flushing of all pending messages to DMaaP MR Publisher Topic. 12:35:28.138 [rcc-notification] DEBUG debugLogger - Force publishing messages to DMaaP MR Topic. Messages Size: 1 12:35:28.138 [rcc-notification] DEBUG debugLogger - DMaaP MR Publisher Authentication is disabled as username or password is not present. 12:35:28.167 [rcc-notification] DEBUG debugLogger - DMaaP MR Messages published successfully. DMaaP Response Code: 200. DMaaP Response Body: { "serverTimeMs": 0, "count": 1 }, Number of Messages published: 1 12:35:28.168 [rcc-notification] INFO metricsLogger - Message successfully published to DMaaP Topic- {"event":{"commonEventHeader":{"domain":"pnfRegistration","eventId":"registration_1556627728115","eventName":"pnfRegistration","eventType":"pnfRegistration","lastEpochMicrosec":1.556627728115E12,"priority":"Normal","reportingEntityName":"VESMapper","sequence":0,"sourceName":"Huawei-HWTCC01B7504","startEpochMicrosec":1.556627728115E12,"version":"4.0.1","vesEventListenerVersion":"7.0.1"},"pnfRegistrationFields":{"additionalFields":{"remote-id":"some-remote-id","attachment-point":"NE=167772165-5-1","cvlan":"1005","svlan":"100"},"lastServiceDate":"somestring","manufactureDate":"","modelNumber":" somestring","oamV4IpAddress":"somestring","oamV6IpAddress":"somestring","pnfRegistrationFieldsVersion":"2.0","serialNumber":"HWTCC01B7504","softwareVersion":"v1","unitFamily":"somestring","unitType":"somestring","vendorName":"Huawei"}}} {"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-8] o.o.b.e.p.p.CpeAuthenticationPipeline : Processing Step: Publish for Policy 2019-04-24 10:42:11.253 TRACE 1 --- [ctor-http-nio-8] o.o.b.e.p.p.CpeAuthenticationPipeline : 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 | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
curl -X GET http://10.133.115.190:30227/events/unauthenticated.DCAE_CL_OUTPUT/foo/bar |
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
[
"{\"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\"}"
] |