统一消息系统

import pika

def send_message(queue_name, message):

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

channel = connection.channel()

channel.queue_declare(queue=queue_name)

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

print(" [x] Sent %r" % message)

connection.close()

# 示例发送消息

send_message('docx_queue', 'process_file')

from docx import Document

def process_docx(file_path):

doc = Document(file_path)

for para in doc.paragraphs:

para.text = para.text.upper() # 将文本转换为大写

doc.save('processed_' + file_path)

# 示例调用

process_docx('example.docx')