Initial version of dcaeapplib package
Change-Id: I54db903e59a67eb4423cacf10ea957d148b4f853
Issue-ID: DCAEGEN2-354
Signed-off-by: Andrew Gauld <ag1282@att.com>
diff --git a/dcaeapplib/ChangeLog.md b/dcaeapplib/ChangeLog.md
new file mode 100644
index 0000000..0942537
--- /dev/null
+++ b/dcaeapplib/ChangeLog.md
@@ -0,0 +1,6 @@
+# Change Log
+
+All notable changes to this project will be documented in this file.
+
+The format is based on [Keep a Changelog](http://keepachangelog.com/)
+and this project adheres to [Semantic Versioning](http://semver.org/).
diff --git a/dcaeapplib/LICENSE.txt b/dcaeapplib/LICENSE.txt
new file mode 100644
index 0000000..8bdab89
--- /dev/null
+++ b/dcaeapplib/LICENSE.txt
@@ -0,0 +1,17 @@
+============LICENSE_START=======================================================
+Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+================================================================================
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+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.
+============LICENSE_END=========================================================
+
+ECOMP is a trademark and service mark of AT&T Intellectual Property.
diff --git a/dcaeapplib/README.md b/dcaeapplib/README.md
new file mode 100644
index 0000000..81fd825
--- /dev/null
+++ b/dcaeapplib/README.md
@@ -0,0 +1,64 @@
+# dcaeapplib
+
+Library for building DCAE analytics applications
+
+# Example use:
+
+```
+
+class myapp:
+ def __init__(self):
+ # get the environment, and register callbacks for health checks and
+ # configuration changes
+ self.dcaeenv = dcaeapplib.DcaeEnv(healthCB=self.isHealthy, reconfigCB=self.reconfigure)
+ # simulate a configuration change - we want the initial configuration
+ self.reconfigure()
+ # start the environment (to wait for health checks and config changes)
+ self.dcaeenv.start()
+ # begin processing loop
+ while True:
+ if self.configchanged:
+ # fetch the updated configuration
+ self.conig = self.dcaeenv.getconfig()
+ self.configchanged = False
+ # do any setup relevant to the configuration
+ data = self.dcaeenv.getdata('myinputstream')
+ # Data is a UTF-8 string, 'myinputstream' is this application's logical
+ # name for this (one of potentially several) data sources.
+ # Can also specify timeout_ms and limit as arguments.
+ # timeout_ms (default 15,000) is the maximum time getdata() will block
+ # limit is the maximum number of records retrieved at a time.
+ # If no data is retrieved (timeout) the return will be None.
+ if data is not None:
+ # do something to process the data
+ self.dcaeenv.senddata('myoutputstream', 'somepartitionkey', data)
+ # data is a string, 'myoutputstream' is the application's logical
+ # name for this (one of potentially several) data sinks.
+ # somepartitionkey is used, by Kafka, to assign the data to a partition.
+
+ def isHealthy(self):
+ # return the health of the application (True/False)
+ return True
+
+ def reconfigure(self):
+ # Do whatever needs to be done to handle a configuration change
+ self.configchanged = True
+```
+
+# Environment Variables
+
+This library uses the onap-dcae-cbs-docker-client library to fetch
+configuration. That library relies on the HOSTNAME and CONSUL_HOST
+environment variables to find the configuration.
+
+This library provides an HTTP interface for health checks. By default this
+listens on port 80 but can be overridden to use another port by setting the
+DCAEPORT environment variable. The HTTP interface supports getting 2 URLs:
+/healthcheck, which will return a status of 202 (Accepted) for healthy,
+and 503 (Service Unavailable) for unhealthy, and /reconfigure, which triggers
+the library to check for updated configuration.
+
+# Console Commands
+
+This library provides a single console command "reconfigure.sh" which
+performs an HTTP get of the /reconfigure URL
diff --git a/dcaeapplib/dcaeapplib/__init__.py b/dcaeapplib/dcaeapplib/__init__.py
new file mode 100644
index 0000000..e81b6fc
--- /dev/null
+++ b/dcaeapplib/dcaeapplib/__init__.py
@@ -0,0 +1,141 @@
+# org.onap.dcae
+# ============LICENSE_START====================================================
+# Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+# =============================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# 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.
+# ============LICENSE_END======================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+
+import base64
+import json
+import os
+import requests
+from threading import Thread
+import uuid
+from onap_dcae_cbs_docker_client.client import get_config
+
+try:
+ from http.server import BaseHTTPRequestHandler, HTTPServer
+except ImportError:
+ from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
+
+_httpport = int(os.environ['DCAEPORT']) if 'DCAEPORT' in os.environ else 80
+_clientid = uuid.uuid4().hex
+_groupid = uuid.uuid4().hex
+
+class _handler(BaseHTTPRequestHandler):
+ def do_GET(self):
+ if '/healthcheck' == self.path:
+ if self.server.env._health():
+ self.send_response(202)
+ self.end_headers()
+ else:
+ self.send_error(503)
+ elif '/reconfigure' == self.path:
+ self.server.env._loadconfig()
+ self.server.env._reconf()
+ self.send_response(202)
+ self.end_headers()
+ else:
+ self.send_error(404)
+
+class DcaeEnv:
+ def __init__(self, healthCB = lambda:True, reconfigCB = lambda:None):
+ """
+ Initialize environment, but don't start web server or invoke any callbacks.
+ """
+ self._health = healthCB
+ self._reconf = reconfigCB
+ self._unread = {}
+ self._server = None
+ self._loadconfig()
+
+ def start(self):
+ """
+ Start web server to receive health checks and reconfigure requests
+ """
+ if self._server is not None:
+ return
+ self._server = HTTPServer(('', _httpport), _handler)
+ self._server.env = self
+ th = Thread(target=self._server.serve_forever, name='webserver')
+ th.daemon = True
+ th.start()
+
+ def stop(self):
+ """
+ Stop web server
+ """
+ if self._server is None:
+ return
+ self._server.shutdown()
+ self._server.env = None
+ self._server = None
+
+ def _loadconfig(self):
+ self._config = get_config()
+
+ def hasdata(self, stream):
+ """
+ Return whether there is any unprocessed received data for the specified
+ data stream. That is, if an earlier getdata() call returned more than
+ one record, and the additional records have not yet been retrieved.
+ """
+ return stream in self._unread
+
+ def getdata(self, stream, timeout_ms = 15000, limit = 10):
+ """
+ Try to retrieve data from Message Router for the specified data stream.
+ If no data is retrieved, within the specified timeout, return None.
+ """
+ sinfo = self._config['streams_subscribes'][stream]
+ if stream in self._unread:
+ x = self._unread[stream]
+ ret = x.pop()
+ if len(x) == 0:
+ del self._unread[stream]
+ return ret
+ gid = sinfo['client_id'] if 'client_id' in sinfo and sinfo['client_id'] else _groupid
+ resp = requests.get('{0}/{1}/{2}?timeout={3}&limit={4}'.format(sinfo['dmaap_info']['topic_url'], gid, _clientid, timeout_ms, limit), auth=(sinfo['aaf_username'], sinfo['aaf_password']))
+ resp.raise_for_status()
+ x = resp.json()
+ if len(x) == 0:
+ return None
+ if len(x) == 1:
+ return x[0]
+ x.reverse()
+ ret = x.pop()
+ self._unread[stream] = x
+ return ret
+
+ def senddata(self, stream, partition, data):
+ """
+ Publish data to the specified stream.
+ """
+ sinfo = self._config['streams_publishes'][stream]
+ body = '{0}.{1}.{2}{3}'.format(len(partition), len(data), partition, data)
+ resp = requests.post('{0}'.format(sinfo['dmaap_info']['topic_url']), auth=(sinfo['aaf_username'], sinfo['aaf_password']), headers={'Content-Type': 'application/cambria'}, data=body)
+ resp.raise_for_status()
+
+ def getconfig(self):
+ """
+ Get the latest version of the configuration data.
+ """
+ return self._config
+
+def reconfigure():
+ """
+ Make the web request to reconfigure (locally)
+ """
+ requests.get('http://localhost:{0}/reconfigure'.format(_httpport))
diff --git a/dcaeapplib/pom.xml b/dcaeapplib/pom.xml
new file mode 100644
index 0000000..878e7c6
--- /dev/null
+++ b/dcaeapplib/pom.xml
@@ -0,0 +1,241 @@
+<?xml version="1.0"?>
+<!--
+================================================================================
+Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+================================================================================
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+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.
+============LICENSE_END=========================================================
+
+ECOMP is a trademark and service mark of AT&T Intellectual Property.
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.onap.dcaegen2.utils</groupId>
+ <artifactId>utils</artifactId>
+ <version>1.2.0-SNAPSHOT</version>
+ </parent>
+ <groupId>org.onap.dcaegen2.utils</groupId>
+ <artifactId>dcaeapplib</artifactId>
+ <name>dcaeapplib</name>
+ <version>0.0.3-SNAPSHOT</version>
+ <url>http://maven.apache.org</url>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+
+ <sonar.sources>.</sonar.sources>
+ <sonar.junit.reportsPath>xunit-results.xml</sonar.junit.reportsPath>
+ <sonar.python.coverage.reportPath>coverage.xml</sonar.python.coverage.reportPath>
+ <sonar.language>py</sonar.language>
+ <sonar.pluginName>Python</sonar.pluginName>
+ <sonar.inclusions>**/*.py</sonar.inclusions>
+ <sonar.exclusions>tests/*</sonar.exclusions>
+ </properties>
+ <build>
+ <finalName>${project.artifactId}-${project.version}</finalName>
+ <pluginManagement>
+ <plugins>
+ <!-- the following plugins are invoked from oparent, we do not need them -->
+ <plugin>
+ <groupId>org.sonatype.plugins</groupId>
+ <artifactId>nexus-staging-maven-plugin</artifactId>
+ <version>1.6.7</version>
+ <configuration>
+ <skipNexusStagingDeployMojo>true</skipNexusStagingDeployMojo>
+ </configuration>
+ </plugin>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <!-- This version supports the "deployAtEnd" parameter -->
+ <version>2.8</version>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ <!-- first disable the default Java plugins at various stages -->
+ <!-- maven-resources-plugin is called during "*resource" phases by default behavior. it prepares
+ the resources dir. we do not need it -->
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-resources-plugin</artifactId>
+ <version>2.6</version>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ <!-- maven-compiler-plugin is called during "compile" phases by default behavior. we do not need it -->
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>3.1</version>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ <!-- maven-jar-plugin is called during "compile" phase by default behavior. we do not need it -->
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-jar-plugin</artifactId>
+ <version>2.4</version>
+ <executions>
+ <execution>
+ <id>default-jar</id>
+ <phase/>
+ </execution>
+ </executions>
+ </plugin>
+ <!-- maven-install-plugin is called during "install" phase by default behavior. it tries to copy stuff under
+ target dir to ~/.m2. we do not need it -->
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-install-plugin</artifactId>
+ <version>2.4</version>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
+ <!-- maven-surefire-plugin is called during "test" phase by default behavior. it triggers junit test.
+ we do not need it -->
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <version>2.12.4</version>
+ <configuration>
+ <skipTests>true</skipTests>
+ </configuration>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ <plugins>
+ <!-- plugin>
+ <artifactId>maven-assembly-plugin</artifactId>
+ <version>2.4.1</version>
+ <configuration>
+ <descriptors>
+ <descriptor>assembly/dep.xml</descriptor>
+ </descriptors>
+ </configuration>
+ <executions>
+ <execution>
+ <id>make-assembly</id>
+ <phase>package</phase>
+ <goals>
+ <goal>single</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin -->
+ <!-- now we configure custom action (calling a script) at various lifecycle phases -->
+ <plugin>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>exec-maven-plugin</artifactId>
+ <version>1.2.1</version>
+ <executions>
+ <execution>
+ <id>clean phase script</id>
+ <phase>clean</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>clean</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>generate-sources script</id>
+ <phase>generate-sources</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>generate-sources</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>compile script</id>
+ <phase>compile</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>compile</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>package script</id>
+ <phase>package</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>package</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>test script</id>
+ <phase>test</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>test</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>install script</id>
+ <phase>install</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>install</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ <execution>
+ <id>deploy script</id>
+ <phase>deploy</phase>
+ <goals>
+ <goal>exec</goal>
+ </goals>
+ <configuration>
+ <arguments>
+ <argument>${project.artifactId}</argument>
+ <argument>deploy</argument>
+ </arguments>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/dcaeapplib/setup.py b/dcaeapplib/setup.py
new file mode 100644
index 0000000..a19fa7c
--- /dev/null
+++ b/dcaeapplib/setup.py
@@ -0,0 +1,39 @@
+# org.onap.dcae
+# ============LICENSE_START====================================================
+# Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+# =============================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# 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.
+# ============LICENSE_END======================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+
+from setuptools import setup, find_packages
+
+setup(
+ name='dcaeapplib',
+ version='0.0.3',
+ packages=find_packages(),
+ author = 'Andrew Gauld',
+ author_email = 'ag1282@att.com',
+ description = ('Library for building DCAE analytics applications'),
+ license = 'Apache 2.0',
+ keywords = '',
+ url = '',
+ zip_safe = True,
+ install_requires=[ 'onap-dcae-cbs-docker-client>=0.0.2' ],
+ entry_points = {
+ 'console_scripts': [
+ 'reconfigure.sh=dcaeapplib:reconfigure'
+ ]
+ }
+)
diff --git a/dcaeapplib/tests/test_dcaeapplib.py b/dcaeapplib/tests/test_dcaeapplib.py
new file mode 100644
index 0000000..fabec41
--- /dev/null
+++ b/dcaeapplib/tests/test_dcaeapplib.py
@@ -0,0 +1,107 @@
+# org.onap.dcae
+# ============LICENSE_START====================================================
+# Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
+# =============================================================================
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# 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.
+# ============LICENSE_END======================================================
+#
+# ECOMP is a trademark and service mark of AT&T Intellectual Property.
+
+import dcaeapplib
+import requests
+import json
+
+class Stubs:
+ def __init__(self):
+ self.toreturn = [ 's1', 's2', 's3' ]
+ self.config = {
+ "anotherparameter": 1,
+ "streams_subscribes": {
+ "myinputstream": {
+ "aaf_username": "user1",
+ "aaf_password": "pass1",
+ "dmaap_info": {
+ "topic_url": "http://messagerouter.example.com:3904/events/topic1"
+ }
+ }
+ },
+ "streams_publishes": {
+ "myoutputstream": {
+ "aaf_username": "user2",
+ "aaf_password": "pass2",
+ "dmaap_info": {
+ "topic_url": "http://messagerouter.example.com:3904/events/topic2"
+ }
+ }
+ }
+ }
+ self.health = True
+ self.cc = False
+
+ def raise_for_status(self):
+ pass
+
+ def json(self):
+ return self.toreturn
+
+def test_todo(monkeypatch):
+ stuff = Stubs()
+ def stub_config():
+ return json.loads(json.dumps(stuff.config))
+ def stub_hc():
+ return stuff.health
+ def stub_cc():
+ stuff.cc = True
+ monkeypatch.setattr(dcaeapplib, 'get_config', stub_config)
+ monkeypatch.setattr(dcaeapplib, '_httpport', 0)
+ env = dcaeapplib.DcaeEnv(healthCB=stub_hc, reconfigCB=stub_cc)
+ env.stop() # exercise stop when not running
+ env.start()
+ print('Port is {0}'.format(env._server.server_port))
+ monkeypatch.setattr(dcaeapplib, '_httpport', env._server.server_port)
+ stuff.config['anotherparameter'] = 2
+ assert env.getconfig()['anotherparameter'] == 1
+ dcaeapplib.reconfigure()
+ assert stuff.cc is True
+ assert env.getconfig()['anotherparameter'] == 2
+ resp = requests.get('http://localhost:{0}/healthcheck'.format(dcaeapplib._httpport))
+ assert resp.status_code < 300
+ stuff.health = False
+ resp = requests.get('http://localhost:{0}/healthcheck'.format(dcaeapplib._httpport))
+ assert resp.status_code >= 500
+ resp = requests.get('http://localhost:{0}/invalid'.format(dcaeapplib._httpport))
+ assert resp.status_code == 404
+ env.start() # exercise start when already running
+ env.stop()
+ def stub_get(*args, **kwargs):
+ return stuff
+ def stub_post(url, data, *args, **kwargs):
+ assert data == '4.11.asdfhello world'
+ stuff.posted = True
+ return stuff
+ monkeypatch.setattr(requests, 'post', stub_post)
+ stuff.posted = False
+ env.senddata('myoutputstream', 'asdf', 'hello world')
+ assert stuff.posted == True
+ monkeypatch.setattr(requests, 'get', stub_get)
+ assert env.hasdata('myinputstream') is False
+ assert env.getdata('myinputstream') == 's1'
+ stuff.toreturn = [ 'a1' ]
+ assert env.getdata('myinputstream') == 's2'
+ assert env.hasdata('myinputstream') is True
+ assert env.getdata('myinputstream') == 's3'
+ assert env.hasdata('myinputstream') is False
+ assert env.getdata('myinputstream') == 'a1'
+ stuff.toreturn = []
+ assert env.hasdata('myinputstream') is False
+ assert env.getdata('myinputstream') is None
diff --git a/dcaeapplib/tox-local.ini b/dcaeapplib/tox-local.ini
new file mode 100644
index 0000000..935a5d6
--- /dev/null
+++ b/dcaeapplib/tox-local.ini
@@ -0,0 +1,11 @@
+[tox]
+envlist = py27
+[testenv]
+deps=
+ onap-dcae-cbs-docker-client>=0.0.2
+ pytest
+ coverage
+ pytest-cov
+setenv =
+ PYTHONPATH={toxinidir}
+commands=pytest --cov dcaeapplib --cov-report html
diff --git a/dcaeapplib/tox.ini b/dcaeapplib/tox.ini
new file mode 100644
index 0000000..9eb453c
--- /dev/null
+++ b/dcaeapplib/tox.ini
@@ -0,0 +1,11 @@
+[tox]
+envlist = py27,py35
+[testenv]
+deps=
+ onap-dcae-cbs-docker-client>=0.0.2
+ pytest
+ coverage
+ pytest-cov
+setenv =
+ PYTHONPATH={toxinidir}
+commands=pytest --junitxml xunit-results.xml --cov dcaeapplib --cov-report xml
diff --git a/pom.xml b/pom.xml
index c03e65a..6af5fc4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -38,6 +38,7 @@
<module>onap-dcae-dcaepolicy-lib</module>
<module>python-discovery-client</module>
<module>python-dockering</module>
+ <module>dcaeapplib</module>
</modules>
<properties>