📊 Управление задачами с Celery

from celery import Celery

# Создание приложения Celery
app = Celery('tasks', broker='redis://localhost:6379/0')

@app.task
def send_email(recipient: str, subject: str, body: str) -> str:
    # Имитация отправки email
    print(f"Отправка email на {recipient} с темой '{subject}'")
    return "Email отправлен!"

# Пример использования
if __name__ == "__main__":
    result_email = send_email.delay("example@example.com", "Hello!", "Это тестовое сообщение.")
    
    print(result_email.get(timeout=10))

📌 Этот код демонстрирует, как использовать Celery для создания и управления асинхронными задачами в Python-приложениях. Он содержит функцию для отправки email, которая может выполняться в фоновом режиме, освобождая основной поток приложения для других операций. Это полезно для создания масштабируемых веб-приложений, где требуется выполнение задач в реальном времени.

Подпишись 👉🏻 @KodduuPython 🤖