批量处理投标文件与消息管理中心的技术实现

import pika

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

channel = connection.channel()

channel.queue_declare(queue='bid_files')

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

print(f"Received: {body.decode()}")

channel.basic_consume(callback, queue='bid_files', no_ack=True)

print('Waiting for messages. To exit press CTRL+C')

channel.start_consuming()

大数据可视化