消息推送系统

CREATE TABLE users (

id INT AUTO_INCREMENT PRIMARY KEY,

name VARCHAR(100) NOT NULL,

email VARCHAR(100) NOT NULL UNIQUE,

is_new BOOLEAN DEFAULT TRUE

);

import smtplib

from email.mime.text import MIMEText

from sqlalchemy.orm import sessionmaker

from sqlalchemy import create_engine

from models import User # 假设User是定义好的ORM模型

def send_welcome_email(user):

msg = MIMEText('欢迎加入我们的团队！')

msg['Subject'] = '欢迎邮件'

msg['From'] = 'noreply@example.com'

msg['To'] = user.email

server = smtplib.SMTP('smtp.example.com', 587)

server.starttls()

server.login('username', 'password')

server.sendmail(msg['From'], [msg['To']], msg.as_string())

server.quit()

def main():

engine = create_engine('sqlite:///users.db') # 假设使用SQLite数据库

Session = sessionmaker(bind=engine)

session = Session()

new_users = session.query(User).filter_by(is_new=True).all()

for user in new_users:

send_welcome_email(user)

user.is_new = False

session.commit()

if __name__ == '__main__':

main()