Создание микросервисов для обработки фоновых задач в реальном времени

from flask import Flask, request
import threading
import time

app = Flask(__name__)

def background_task(task_id):
    print(f"Starting task {task_id}")
    # Здесь могла бы быть ваша логика обработки задачи
    time.sleep(10) # Имитация длительной задачи
    print(f"Task {task_id} completed")

@app.route('/start-task', methods=['POST'])
def start_task():
    task_id = request.json.get('task_id')
    threading.Thread(target=background_task, args=(task_id,)).start()
    return {'message': f'Task {task_id} started'}, 200

if __name__ == '__main__':
    app.run(debug=True)