统一消息系统

import pika

def send_bid_file(file_path):

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

channel = connection.channel()

channel.queue_declare(queue='bid_queue')

with open(file_path, 'r') as f:

message = f.read()

channel.basic_publish(exchange='', routing_key='bid_queue', body=message)

print(" [x] Sent bid file")

connection.close()