Python中是否有类似HTTPSQS的简单队列实现？用于危急值提醒系统

celery ？

Python里没有HTTPSQS那种开箱即用的独立服务，但用标准库和几个轻量级包就能轻松搭一个类似的HTTP队列服务。核心思路就是用Flask或FastAPI提供HTTP接口，用queue.Queue或Redis做后端存储。

下面是一个用Flask和内存队列实现的完整示例，包含入队、出队和查看状态的基础功能：

from flask import Flask, request, jsonify
import queue
import threading
import time

app = Flask(__name__)

# 使用线程安全的队列
task_queue = queue.Queue(maxsize=1000)  # 设置队列最大长度防止内存溢出

@app.route('/put', methods=['POST'])
def put_message():
    """入队接口，接收JSON格式消息"""
    data = request.get_json()
    if not data or 'message' not in data:
        return jsonify({'error': 'Missing message field'}), 400
    
    try:
        # 添加时间戳和唯一ID
        import uuid
        message = {
            'id': str(uuid.uuid4()),
            'timestamp': time.time(),
            'content': data['message']
        }
        task_queue.put(message, block=False)
        return jsonify({'status': 'success', 'id': message['id']}), 200
    except queue.Full:
        return jsonify({'error': 'Queue is full'}), 507

@app.route('/get', methods=['GET'])
def get_message():
    """出队接口，支持timeout参数"""
    timeout = request.args.get('timeout', default=0, type=int)
    try:
        message = task_queue.get(block=True, timeout=timeout)
        return jsonify(message), 200
    except queue.Empty:
        return jsonify({'error': 'Queue is empty'}), 404

@app.route('/status', methods=['GET'])
def queue_status():
    """查看队列状态"""
    return jsonify({
        'size': task_queue.qsize(),
        'empty': task_queue.empty(),
        'full': task_queue.full()
    })

if __name__ == '__main__':
    # 启动一个消费者线程模拟处理
    def consumer():
        while True:
            try:
                item = task_queue.get(timeout=1)
                print(f"[Consumer] Processing: {item['id']} - {item['content']}")
                # 这里添加实际的处理逻辑，比如发送短信/邮件提醒
                task_queue.task_done()
            except queue.Empty:
                continue
    
    threading.Thread(target=consumer, daemon=True).start()
    app.run(host='0.0.0.0', port=5000, debug=False)

这个实现提供了三个核心接口：