消息推送系统

import pika

def send_message(message):

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

channel = connection.channel()

channel.queue_declare(queue='school_messages')

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

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

connection.close()

send_message('Hello School!')

]]>

import requests

def receive_message():

response = requests.get('http://school-system/api/receive-message')

if response.status_code == 200:

return response.json()['message']

实习就业管理系统

else:

return None

print(receive_message())

]]>