企业账户同步报价

import pika
import json

# 生产者：发送报价更新消息
def send_price_update(product_id, new_price):
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='price_updates')
    message = {'product_id': product_id, 'new_price': new_price}
    channel.basic_publish(exchange='', routing_key='price_updates', body=json.dumps(message))
    print(f" [x] Sent {message}")
    connection.close()

# 消费者：接收并处理报价更新消息
def process_price_update(ch, method, properties, body):
    data = json.loads(body)
    print(f" [x] Received {data}")
    # 这里可以添加更新数据库或其他系统的逻辑

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='price_updates')
channel.basic_consume(queue='price_updates', on_message_callback=process_price_update, auto_ack=True)

print(' [*] Waiting for price updates. To exit press CTRL+C')
channel.start_consuming()