diff options
Diffstat (limited to 'components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py')
| -rw-r--r-- | components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py | 123 |
1 files changed, 69 insertions, 54 deletions
diff --git a/components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py b/components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py index 518666a76..01e2ec477 100644 --- a/components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py +++ b/components/model-catalog/blueprint-model/test-blueprint/capability_restconf/Scripts/python/RestconfConfigDeploy.py @@ -12,9 +12,8 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. -# -# SPDX-License-Identifier: Apache-2.0 # ============LICENSE_END========================================================= + from time import sleep from org.onap.ccsdk.cds.blueprintsprocessor.functions.restconf.executor import \ @@ -25,88 +24,104 @@ from java.lang import Exception as JavaException class RestconfConfigDeploy(RestconfComponentFunction): log = globals()["log"] - seconds_to_sleep = 5 - base_mount_url = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/" + odl_status_check_limit = 10 + odl_status_check_pause = 1 + odl_status_check_url = "restconf/operational/network-topology:network-topology/topology/topology-netconf/node/" + base_odl_url = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/" server_identifier = "sdncodl" configlet_template_name = "config-assign" + configlet_odl_resource = "/yang-ext:mount/mynetconf:netconflist" def process(self, execution_request): self.log.info("Started execution of process method") try: - self.log.info("getting resolution-key") - resolution_key = self.getDynamicProperties("resolution-key").asText() - self.log.info("resolution_key: {}", resolution_key) - - self.log.info("getting pnf-id") - pnf_id = execution_request.payload.get("config-deploy-request").get("config-deploy-properties").get("entity").get("pnf-id") - pnf_id = str(pnf_id).strip('\"') - self.log.info("pnf-id: {}", pnf_id) - - self.log.info("mounting device {}", pnf_id) - self.mount(pnf_id) - - self.log.info("sleeping for {} seconds", self.seconds_to_sleep) - sleep(self.seconds_to_sleep) - - try: - self.log.info("configuring device {}", pnf_id) - self.apply_configuration(pnf_id, resolution_key, self.configlet_template_name) - except Exception, err: - self.log.error("an error occurred while configuring device {}", err) - raise err - finally: - self.log.info("unmounting device {}", pnf_id) - self.unmount(pnf_id) - - self.log.info("Ended execution of process method") - + pnf_id, resolution_key = self.retrieve_parameters(execution_request) + self.interact_with_odl(pnf_id, resolution_key) except JavaException, err: self.log.error("Java Exception in the script", err) raise err except Exception, err: - self.log.error("Python Exception in the script", err) + self.log.error("Python Exception in the script:" + str(err), err) + raise err + self.log.info("Ended execution of process method") + + def retrieve_parameters(self, execution_request): + resolution_key = self.getDynamicProperties("resolution-key").asText() + self.log.info("resolution_key: {}", resolution_key) + pnf_id = execution_request.payload.get("config-deploy-request").get("config-deploy-properties").get("pnf-id") + pnf_id = str(pnf_id).strip('\"') + self.log.info("pnf-id: {}", pnf_id) + return pnf_id, resolution_key + + def interact_with_odl(self, pnf_id, resolution_key): + try: + self.mount(pnf_id) + self.log_current_configlet(pnf_id) + self.apply_configuration(pnf_id, resolution_key, self.configlet_template_name) + except Exception, err: + self.log.error("an error occurred while configuring device {}", err) raise err + finally: + self.log.info("unmounting device {}", pnf_id) + self.unmount(pnf_id) def mount(self, pnf_id): - self.log.info("meshing mount payload") + self.log.info("mounting device {}", pnf_id) mount_payload = self.resolveAndGenerateMessage("config-deploy-mapping", "config-deploy-template") self.log.info("mount payload: \n {}", mount_payload) - - # defining custom header - headers = { - "Content-Type": "application/xml" - } - - url = self.base_mount_url + str(pnf_id) + headers = {"Content-Type": "application/xml"} # defining custom header + url = self.base_odl_url + str(pnf_id) self.log.info("sending mount request, url: {}", url) web_client_service = self.restClientService(self.server_identifier) web_client_service.exchangeResource("PUT", url, mount_payload, headers) + self.wait_for_odl_to_mount(pnf_id) - def unmount(self, pnf_id): - url = self.base_mount_url + str(pnf_id) - self.log.info("sending unmount request, url: {}", url) + def wait_for_odl_to_mount(self, pnf_id): + counter = 0 + url = self.odl_status_check_url + pnf_id + self.log.info("url for ODL status check: {}", url) web_client_service = self.restClientService(self.server_identifier) - web_client_service.exchangeResource("DELETE", url, "") + expected_result = '"netconf-node-topology:connection-status":"connected"' + while counter < self.odl_status_check_limit: + result = web_client_service.exchangeResource("GET", url, "") + self.log.info("ODL status check result: {}", result) + if expected_result in result: + self.log.info("PNF was mounted successfully on ODL") + return None + sleep(1) + counter += 1 + raise JavaException("PNF was not mounted on ODL, aborting configuration procedure") + + def log_current_configlet(self, pnf_id): + self.log.info("retrieving configuration for device {}", pnf_id) + url = self.base_odl_url + pnf_id + self.configlet_odl_resource + self.log.info("sending GET request, url: {}", url) + web_client_service = self.restClientService(self.server_identifier) + result = web_client_service.exchangeResource("GET", url, "") + self.log.info("Current configuration: {}", result) def apply_configuration(self, pnf_id, resolution_key, template_name): + self.log.info("configuring device {}", pnf_id) self.log.info("Retrieving configlet from database (resolution-key: {}, template_name: {}", resolution_key, template_name) configlet = self.resolveFromDatabase(resolution_key, template_name) self.log.info("Configlet: {}", configlet) - - # defining custom header - headers = { - "Content-Type": "application/yang.patch+json" - } - - url = "restconf/config/network-topology:network-topology/topology/topology-netconf/node/" + pnf_id \ - + "/yang-ext:mount/mynetconf:netconflist" + headers = { "Content-Type": "application/yang.patch+json" } # defining custom header + url = self.base_odl_url + pnf_id + self.configlet_odl_resource self.log.info("sending patch request, url: {}", url) web_client_service = self.restClientService(self.server_identifier) result = web_client_service.exchangeResource("PATCH", url, configlet, headers) self.log.info("Configuration application result: {}", result) + def unmount(self, pnf_id): + url = self.base_odl_url + str(pnf_id) + self.log.info("sending unmount request, url: {}", url) + web_client_service = self.restClientService(self.server_identifier) + web_client_service.exchangeResource("DELETE", url, "") + def recover(self, runtime_exception, execution_request): - self.log.info("Recover method, no code to execute") - return None + self.log.info("Recover function called!") + self.log.error(runtime_exception.getMessage()) + print self.bluePrintRuntimeService.getBluePrintError().addError(runtime_exception.getMessage()) + return None
\ No newline at end of file |