diff --git a/common/command.py b/common/command.py
index 9e1ded07..f62134f8 100644
--- a/common/command.py
+++ b/common/command.py
@@ -243,7 +243,7 @@ def get_observer_version(context):
         stdio.verbose("get observer version, by sql")
         obcluster = context.cluster_config
         # by sql
-        observer_version = get_observer_version_by_sql(obcluster, stdio)
+        observer_version = get_observer_version_by_sql(context, obcluster)
     except Exception as e:
         try:
             stdio.verbose("get observer version, by sql fail. by ssh")
@@ -325,15 +325,15 @@ def get_obproxy_version(context):
 # Only applicable to the community version
 
 
-def get_observer_version_by_sql(ob_cluster, stdio=None):
-    stdio.verbose("start get_observer_version_by_sql . input: {0}:{1}".format(ob_cluster.get("db_host"), ob_cluster.get("db_port")))
+def get_observer_version_by_sql(context, ob_cluster):
+    context.stdio.verbose("start get_observer_version_by_sql . input: {0}:{1}".format(ob_cluster.get("db_host"), ob_cluster.get("db_port")))
     try:
-        ob_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=stdio, timeout=100)
+        ob_connector = OBConnector(context=context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
         ob_version_info = ob_connector.execute_sql("select version();")
     except Exception as e:
         raise Exception("get_observer_version_by_sql Exception. Maybe cluster'info is error: " + e.__str__())
     ob_version = ob_version_info[0]
-    stdio.verbose("get_observer_version_by_sql ob_version_info is {0}".format(ob_version))
+    context.stdio.verbose("get_observer_version_by_sql ob_version_info is {0}".format(ob_version))
     version = re.findall(r'OceanBase(_)?(.CE)?-v(.+)', ob_version[0])
     if len(version) > 0:
         return version[0][2]
diff --git a/common/config_helper.py b/common/config_helper.py
index 292afbe4..dbf2b030 100644
--- a/common/config_helper.py
+++ b/common/config_helper.py
@@ -55,7 +55,7 @@ def __init__(self, context):
 
     def get_cluster_name(self):
         ob_version = get_observer_version(self.context)
-        obConnetcor = OBConnector(ip=self.db_host, port=self.db_port, username=self.sys_tenant_user, password=self.sys_tenant_password, stdio=self.stdio, timeout=100)
+        obConnetcor = OBConnector(context=self.context, ip=self.db_host, port=self.db_port, username=self.sys_tenant_user, password=self.sys_tenant_password, timeout=100)
         if ob_version.startswith("3") or ob_version.startswith("2"):
             sql = "select cluster_name from oceanbase.v$ob_cluster"
             res = obConnetcor.execute_sql(sql)
@@ -68,7 +68,7 @@ def get_cluster_name(self):
 
     def get_host_info_list_by_cluster(self):
         ob_version = get_observer_version(self.context)
-        obConnetcor = OBConnector(ip=self.db_host, port=self.db_port, username=self.sys_tenant_user, password=self.sys_tenant_password, stdio=self.stdio, timeout=100)
+        obConnetcor = OBConnector(context=self.context, ip=self.db_host, port=self.db_port, username=self.sys_tenant_user, password=self.sys_tenant_password, timeout=100)
         sql = "select SVR_IP, SVR_PORT, ZONE, BUILD_VERSION from oceanbase.DBA_OB_SERVERS"
         if ob_version.startswith("3") or ob_version.startswith("2") or ob_version.startswith("1"):
             sql = "select SVR_IP, SVR_PORT, ZONE, BUILD_VERSION from oceanbase.__all_server"
diff --git a/common/ob_connector.py b/common/ob_connector.py
index 4383738f..02cc9d70 100644
--- a/common/ob_connector.py
+++ b/common/ob_connector.py
@@ -28,21 +28,22 @@ class OBConnector(object):
 
     def __init__(
         self,
+        context,
         ip,
         port,
         username,
         password=None,
         database=None,
-        stdio=None,
         timeout=30,
     ):
+        self.context = context
         self.ip = str(ip)
         self.port = int(port)
         self.username = str(username)
         self.password = str(password)
         self.timeout = timeout
         self.conn = None
-        self.stdio = stdio
+        self.stdio = context.stdio
         self.database = database
         self.init()
 
diff --git a/core.py b/core.py
index 41cdc039..a682f3cf 100644
--- a/core.py
+++ b/core.py
@@ -139,7 +139,7 @@ def set_context(self, handler_name, namespace, config):
             stdio=self.stdio,
             inner_config=self.inner_config_manager.config,
         )
-        telemetry.set_cluster_conn(config.get_ob_cluster_config)
+        telemetry.set_cluster_conn(self.context, config.get_ob_cluster_config)
 
     def set_context_skip_cluster_conn(self, handler_name, namespace, config):
         self.context = HandlerContext(
@@ -175,7 +175,7 @@ def update_obcluster_nodes(self, config):
             return
 
         ob_version = get_observer_version_by_sql(ob_cluster, self.stdio)
-        obConnetcor = OBConnector(ip=ob_cluster["db_host"], port=ob_cluster["db_port"], username=ob_cluster["tenant_sys"]["user"], password=ob_cluster["tenant_sys"]["password"], stdio=self.stdio)
+        obConnetcor = OBConnector(context=self.context, ip=ob_cluster["db_host"], port=ob_cluster["db_port"], username=ob_cluster["tenant_sys"]["user"], password=ob_cluster["tenant_sys"]["password"])
 
         sql = "select SVR_IP, SVR_PORT, ZONE, BUILD_VERSION from oceanbase.__all_server"
         if ob_version.startswith(("1", "2", "3")):
diff --git a/handler/analyzer/analyze_index_space.py b/handler/analyzer/analyze_index_space.py
index ba2b2419..5909e275 100644
--- a/handler/analyzer/analyze_index_space.py
+++ b/handler/analyzer/analyze_index_space.py
@@ -58,7 +58,7 @@ def init_option(self):
         ob_cluster = self.context.cluster_config
         self.stdio.verbose('cluster config: {0}'.format(StringUtils.mask_passwords(ob_cluster)))
         self.ob_cluster = ob_cluster
-        self.sys_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100)
+        self.sys_connector = OBConnector(context=self.context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
         tenant_name = Util.get_option(options, 'tenant_name')
         table_name = Util.get_option(options, 'table_name')
         index_name = Util.get_option(options, 'index_name')
diff --git a/handler/analyzer/analyze_memory.py b/handler/analyzer/analyze_memory.py
index 4ed5cc10..980c438b 100644
--- a/handler/analyzer/analyze_memory.py
+++ b/handler/analyzer/analyze_memory.py
@@ -130,7 +130,7 @@ def init_option(self):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.ob_cluster, self.stdio)
+            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
         except Exception as e:
             self.stdio.exception("failed to get observer version:{0}".format(e))
         self.stdio.verbose("get observer version: {0}".format(observer_version))
diff --git a/handler/analyzer/analyze_parameter.py b/handler/analyzer/analyze_parameter.py
index 40e5c012..7f8df5d3 100644
--- a/handler/analyzer/analyze_parameter.py
+++ b/handler/analyzer/analyze_parameter.py
@@ -44,11 +44,11 @@ def __init__(self, context, analyze_type='default'):
         self.observer_nodes = self.context.cluster_config.get("servers")
         try:
             self.obconn = OBConnector(
+                context=self.context,
                 ip=self.ob_cluster.get("db_host"),
                 port=self.ob_cluster.get("db_port"),
                 username=self.ob_cluster.get("tenant_sys").get("user"),
                 password=self.ob_cluster.get("tenant_sys").get("password"),
-                stdio=self.stdio,
                 timeout=10000,
                 database="oceanbase",
             )
@@ -59,7 +59,7 @@ def __init__(self, context, analyze_type='default'):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.ob_cluster, self.stdio)
+            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
         except Exception as e:
             self.stdio.warn("failed to get observer version:{0}".format(e))
         self.stdio.verbose("get observer version: {0}".format(observer_version))
diff --git a/handler/analyzer/analyze_queue.py b/handler/analyzer/analyze_queue.py
index 62cf11cb..fc26a46c 100644
--- a/handler/analyzer/analyze_queue.py
+++ b/handler/analyzer/analyze_queue.py
@@ -64,11 +64,11 @@ def __init__(self, context):
         self.scope = None
         try:
             self.obconn = OBConnector(
+                context=self.context,
                 ip=self.ob_cluster.get("db_host"),
                 port=self.ob_cluster.get("db_port"),
                 username=self.ob_cluster.get("tenant_sys").get("user"),
                 password=self.ob_cluster.get("tenant_sys").get("password"),
-                stdio=self.stdio,
                 timeout=10000,
                 database="oceanbase",
             )
@@ -159,7 +159,7 @@ def init_option(self):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.ob_cluster, self.stdio)
+            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
         except Exception as e:
             self.stdio.warn("AnalyzeQueueHandler failed to get observer version:{0}".format(e))
         self.stdio.verbose("AnalyzeQueueHandler get observer version: {0}".format(observer_version))
diff --git a/handler/analyzer/analyze_sql.py b/handler/analyzer/analyze_sql.py
index ded4f21b..98cb38ef 100644
--- a/handler/analyzer/analyze_sql.py
+++ b/handler/analyzer/analyze_sql.py
@@ -120,7 +120,7 @@ def init_config(self):
         ob_cluster = self.context.cluster_config
         self.stdio.verbose('cluster config: {0}'.format(StringUtils.mask_passwords(ob_cluster)))
         self.ob_cluster = ob_cluster
-        self.sys_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100)
+        self.sys_connector = OBConnector(context=self.context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
         self.ob_cluster_name = ob_cluster.get("ob_cluster_name")
         self.stdio.print('init cluster config complete')
         return True
@@ -134,7 +134,7 @@ def init_ob_version(self):
     def init_db_connector(self):
         if self.db_user:
             self.db_connector_provided = True
-            self.db_connector = OBConnector(ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.db_user, password=self.db_password, stdio=self.stdio, timeout=100)
+            self.db_connector = OBConnector(context=self.context, ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.db_user, password=self.db_password, timeout=100)
         else:
             self.db_connector = self.sys_connector
 
diff --git a/handler/analyzer/analyze_sql_review.py b/handler/analyzer/analyze_sql_review.py
index f2c8494d..03245d38 100644
--- a/handler/analyzer/analyze_sql_review.py
+++ b/handler/analyzer/analyze_sql_review.py
@@ -58,7 +58,7 @@ def init_config(self):
         ob_cluster = self.context.cluster_config
         self.stdio.verbose('cluster config: {0}'.format(StringUtils.mask_passwords(ob_cluster)))
         self.ob_cluster = ob_cluster
-        self.sys_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100)
+        self.sys_connector = OBConnector(context=self.context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
         self.ob_cluster_name = ob_cluster.get("ob_cluster_name")
         self.stdio.print('init cluster config complete')
         return True
@@ -67,7 +67,7 @@ def init_db_connector(self):
         if self.db_user:
             self.stdio.verbose("init db connector start")
             self.db_connector_provided = True
-            self.db_connector = OBConnector(ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.db_user, password=self.db_password, stdio=self.stdio, timeout=100)
+            self.db_connector = OBConnector(context=self.context, ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.db_user, password=self.db_password, timeout=100)
             self.stdio.verbose("init db connector complete")
         else:
             self.db_connector = self.sys_connector
diff --git a/handler/analyzer/analyze_variable.py b/handler/analyzer/analyze_variable.py
index 9199e77a..ce882b82 100644
--- a/handler/analyzer/analyze_variable.py
+++ b/handler/analyzer/analyze_variable.py
@@ -42,11 +42,11 @@ def __init__(self, context, analyze_type='diff'):
         self.observer_nodes = self.context.cluster_config.get("servers")
         try:
             self.obconn = OBConnector(
+                context=self.context,
                 ip=self.ob_cluster.get("db_host"),
                 port=self.ob_cluster.get("db_port"),
                 username=self.ob_cluster.get("tenant_sys").get("user"),
                 password=self.ob_cluster.get("tenant_sys").get("password"),
-                stdio=self.stdio,
                 timeout=10000,
                 database="oceanbase",
             )
diff --git a/handler/checker/check_handler.py b/handler/checker/check_handler.py
index aced1a8e..a5fc20c9 100644
--- a/handler/checker/check_handler.py
+++ b/handler/checker/check_handler.py
@@ -261,7 +261,7 @@ def __init__(self, context, max_size, cluster):
         self.stdio.verbose("obConnectorPool init success!")
         try:
             for i in range(max_size):
-                conn = OBConnector(ip=self.cluster.get("db_host"), port=self.cluster.get("db_port"), username=self.cluster.get("tenant_sys").get("user"), password=self.cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=10000)
+                conn = OBConnector(context=context, ip=self.cluster.get("db_host"), port=self.cluster.get("db_port"), username=self.cluster.get("tenant_sys").get("user"), password=self.cluster.get("tenant_sys").get("password"), timeout=10000)
                 self.connections.put(conn)
             self.stdio.verbose("obConnectorPool init success!")
         except Exception as e:
diff --git a/handler/display/display_scenes.py b/handler/display/display_scenes.py
index bc1c998d..e20c876e 100644
--- a/handler/display/display_scenes.py
+++ b/handler/display/display_scenes.py
@@ -57,7 +57,7 @@ def __init__(self, context, display_pack_dir='./', tasks_base_path="~/.obdiag/di
 
     def init_config(self):
         self.cluster = self.context.cluster_config
-        self.sys_connector = OBConnector(ip=self.cluster.get("db_host"), port=self.cluster.get("db_port"), username=self.cluster.get("tenant_sys").get("user"), password=self.cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100)
+        self.sys_connector = OBConnector(context=self.context, ip=self.cluster.get("db_host"), port=self.cluster.get("db_port"), username=self.cluster.get("tenant_sys").get("user"), password=self.cluster.get("tenant_sys").get("password"), timeout=100)
         self.obproxy_nodes = self.context.obproxy_config['servers']
         self.ob_nodes = self.context.cluster_config['servers']
         new_nodes = Util.get_nodes_list(self.context, self.ob_nodes, self.stdio)
@@ -89,7 +89,7 @@ def execute(self):
             self.stdio.error("Internal error :{0}".format(e))
 
     def __init_db_connector(self):
-        self.db_connector = OBConnector(ip=self.db_conn.get("host"), port=self.db_conn.get("port"), username=self.db_conn.get("user"), password=self.db_conn.get("password"), database=self.db_conn.get("database"), stdio=self.stdio, timeout=100)
+        self.db_connector = OBConnector(context=self.context, ip=self.db_conn.get("host"), port=self.db_conn.get("port"), username=self.db_conn.get("user"), password=self.db_conn.get("password"), database=self.db_conn.get("database"), timeout=100)
 
     def __init_db_conn(self, cli_connection_string):
         try:
diff --git a/handler/gather/gather_ash_report.py b/handler/gather/gather_ash_report.py
index 410f1d55..cac8e8a9 100644
--- a/handler/gather/gather_ash_report.py
+++ b/handler/gather/gather_ash_report.py
@@ -53,7 +53,13 @@ def __init__(self, context, gather_pack_dir='./'):
         self.observer_nodes = self.context.cluster_config.get("servers")
         try:
             self.obconn = OBConnector(
-                ip=self.cluster.get("db_host"), port=self.cluster.get("db_port"), username=self.cluster.get("tenant_sys").get("user"), password=self.cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=10000, database="oceanbase"
+                context=self.context,
+                ip=self.cluster.get("db_host"),
+                port=self.cluster.get("db_port"),
+                username=self.cluster.get("tenant_sys").get("user"),
+                password=self.cluster.get("tenant_sys").get("password"),
+                timeout=10000,
+                database="oceanbase",
             )
         except Exception as e:
             self.stdio.error("Failed to connect to database: {0}".format(e))
diff --git a/handler/gather/gather_parameters.py b/handler/gather/gather_parameters.py
index 359ff423..439536f2 100644
--- a/handler/gather/gather_parameters.py
+++ b/handler/gather/gather_parameters.py
@@ -40,11 +40,11 @@ def __init__(self, context, gather_pack_dir='./'):
         self.observer_nodes = self.context.cluster_config.get("servers")
         try:
             self.obconn = OBConnector(
+                context=self.context,
                 ip=self.ob_cluster.get("db_host"),
                 port=self.ob_cluster.get("db_port"),
                 username=self.ob_cluster.get("tenant_sys").get("user"),
                 password=self.ob_cluster.get("tenant_sys").get("password"),
-                stdio=self.stdio,
                 timeout=10000,
                 database="oceanbase",
             )
@@ -77,7 +77,7 @@ def init_option(self):
     def get_version(self):
         observer_version = ""
         try:
-            observer_version = get_observer_version_by_sql(self.ob_cluster, self.stdio)
+            observer_version = get_observer_version_by_sql(self.context, self.ob_cluster)
         except Exception as e:
             self.stdio.warn("failed to get observer version:{0}".format(e))
         self.stdio.verbose("get observer version: {0}".format(observer_version))
diff --git a/handler/gather/gather_plan_monitor.py b/handler/gather/gather_plan_monitor.py
index 81ec817a..b652e351 100644
--- a/handler/gather/gather_plan_monitor.py
+++ b/handler/gather/gather_plan_monitor.py
@@ -63,7 +63,7 @@ def __init__(self, context, gather_pack_dir='./', is_scene=False):
     def init_config(self):
         ob_cluster = self.context.cluster_config
         self.ob_cluster = ob_cluster
-        self.sys_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100)
+        self.sys_connector = OBConnector(context=self.context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=100)
         self.ob_cluster_name = ob_cluster.get("ob_cluster_name")
         return True
 
@@ -92,7 +92,7 @@ def init_option(self):
         return self.tenant_mode_detected()
 
     def __init_db_connector(self):
-        self.db_connector = OBConnector(ip=self.db_conn.get("host"), port=self.db_conn.get("port"), username=self.db_conn.get("user"), password=self.db_conn.get("password"), database=self.db_conn.get("database"), stdio=self.stdio, timeout=100)
+        self.db_connector = OBConnector(context=self.context, ip=self.db_conn.get("host"), port=self.db_conn.get("port"), username=self.db_conn.get("user"), password=self.db_conn.get("password"), database=self.db_conn.get("database"), timeout=100)
 
     def handle(self):
         if not self.init_config():
diff --git a/handler/gather/gather_tabledump.py b/handler/gather/gather_tabledump.py
index 0d0c2130..46a2626c 100644
--- a/handler/gather/gather_tabledump.py
+++ b/handler/gather/gather_tabledump.py
@@ -88,9 +88,9 @@ def init(self):
             else:
                 self.tenant_name = self.__extract_string(user)
             self.ob_connector = OBConnector(
-                ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.ob_cluster.get("tenant_sys").get("user"), password=self.ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=100
+                context=self.context, ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=self.ob_cluster.get("tenant_sys").get("user"), password=self.ob_cluster.get("tenant_sys").get("password"), timeout=100
             )
-            self.tenant_connector = OBConnector(ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=user, password=password, stdio=self.stdio, timeout=100)
+            self.tenant_connector = OBConnector(context=self.context, ip=self.ob_cluster.get("db_host"), port=self.ob_cluster.get("db_port"), username=user, password=password, timeout=100)
             self.file_name = "{0}/obdiag_tabledump_result_{1}.txt".format(self.store_dir, TimeUtils.timestamp_to_filename_time(self.gather_timestamp))
             return True
         except Exception as e:
diff --git a/handler/gather/gather_variables.py b/handler/gather/gather_variables.py
index 970e5ad2..1c620abc 100644
--- a/handler/gather/gather_variables.py
+++ b/handler/gather/gather_variables.py
@@ -39,11 +39,11 @@ def __init__(self, context, gather_pack_dir='./'):
         self.observer_nodes = self.context.cluster_config.get("servers")
         try:
             self.obconn = OBConnector(
+                context=self.context,
                 ip=self.ob_cluster.get("db_host"),
                 port=self.ob_cluster.get("db_port"),
                 username=self.ob_cluster.get("tenant_sys").get("user"),
                 password=self.ob_cluster.get("tenant_sys").get("password"),
-                stdio=self.stdio,
                 timeout=10000,
                 database="oceanbase",
             )
diff --git a/handler/gather/step/sql.py b/handler/gather/step/sql.py
index 8f6e8050..c754fca6 100644
--- a/handler/gather/step/sql.py
+++ b/handler/gather/step/sql.py
@@ -34,7 +34,7 @@ def __init__(self, context, step, ob_cluster, report_path, task_variable_dict, e
             self.sys_database = None
             self.database = None
             self.env = env
-            self.ob_connector = OBConnector(ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=10000)
+            self.ob_connector = OBConnector(context=self.context, ip=ob_cluster.get("db_host"), port=ob_cluster.get("db_port"), username=ob_cluster.get("tenant_sys").get("user"), password=ob_cluster.get("tenant_sys").get("password"), timeout=10000)
         except Exception as e:
             self.stdio.error("StepSQLHandler init fail. Please check the OBCLUSTER conf. OBCLUSTER: {0} Exception : {1} .".format(ob_cluster, e))
         self.task_variable_dict = task_variable_dict
diff --git a/handler/rca/rca_handler.py b/handler/rca/rca_handler.py
index 581197bb..2546a65c 100644
--- a/handler/rca/rca_handler.py
+++ b/handler/rca/rca_handler.py
@@ -79,11 +79,11 @@ def __init__(self, context):
         try:
             if self.ob_cluster is not None:
                 ob_connector = OBConnector(
+                    context=self.context,
                     ip=self.ob_cluster.get("db_host"),
                     port=self.ob_cluster.get("db_port"),
                     username=self.ob_cluster.get("tenant_sys").get("user"),
                     password=self.ob_cluster.get("tenant_sys").get("password"),
-                    stdio=self.stdio,
                     timeout=10000,
                 )
                 self.context.set_variable("ob_connector", ob_connector)
diff --git a/telemetry/telemetry.py b/telemetry/telemetry.py
index 5c9e2f68..680510e8 100644
--- a/telemetry/telemetry.py
+++ b/telemetry/telemetry.py
@@ -48,7 +48,7 @@ def __init__(self):
         self.version = get_obdiag_version()
         self.stdio = IO(1)
 
-    def set_cluster_conn(self, obcluster):
+    def set_cluster_conn(self, context, obcluster):
         try:
             if not self.work_tag:
                 return
@@ -60,7 +60,7 @@ def set_cluster_conn(self, obcluster):
             if obcluster is not None:
                 try:
 
-                    self.cluster_conn = OBConnector(ip=obcluster.get("db_host"), port=obcluster.get("db_port"), username=obcluster.get("tenant_sys").get("user"), password=obcluster.get("tenant_sys").get("password"), stdio=self.stdio, timeout=10000)
+                    self.cluster_conn = OBConnector(context=context, ip=obcluster.get("db_host"), port=obcluster.get("db_port"), username=obcluster.get("tenant_sys").get("user"), password=obcluster.get("tenant_sys").get("password"), timeout=10000)
                     self.threads.append(threading.Thread(None, self.get_cluster_info()))
                     # self.threads.append(threading.Thread(None, self.get_tenant_info()))
                     for thread in self.threads: