Skip to content

[CPCLOUD-5995] Add support MySQL 84 #97

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
renakas merged 4 commits into from
Oct 13, 2026
Merged

[CPCLOUD-5995] Add support MySQL 84 #97

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
d02e2d3
Added log rotation with python
renakas Oct 6, 2025
c62f969
Update mysql.py
renakas Jan 15, 2026
077eb92
Revert "Added log rotation with python"
renakas Jan 21, 2026
ad99bc9
[CPCLOUD-5995] Add support MySQL 84
renakas Oct 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 21 additions & 1 deletion agent360/plugins/mysql.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -129,8 +129,27 @@ def run(self, config):
pass

cursor = db.cursor(MySQLdb.cursors.DictCursor)
cursor.execute('SHOW SLAVE STATUS')
# SHOW REPLICA STATUS: MySQL 8.0.22+ / MariaDB 10.5.1+. Older servers
# reject it with a syntax error (ProgrammingError), so fall back.
try:
cursor.execute('SHOW REPLICA STATUS')
except MySQLdb.Error:
cursor.execute('SHOW SLAVE STATUS')
query_result_slave = cursor.fetchone()

# Newer servers renamed columns; map them back to the legacy names
# so metric keys stay the same across server versions.
replica_key_map = {
'replica_io_state': 'slave_io_state',
'source_host': 'master_host',
'seconds_behind_source': 'seconds_behind_master',
'read_source_log_pos': 'read_master_log_pos',
'replica_io_running': 'slave_io_running',
'replica_sql_running': 'slave_sql_running',
'exec_source_log_pos': 'exec_master_log_pos',
'replica_sql_running_state': 'slave_sql_running_state',
'source_retry_count': 'master_retry_count',
}
non_delta_slave = (
'slave_io_state',
'master_host',
Expand All @@ -149,6 +168,7 @@ def run(self, config):
query_result_slave = dict()
for key, value in query_result_slave.items():
key = key.lower().strip()
key = replica_key_map.get(key, key)
if key == 'slave_sql_running':
value = 1 if value == 'Yes' else 0
if key == 'slave_io_running':
Expand Down
Loading