code: def __init__(self, config, name, control_stream=None):
      Integration.__init__(self, config, name)
      self._streams = []
      self._control_stream = control_stream
  
file_path: mindsdb/mindsdb/interfaces/stream/base/integration.py
imports: from threading import Thread
  import mindsdb.interfaces.storage.db
  from mindsdb.interfaces.stream.utilities import STOP_THREADS_EVENT
  from mindsdb.utilities import log
  from mindsdb.utilities.context import context
label_desc: Use image node_id 1 to create a new StreamIntegration object from inherited base classes: Integration with example: obj = StreamIntegration(config, name, control_stream)