消息推送系统

from channels.generic.websocket import AsyncWebsocketConsumer

import json

class ChatConsumer(AsyncWebsocketConsumer):

async def connect(self):

await self.accept()

async def disconnect(self, close_code):

pass

async def receive(self, text_data):

text_data_json = json.loads(text_data)

message = text_data_json['message']

# 发送消息到客户端

await self.send(text_data=json.dumps({

'message': message

}))

from celery import shared_task

from datetime import timedelta

from django.utils import timezone

from .models import Message

@shared_task

def delete_old_messages():

old_messages = Message.objects.filter(created_at__lt=timezone.now() - timedelta(days=90))

old_messages.delete()