如何在两个独立的后台之间同步数据？

# 生产者（发送数据变更通知）
import pika

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

channel.queue_declare(queue='data_sync_queue')

def send_notification(data):
    channel.basic_publish(exchange='',
                          routing_key='data_sync_queue',
                          body=data)

send_notification('{"key": "value"}')
connection.close()

# 消费者（接收数据变更通知并处理）
import pika

def callback(ch, method, properties, body):
    print(f"Received data: {body}")
    # 处理数据同步逻辑

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

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

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

-- 配置主数据库
server-id = 1
log_bin = /var/log/mysql/mysql-bin.log

-- 配置从数据库
server-id = 2
relay_log = /var/log/mysql/mysql-relay-bin.log
log_bin = /var/log/mysql/mysql-bin.log

# 提供数据的后台
from flask import Flask, jsonify

app = Flask(__name__)

@app.route('/api/data', methods=['GET'])
def get_data():
    data = {"key": "value"}
    return jsonify(data)

if __name__ == '__main__':
    app.run(port=5000)

# 请求数据的后台
import requests

response = requests.get('http://localhost:5000/api/data')
print(response.json())