异步协程开发指南：实现高并发的邮件队列系统

pip install asyncio aiosmtplib aioredis

import asyncio
import aioredis

async def get_redis():
    return await aioredis.create_redis('redis://localhost')

async def send_email(to_address, message):
    try:
        smtp_client = aiosmtplib.SMTP(hostname='smtp.gmail.com', port=587)
        await smtp_client.connect()
        await smtp_client.starttls()
        await smtp_client.login(user='your_email_address@gmail.com', passWord='your_password')
        await smtp_client.sendmail(from_addr='your_email_address@gmail.com', to_addrs=[to_address], msg=message)
        await smtp_client.quit()
        return True
    except:
        return False

async def process_queue():
    redis = await get_redis()
    while True:
        message = await redis.lpop('email_queue')
        if message is not None:
            to_address, subject, body = message.decode('utf-8').split(',')
            email_message = f'Subject: {subject}

{body}'
            result = await send_email(to_address, email_message)
            if result:
                print(f'Sent email to {to_address}')
            else:
                await redis.rpush('email_queue', message)
        else:
            await asyncio.sleep(1)

async def add_email_to_queue(to_address, subject, body):
    redis = await get_redis()
    email_message = f'{to_address},{subject},{body}'.encode('utf-8')
    await redis.rpush('email_queue', email_message)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    tasks = [process_queue() for i in range(10)]
    loop.run_until_complete(asyncio.gather(*tasks))