统一消息系统

from flask import Flask, request

import pika

app = Flask(__name__)

def send_price_update(product_id, price):

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

channel = connection.channel()

channel.queue_declare(queue='price_updates')

channel.basic_publish(exchange='', routing_key='price_updates', body=f'{product_id}:{price}')

connection.close()

@app.route('/update-price', methods=['POST'])

def update_price():

data = request.json

product_id = data['product_id']

price = data['price']

send_price_update(product_id, price)

return {'status': 'success'}

if __name__ == '__main__':

app.run(port=5000)