diff --git a/src/nbi/service/vntm_recommend/Namespaces.py b/src/nbi/service/vntm_recommend/Namespaces.py index a7660f85912391f2ea8984971254cd819b6892da..b19550fae4422d81230cd29143a6a3f3c333484e 100644 --- a/src/nbi/service/vntm_recommend/Namespaces.py +++ b/src/nbi/service/vntm_recommend/Namespaces.py @@ -37,23 +37,24 @@ class VntRecommServerNamespace(Namespace): def on_connect(self, auth): MSG = '[on_connect] Client connect: sid={:s}, auth={:s}' - LOGGER.info(MSG.format(str(request.sid), str(auth))) + LOGGER.debug(MSG.format(str(request.sid), str(auth))) join_room(SIO_ROOM, namespace=SIO_NAMESPACE) def on_disconnect(self, reason): MSG = '[on_disconnect] Client disconnect: sid={:s}, reason={:s}' - LOGGER.info(MSG.format(str(request.sid), str(reason))) + LOGGER.debug(MSG.format(str(request.sid), str(reason))) leave_room(SIO_ROOM, namespace=SIO_NAMESPACE) def on_vlink_created(self, data): MSG = '[on_vlink_created] begin: sid={:s}, data={:s}' - LOGGER.info(MSG.format(str(request.sid), str(data))) + LOGGER.debug(MSG.format(str(request.sid), str(data))) data = json.loads(data) - request_key = data.pop('_request_key') - + request_key = str(data.pop('_request_key')).encode('utf-8') vntm_reply = json.dumps({'event': 'vlink_created', 'data': data}).encode('utf-8') - LOGGER.info('[on_vlink_created] vntm_reply={:s}'.format(str(vntm_reply))) + LOGGER.debug('[on_vlink_created] request_key={:s}/{:s}'.format(str(type(request_key)), str(request_key))) + LOGGER.debug('[on_vlink_created] vntm_reply={:s}/{:s}'.format(str(type(vntm_reply)), str(vntm_reply))) + self.kafka_producer.send( KafkaTopic.VNTMANAGER_RESPONSE.value, key=request_key, value=vntm_reply ) @@ -61,13 +62,14 @@ class VntRecommServerNamespace(Namespace): def on_vlink_removed(self, data): MSG = '[on_vlink_removed] begin: sid={:s}, data={:s}' - LOGGER.info(MSG.format(str(request.sid), str(data))) + LOGGER.debug(MSG.format(str(request.sid), str(data))) data = json.loads(data) - request_key = data.pop('_request_key') - + request_key = str(data.pop('_request_key')).encode('utf-8') vntm_reply = json.dumps({'event': 'vlink_removed', 'data': data}).encode('utf-8') - LOGGER.info('[on_vlink_removed] vntm_reply={:s}'.format(str(vntm_reply))) + LOGGER.debug('[on_vlink_removed] request_key={:s}/{:s}'.format(str(type(request_key)), str(request_key))) + LOGGER.debug('[on_vlink_removed] vntm_reply={:s}/{:s}'.format(str(type(vntm_reply)), str(vntm_reply))) + self.kafka_producer.send( KafkaTopic.VNTMANAGER_RESPONSE.value, key=request_key, value=vntm_reply )