mysql 触发器跨主机

CREATE EVENT my_event
ON SCHEDULE EVERY 1 MINUTE
DO
  -- 这里执行你需要的SQL语句
  INSERT INTO log_table (message) VALUES ('Data updated on remote host');

import mysql.connector

# 连接到本地数据库
local_db = mysql.connector.connect(
  host="localhost",
  user="user",
  password="password",
  database="local_db"
)

# 连接到远程数据库
remote_db = mysql.connector.connect(
  host="remote_host",
  user="user",
  password="password",
  database="remote_db"
)

# 监控本地数据库的变化
cursor = local_db.cursor()
cursor.execute("SELECT * FROM local_table WHERE status = 'updated'")

for row in cursor:
  # 在远程数据库中执行相应的操作
  remote_cursor = remote_db.cursor()
  remote_cursor.execute("UPDATE remote_table SET status = 'processed' WHERE id = %s", (row[0],))
  remote_db.commit()

cursor.close()
remote_cursor.close()
local_db.close()
remote_db.close()

# 生产者代码示例
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='db_updates')

def callback(ch, method, properties, body):
    print("Received %r" % body)

channel.basic_consume(queue='db_updates', on_message_callback=callback, auto_ack=True)

print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

# 消费者代码示例
import pika
import mysql.connector

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='db_updates')

remote_db = mysql.connector.connect(
  host="remote_host",
  user="user",
  password="password",
  database="remote_db"
)

def callback(ch, method, properties, body):
    cursor = remote_db.cursor()
    cursor.execute("UPDATE remote_table SET status = 'processed' WHERE id = %s", (body,))
    remote_db.commit()

channel.basic_consume(queue='db_updates', on_message_callback=callback, auto_ack=True)

print('Waiting for messages. To exit press CTRL+C')
channel.start_consuming()