企业账户同步大促

import pika

# 生产者：发送同步消息
def send_message(queue_name, message):
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue=queue_name)
    channel.basic_publish(exchange='', routing_key=queue_name, body=message)
    print(f" [x] Sent {message}")
    connection.close()

# 消费者：接收并处理同步消息
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
    # 在这里处理数据同步逻辑
    # ...

def receive_message(queue_name):
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue=queue_name)
    channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
    print(' [*] Waiting for messages. To exit press CTRL+C')
    channel.start_consuming()

if __name__ == '__main__':
    queue_name = 'account_sync_queue'
    send_message(queue_name, 'user_account_update')
    receive_message(queue_name)