code: def handle_insert(self, query: ast.Insert):
      message_builder = self.messaging_service.message_builder()
  
      topic_name = "/".join(query.table.parts)
  
      column_names = [col.name for col in query.columns]
      for insert_row in query.values:
          data = dict(zip(column_names, insert_row))
  
          outbound_message = message_builder.build(data)
          self.direct_publisher.publish(
              destination=Topic.of(topic_name), message=outbound_message
          )
  
      return Response(RESPONSE_TYPE.OK)
  
imports: import pandas
  from solace.messaging.messaging_service import MessagingService, RetryStrategy
  from solace.messaging.resources.topic_subscription import TopicSubscription
  from solace.messaging.receiver.message_receiver import MessageHandler
  from solace.messaging.resources.topic import Topic
  from solace.messaging.receiver.inbound_message import InboundMessage
  from mindsdb_sql import parse_sql
  from mindsdb_sql.parser import ast
  from mindsdb.api.executor.data_types.response_type import RESPONSE_TYPE
  from mindsdb.integrations.libs.base import DatabaseHandler
  from mindsdb.integrations.libs.response import HandlerStatusResponse, HandlerResponse
  from mindsdb.utilities import log
label_desc: Use image node_id 9 for calling the SolaceHandler obj's underlying member method code with example usage: obj.handle_insert(query) and returns: Response