StarRocks 排查单副本表

文章目录

• 
  
  
  
  • StarRocks 排查单副本表
    
  • 
    
    
    
    • 方式1 查询元数据，检查分区级的副本数
      
    • 方式2 SHOW PARTITIONS命令查看 ReplicationNum
      
    • 修改副本数命令
      
    
    
  
  

StarRocks 排查单副本表

方式1 查询元数据，检查分区级的副本数

1. # 方式一 查询元数据，检查分区级的副本数
2. with v_tmp1 as (
3.   select
4.     TABLE_ID, PARTITION_ID, tablet_id, count(*) as cnt
5.   from
6.     information_schema.be_tablets
7.   group by
8.     TABLE_ID, PARTITION_ID, tablet_id
9.   having
10.     count(*) = 1
11. )
12. select /*+ set_var(query_timeout = 20) */
13.   distinct t1.TABLE_SCHEMA, t1.TABLE_NAME
14. from information_schema.tables_config t1
15. join v_tmp1 t2 on t1.TABLE_ID = t2.TABLE_ID
16. ;

复制代码

方式2 SHOW PARTITIONS命令查看 ReplicationNum

1. # 方式二 遍历所有库表SHOW PARTITIONS命令查看 ReplicationNum
2. SHOW  PARTITIONS FROM [db_name.]table_name WHERE ReplicationNum = 1

复制代码

修改副本数命令

1. # 修改副本数命令
2. # 修改表基本副本数
3. ALTER TABLE example_db.my_table SET ("default.replication_num" = "2");
4. # 单分区副本数
5. ALTER TABLE example_db.my_table SET ("replication_num" = "2");
6. # 历史分区副本数
7. ALTER TABLE example_db.my_table MODIFY PARTITION (*) SET("replication_num"="2");

复制代码

遍历所有库表实行SHOW PARTITIONS命令

1. import pymysql
2. import logging
3. logging.basicConfig(level=logging.INFO,
4.                     format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
5.                     filemode='a',
6.                     filename='./sr.log'
7.                     )
9. ip = '10.xx'
10. port = 9030
11. user = 'xx'
12. passwd = 'xx'
13. database = 'information_schema'
15. class MysqlUtils(object):
16.     def __init__(self, ip, port, user, passwd, database):
17.         self.ip = ip
18.         self.port = port
19.         self.user = user
20.         self.passwd = passwd
21.         self.database = database
22.         self.conn = None
23.         self.cur = None
24.         try:
25.             self.conn = pymysql.connect(host=self.ip, user=self.user, passwd=self.passwd, port=self.port,
26.                                         charset='utf8', database=self.database)
27.         except Exception as e:
28.             logging.error("连接失败：{}".format(e))
29.         if self.conn:
30.             self.cur = self.conn.cursor()
32.     def close(self):
33.         if self.cur:
34.             self.cur.close()
35.         if self.conn:
36.             self.conn.close()
38.     def insert_data(self, sql, data):
39.         if self.cur:
40.             # cur = conn.cursor(pymysql.cursors.DictCursor)
41.             try:
42.                 self.cur.executemany(sql, data)
43.             except pymysql.Error as e:
44.                 logging.error("executemany执行失败：{}".format(e))
45.                 self.conn.rollback()
46.                 self.conn.close()
47.             self.conn.commit()
50.     def select_data(self,sql):
51.         if self.cur:
52.             self.cur.execute(sql)
53.             res = self.cur.fetchall()
54.             return res
57. def start():
59.     obj = MysqlUtils(ip, port, user, passwd, database)
60.     sql1 = "show databases;"
61.     dbs = obj.select_data(sql1)  # (('_statistics_',), ('ads_biz',))
62.     dbs = [d[0] for d in dbs if d[0] not in ('_statistics_','information_schema')]
63.         resu = list()
64.     for db in dbs:
66.         sql2 = "show tables from {}".format(db)
67.         tables = obj.select_data(sql2)
68.         tables = [t[0] for t in tables]
69.         # print(tables)
71.         for table in tables:
72.             # sql3 = "show create table `{}`.`{}`".format(db,table)
73.             # sql3 = """ ALTER TABLE `{}`.`{}` MODIFY PARTITION (*) SET("replication_num"="2"); """ .format(db,table)
74.             sql3 = "SHOW  PARTITIONS FROM `{}`.`{}` WHERE ReplicationNum = 1".format(db,table)
75.             logging.info(sql3)
76.             try:
77.                 res = obj.select_data(sql3)  
78.             except Exception as e:
79.                 logging.error(e)
80.             if res:
81.                 resu.append(res)
82.     obj.close()

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。