set @@global.ob_sql_work_area_percentage = 30;  -- 定义租户的SQL层可使用的内存空间占比
set @@global.parallel_max_servers=900;  -- 提高px可同时并发的线程数上限
set @@global.parallel_servers_target=900;  -- 提高px并行度

set @@global.recyclebin='OFF';  -- 关闭回收站

#!/usr/bin/env python
# coding=utf-8

import sys,os,time
import yaml
import MySQLdb
from getopt import getopt, GetoptError


class Option():
    OB_CONFIG = """{
        ob_cluster_int_params:{
          clog_disk_usage_limit_percentage: 90,
          data_disk_usage_limit_percentage: 90,
          minor_freeze_times: 3,
          cpu_reserved: 2,
          memory_limit_percentage: 90,
          memstore_limit_percentage: 70,
          freeze_trigger_percentage: 50,
          max_syslog_file_count: 100,
          zone_merge_concurrency: 0,
          merge_thread_count: 0,
          global_write_halt_residual_memory: 30,
          global_major_freeze_residual_memory: 40,
          minor_merge_concurrency: 0,
          large_query_worker_percentage: 30,
          sys_bkgd_net_percentage: 60,
          user_iort_up_percentage: 100,
          sys_bkgd_io_high_percentage: 90,
          sys_bkgd_io_low_percentage: 0
          },
        ob_cluster_str_params:{
          autoinc_cache_refresh_interval: 72000s,
          syslog_level: INFO,
          enable_syslog_recycle: true,
          enable_merge_by_turn: false,
          major_freeze_duty_time: "02:00",
          merger_warm_up_duration_time: 300s,
          minor_warm_up_duration_time: 300s,
          large_query_threshold: 500ms,
          trx_force_kill_threshold: 100ms,
          zone_merge_timeout: 3h,
          trx_try_wait_lock_timeout: 0ms,
          trace_log_slow_query_watermark: 100ms,
          syslog_io_bandwidth_limit: 30MB,
          default_compress_func: "zstd_1.0"
          }
        }
        """
    hosts = os.getenv('OB_SERVER_IP_LIST', '127.1')
    host = hosts.split(',')[0]
    port = int(os.getenv('OB_SERVER_SQL_PORT', 2881))
    user = 'root@sys'
    password = os.getenv('OB_SERVER_PASSWD', '')
    database = 'oceanbase'
    params = yaml.load(OB_CONFIG)

class ObConn():
def __init__(self):
            self.conn = MySQLdb.connect(host=Option.host, port=Option.port, user=Option.user, passwd=Option.password, db=Option.database)

def run_sql(self, sql_str):
try:
            cursor = self.conn.cursor(MySQLdb.cursors.DictCursor)
            rows_count = cursor.execute(sql_str)
except MySQLdb.Error as err:
print(err)
            sys.exit(1)
else:
if rows_count > 0:
                rows = cursor.fetchall()
                cursor.close()
return rows
else:
                cursor.close()
return None

def close(self):
        self.conn.close()

def parse_arg():
try:
        opts, args = getopt(sys.argv[1:], "h:P:u:p:", ["help", "host=", "port=", "password="])
except GetoptError as err:
print str(err)
print('Usage: python obparam.py [-h|--host=HOST] [-P|--port=PORT] [-u|--user=USER] [-p|--password=PASSWORD]')
        sys.exit(1)
for o, v in opts:
if o == "--help":
            usage()
            sys.exit(1)
elif o in ("-h", "--host"):
            Option.host = v
elif o in ("-P", "--port"):
            Option.port = int(v)
elif o in ("-p", "--password"):
            Option.password = v
elif o in ("-u", "--user"):
            Option.user = v
else:
assert False, "unhandled option"

def Main():
    parse_arg()
    db_conn = ObConn()
for k,v in Option.params['ob_cluster_int_params'].iteritems():
        db_conn.run_sql("alter system set {0} = {1}".format(k, int(v)))
print(k, v)
for k,v in Option.params['ob_cluster_str_params'].iteritems():
        db_conn.run_sql("alter system set {0} = '{1}'".format(k, v))
print(k, v)

if __name__ == "__main__":
    Main()

sudo yum -y install MySQL-python.x86_64 PyYAML.x86_64

• 从ORACLE/MySQL到OceanBase：参数或变量

• OceanBase实践入门技术序列