统一消息系统

from docx import Document

import pika

# 生成DOCX

def generate_docx():

doc = Document()

doc.add_paragraph('这是生成的DOCX内容')

doc.save('output.docx')

# 发送消息到消息队列

def send_message():

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

channel = connection.channel()

channel.queue_declare(queue='docx_queue')

channel.basic_publish(exchange='', routing_key='docx_queue', body='DOCX生成完成')

connection.close()

if __name__ == '__main__':

generate_docx()

send_message()