code: def init_health_checkers(self, collection_name=None, file_type="npy"):
      log.info("init health checkers")
      c_name = (
          collection_name
          if collection_name
          else cf.gen_unique_str("BulkInsertChecker")
      )
      fields = [
          FieldSchema(name="id", dtype=DataType.INT64, is_primary=True),
          FieldSchema(
              name="title", dtype=DataType.VARCHAR, max_length=65535
          ),
          FieldSchema(
              name="text", dtype=DataType.VARCHAR, max_length=65535
          ),
          FieldSchema(
              name="url", dtype=DataType.VARCHAR, max_length=65535
          ),
          FieldSchema(name="wiki_id", dtype=DataType.INT64),
          FieldSchema(name="views", dtype=DataType.DOUBLE),
          FieldSchema(name="paragraph_id", dtype=DataType.INT64),
          FieldSchema(name="langs", dtype=DataType.INT64),
          FieldSchema(name="emb", dtype=DataType.FLOAT_VECTOR, dim=768),
      ]
      schema = CollectionSchema(
          fields=fields, description="test collection"
      )
      fields_name = [
          "id",
          "title",
          "text",
          "url",
          "wiki_id",
          "views",
          "paragraph_id",
          "langs",
          "emb",
      ]
      files = []
      if file_type == "json":
          files = ["train-00000-of-00252.json"]
      if file_type == "npy":
          for field_name in fields_name:
              files.append(f"{field_name}.npy")
      if file_type == "parquet":
          files = ["train-00000-of-00252.parquet"]
      checkers = {
          Op.bulk_insert: BulkInsertChecker(
              collection_name=c_name,
              use_one_collection=False,
              schema=schema,
              files=files,
              insert_data=False,
          )
      }
      self.health_checkers = checkers
  
file_path: milvus/tests/python_client/bulk_insert/test_bulk_insert_perf_with_cohere_dataset.py
imports: import pytest
  import threading
  from time import sleep
  from pymilvus import connections, DataType, FieldSchema, CollectionSchema
  from chaos.checker import BulkInsertChecker, Op
  from utils.util_log import test_log
  from chaos import chaos_commons
  from common.common_type import CaseLabel
  from common import common_func
  from chaos import constants
  from delayed_assert import expect, assert_expectations
label_desc: Use image node_id 3 for calling the TestBUlkInsertPerf obj's underlying member method code with example usage: obj.init_health_checkers(collection_name, file_type) without return types