Skip to content
Snippets Groups Projects
Commit a94fe1fd authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Pre-merge Cosmetic changes

parent 25c86b17
No related branches found
No related tags found
2 merge requests!294Release TeraFlowSDN 4.0,!261(CTTC) New Analytics Component
...@@ -13,7 +13,8 @@ ...@@ -13,7 +13,8 @@
# limitations under the License. # limitations under the License.
import logging, signal, sys, threading import logging, signal, sys, threading
from common.Settings import get_log_level from prometheus_client import start_http_server
from common.Settings import get_log_level, get_metrics_port
from .TelemetryBackendService import TelemetryBackendService from .TelemetryBackendService import TelemetryBackendService
terminate = threading.Event() terminate = threading.Event()
...@@ -27,13 +28,17 @@ def main(): ...@@ -27,13 +28,17 @@ def main():
global LOGGER # pylint: disable=global-statement global LOGGER # pylint: disable=global-statement
log_level = get_log_level() log_level = get_log_level()
logging.basicConfig(level=log_level) logging.basicConfig(level=log_level, format="[%(asctime)s] %(levelname)s:%(name)s:%(message)s")
LOGGER = logging.getLogger(__name__) LOGGER = logging.getLogger(__name__)
signal.signal(signal.SIGINT, signal_handler) signal.signal(signal.SIGINT, signal_handler)
signal.signal(signal.SIGTERM, signal_handler) signal.signal(signal.SIGTERM, signal_handler)
LOGGER.debug('Starting...') LOGGER.info('Starting...')
# Start metrics server
metrics_port = get_metrics_port()
start_http_server(metrics_port)
grpc_service = TelemetryBackendService() grpc_service = TelemetryBackendService()
grpc_service.start() grpc_service.start()
...@@ -41,10 +46,10 @@ def main(): ...@@ -41,10 +46,10 @@ def main():
# Wait for Ctrl+C or termination signal # Wait for Ctrl+C or termination signal
while not terminate.wait(timeout=1.0): pass while not terminate.wait(timeout=1.0): pass
LOGGER.debug('Terminating...') LOGGER.info('Terminating...')
grpc_service.stop() grpc_service.stop()
LOGGER.debug('Bye') LOGGER.info('Bye')
return 0 return 0
if __name__ == '__main__': if __name__ == '__main__':
......
...@@ -28,13 +28,13 @@ def main(): ...@@ -28,13 +28,13 @@ def main():
global LOGGER # pylint: disable=global-statement global LOGGER # pylint: disable=global-statement
log_level = get_log_level() log_level = get_log_level()
logging.basicConfig(level=log_level) logging.basicConfig(level=log_level, format="[%(asctime)s] %(levelname)s:%(name)s:%(message)s")
LOGGER = logging.getLogger(__name__) LOGGER = logging.getLogger(__name__)
signal.signal(signal.SIGINT, signal_handler) signal.signal(signal.SIGINT, signal_handler)
signal.signal(signal.SIGTERM, signal_handler) signal.signal(signal.SIGTERM, signal_handler)
LOGGER.debug('Starting...') LOGGER.info('Starting...')
# Start metrics server # Start metrics server
metrics_port = get_metrics_port() metrics_port = get_metrics_port()
...@@ -46,10 +46,10 @@ def main(): ...@@ -46,10 +46,10 @@ def main():
# Wait for Ctrl+C or termination signal # Wait for Ctrl+C or termination signal
while not terminate.wait(timeout=1.0): pass while not terminate.wait(timeout=1.0): pass
LOGGER.debug('Terminating...') LOGGER.info('Terminating...')
grpc_service.stop() grpc_service.stop()
LOGGER.debug('Bye') LOGGER.info('Bye')
return 0 return 0
if __name__ == '__main__': if __name__ == '__main__':
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment