code: def __init__(
      self, collection_name=None, host=None, port=None, timeout=300
  ):
      self._collection_name = collection_name
      self._collection_info = None
      self._dimension = None
      start_time = time.time()
      if not host:
          host = config.SERVER_HOST_DEFAULT
      if not port:
          port = config.SERVER_PORT_DEFAULT
      # retry connect remote server
      i = 0
      while time.time() < start_time + timeout:
          try:
              self._milvus = Milvus(
                  host=host,
                  port=port,
                  try_connect=False,
                  pre_ping=False,
              )
              break
          except Exception as e:
              logger.error(str(e))
              logger.error("Milvus connect failed: %d times" % i)
              i = i + 1
              time.sleep(30)
  
      if time.time() > start_time + timeout:
          raise Exception("Server connect timeout")
  
imports: import random
  import logging
  import time
  from multiprocessing import Process
  from pymilvus import Milvus, DataType
  import utils
  import config
  from milvus_benchmark.runners import utils
label_desc: Use image node_id 1 to create a new MilvusClient object from inherited base classes: object with example: obj = MilvusClient(collection_name, host, port, timeout)