from flask import Flask, jsonify, request

app = Flask(__name__)

@app.route('/download_messages', methods=['POST'])

def download_messages():

user_id = request.json.get('user_id')

unread_messages = fetch_unread_messages(user_id)

return jsonify({'messages': unread_messages})

def fetch_unread_messages(user_id):

# 假設(shè)我們從數(shù)據(jù)庫(kù)中獲取未讀消息

return ["Message 1", "Message 2", "Message 3"]

@app.route('/download_messages', methods=['POST'])

def download_messages():

user_id = request.json.get('user_id')

page = int(request.json.get('page', 1))

page_size = int(request.json.get('page_size', 10))

start_index = (page - 1) * page_size

end_index = start_index + page_size

unread_messages = fetch_unread_messages(user_id)[start_index:end_index]

return jsonify({'messages': unread_messages})

from celery import Celery

app = Celery('tasks', broker='redis://localhost:6379/0')

@app.task

def async_download_messages(user_id, page, page_size):

start_index = (page - 1) * page_size

end_index = start_index + page_size

unread_messages = fetch_unread_messages(user_id)[start_index:end_index]

return {'messages': unread_messages}