code: def _on_connection(self, data, unique_id):
          
          if unique_id is None:
              unique_id = self.stream_unique_id
          self.connection_id = data.get('connectionId')
          logger.info('[Connect: %s]: connection_id: %s' % (unique_id, self.connection_id))
docs: Called on collection operation
  
          :param data: Received data