统一消息系统

import pika

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

channel = connection.channel()

channel.queue_declare(queue='task_queue', durable=True)

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

print(" [x] Received %r" % body)

数据可视化

channel.basic_consume(queue='task_queue',

on_message_callback=callback,

auto_ack=True)

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

channel.start_consuming()

]]>

from sqlalchemy import create_engine, Column, Integer, String

from sqlalchemy.ext.declarative import declarative_base

from sqlalchemy.orm import sessionmaker

Base = declarative_base()

class Message(Base):

__tablename__ = 'messages'

id = Column(Integer, primary_key=True)

content = Column(String)

engine = create_engine('sqlite:///messages.db')

Base.metadata.create_all(engine)

Session = sessionmaker(bind=engine)

session = Session()

new_message = Message(content="Hello World")

session.add(new_message)

session.commit()

]]>