code: def get_metrics_querynode_sq_req_count():
      """get metric milvus_querynode_collection_num from prometheus"""
  
      PROMETHEUS = "http://10.96.7.6:9090"
      query_str = (
          'milvus_querynode_sq_req_count{app_kubernetes_io_instance="mic-replica",'
          'app_kubernetes_io_name="milvus",namespace="chaos-testing"}'
      )
  
      response = requests.get(
          PROMETHEUS + "/api/v1/query", params={"query": query_str}
      )
      if response.status_code == 200:
          results = response.json()["data"]["result"]
          # print(results)
          # print(type(results))
          log.debug(json.dumps(results, indent=4))
          milvus_querynode_sq_req_count = {}
          for res in results:
              if res["metric"]["status"] == "total":
                  querynode_id = res["metric"]["node_id"]
                  # pod = res["metric"]["pod"]
                  value = res["value"][-1]
                  milvus_querynode_sq_req_count[
                      int(querynode_id)
                  ] = int(value)
          # log.debug(milvus_querynode_sq_req_count)
          return milvus_querynode_sq_req_count
      else:
          raise Exception(
              -1,
              f"Failed to get metrics with status code {response.status_code}",
          )
  
imports: import json
  import os.path
  import time
  import pyetcd
  import requests
  from pymilvus import connections
  from kubernetes import client, config
  from kubernetes.client.rest import ApiException
  from common.milvus_sys import MilvusSys
  from utils.util_log import test_log
  from chaos import chaos_commons
  from common.common_type import in_cluster_env
label_desc: Use image node_id 11 for calling a global function with example usage: get_metrics_querynode_sq_req_count() and returns: milvus_querynode_sq_req_count