blob: 4db7c731bda763a3754e29eebbac26c7ba27c228 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
import netconf_constant
from netconfclient import NetconfClient
from java.lang import Exception
from abstract_blueprint_function import AbstractPythonComponentFunction
from org.onap.ccsdk.apps.blueprintsprocessor.functions.netconf.executor import NetconfRpcService
from org.onap.ccsdk.apps.controllerblueprints.core.utils import JacksonUtils
from org.onap.ccsdk.apps.blueprintsprocessor.functions.netconf.executor.interfaces import DeviceInfo
from org.onap.ccsdk.apps.controllerblueprints.core.service import BluePrintRuntimeService
class DefaultGetNetConfig(AbstractPythonComponentFunction):
def process(self, execution_request):
try:
log = globals()[netconf_constant.SERVICE_LOG]
print(globals())
#requestId = globals()[netconf_constant.PARAM_REQUEST_ID]
requestId = '1234'
bluePrintRuntimeService = globals()['bluePrintRuntimeService']
capabilityProperty = bluePrintRuntimeService.resolveNodeTemplateCapabilityProperties("sample-netconf-device","netconf")
log.info("capabilityProperty {}",capabilityProperty)
netconfService = NetconfRpcService()
nc = NetconfClient(log, netconfService)
nc.connect(netconfService.getNetconfDeviceInfo(capabilityProperty))
runningConfigTemplate = "runningconfig-template"
runningConfigMessageId = "get-config-" + requestId
deviceResponse = nc.getConfig(messageId=runningConfigMessageId,
filter=runningConfigTemplate)
log.info("Get Running Config Response {} ", deviceResponse.responseMessage)
if(deviceResponse !='null') :
status = deviceResponse.status
responseData = "{}"
if (deviceResponse.status != netconf_constant.STATUS_SUCCESS and deviceResponse.errorMessage != 'null'):
errorMessage = "Get Running Config Failure ::"+ deviceResponse.errorMessage
except Exception, err:
log.info("Exception in the script {}",err.getMessage())
status = netconf_constant.STATUS_FAILURE
errorMessage = "Get Running Config Failure ::"+err.getMessage()
def recover(self, runtime_exception, execution_request):
print "Recovering calling.." + PROPERTY_BLUEPRINT_BASE_PATH
return None
|