Added more logs

Author: bakwc

mysql_ch_replicator/binlog_replicator.py

@@ -480,14 +480,20 @@ def run(self):
                         continue
 
                     if log_event.event_type == EventType.QUERY.value:
+                        logger.info(f'received query event: {event.query}')
                         db_name_from_query = self._try_parse_db_name_from_query(event.query)
                         if db_name_from_query:
                             log_event.db_name = db_name_from_query
 
                     if not self.settings.is_database_matches(log_event.db_name):
+
+                        if log_event.event_type == EventType.QUERY.value:
+                            logger.info(f'query event not matched')
+
                         continue
 
-                    logger.debug(f'event matched {transaction_id}, {log_event.db_name}, {log_event.table_name}')
+                    if log_event.event_type == EventType.QUERY.value:
+                        logger.info(f'query event matched {transaction_id}, {log_event.db_name}, {log_event.table_name}')
 
                     log_event.transaction_id = transaction_id
 

mysql_ch_replicator/db_replicator_realtime.py

@@ -82,7 +82,7 @@ def handle_event(self, event: LogEvent):
             if event.transaction_id <= self.replicator.state.last_processed_transaction_non_uploaded:
                 return
 
-        logger.debug(f'processing event {event.transaction_id}, {event.event_type}, {event.table_name}')
+        logger.info(f'processing event {event.transaction_id}, {event.event_type}, {event.table_name}')
 
         event_handlers = {
             EventType.ADD_EVENT.value: self.handle_insert_event,
@@ -166,8 +166,8 @@ def handle_erase_event(self, event: LogEvent):
             current_table_records_to_insert.pop(record_id, None)
 
     def handle_query_event(self, event: LogEvent):
-        if self.replicator.config.debug_log_level:
-            logger.debug(f'processing query event: {event.transaction_id}, query: {event.records}')
+        logger.info(f'processing query event: {event.transaction_id}, query: {event.records}')
+
         query = strip_sql_comments(event.records)
         if query.lower().startswith('alter'):
             self.upload_records()