Guide d’Installation

Installer Taskiq-Flow et configurer votre environnement

Prérequis

Python 3.9 ou supérieur
pip (gestionnaire de paquets Python)
Optionnel : Redis (pour le suivi/stockage distribué)

Installation de base

Installez Taskiq-Flow depuis PyPI :

pip install taskiq taskiq-flow

C’est tout ! Vous êtes prêt à créer des pipelines.

Dépendances optionnelles

Taskiq-Flow propose des fonctionnalités supplémentaires via des extras :

# Toutes les fonctionnalités (suivi, planification, visualisation)
pip install "taskiq-flow[all]"

# Support Redis pour backends de stockage
pip install "taskiq-flow[redis]"

# Capacités de planification (APScheduler)
pip install "taskiq-flow[scheduler]"

# Dépendances de développement (inclut toutes les above)
pip install "taskiq-flow[dev]"

Vérifier l’installation

Créez un fichier de test test_install.py :

from taskiq import InMemoryBroker
from taskiq_flow import Pipeline, PipelineMiddleware

broker = InMemoryBroker()
broker.add_middlewares(PipelineMiddleware())

@broker.task
def hello(name: str) -> str:
    return f"Bonjour, {name}!"

async def main():
    pipeline = Pipeline(broker).call_next(hello)
    task = await pipeline.kiq("Monde")
    result = await task.wait_result()
    print(result.return_value)  # Devrait afficher : Bonjour, Monde !

if __name__ == "__main__":
    import asyncio
    asyncio.run(main())

Exécutez :

python test_install.py

Sortie attendue :

Bonjour, Monde !

Prochaines étapes

Une fois installé, continuez avec :

Guide de Démarrage Rapide — Créez votre premier pipeline
Guide des Concepts — Comprenez les idées fondamentales

Installation réussie ? Passez au Guide de Démarrage Rapide.