消息推送系统

import pika

import json

# 消息队列连接

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

channel = connection.channel()

# 定义回调函数

数据管理系统

def callback(ch, method, properties, body):

data = json.loads(body)

if 'proxy_price' in data:

print(f"Received proxy price: {data['proxy_price']}")

adjust_price(data['proxy_price'])

# 监听消息队列

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

print('Waiting for messages...')

channel.start_consuming()

]]>