Contexte et objectifs

Les prévisions traditionnelles reposent sur des modèles spécifiques, chaque série nécessitant plusieurs semaines de travail d’experts. IBM propose un Time Series Foundation Model (TSFM) appelé Granite, entraîné une fois sur plus de 44 M de téléchargements de signaux variés. Le modèle prétend généraliser à toute série jamais vue, fournir prévisions, détection d’anomalies, recherche de similarité et optimisation, le tout sans mobilisation d’une équipe de data‑science. Les gains annoncés sont de 5 à 10 × en productivité, chaque point d’amélioration de précision se traduisant par des économies de plusieurs millions de dollars.

Architecture du déploiement

Granite s’intègre à la plateforme de streaming de Confluent, hébergée sur Confluent Cloud (AWS) et exécutée dans Apache Flink®. La chaîne de traitement se compose de trois couches : (1) ingestion des flux Kafka, (2) appel du modèle via les fonctions AI_FORECAST et AI_DETECT_ANOMALIE, (3) écriture des résultats dans des topics Kafka persistants. Flink maintient l’état de chaque série (historique recent) de façon keyed et tolérante aux pannes, évitant ainsi toute requête vers une base de données externe. Cette architecture élimine le besoin de provisionner des serveurs de modèle ou des GPU dédiés.

Mécanismes d’inférence en flux

Lorsqu’un nouveau point arrive, Flink transmet la fenêtre de mesures au TSFM. Le modèle renvoie la valeur prévue, un score d’anomalie et le nearest‑neighbor historique. Le processus est déclenché directement depuis du SQL Flink, comme illustré ci‑dessous :

SELECT *
FROM AI_FORECAST(
  model='granite-tsfm',
  input_topic='sensor_data',
  output_topic='forecast_results');

Cette invocation ne requiert aucune configuration supplémentaire : Confluent provisionne le service de modèle, gère le scaling et applique les politiques RBAC. Les résultats sont immédiatement disponibles pour des alertes, des tableaux de bord ou des pipelines de décision, grâce à la nature durable et rejouable des topics Kafka.

Analyse des bénéfices et limites

Le principal avantage réside dans la réduction du temps de mise en production : les mois de travail d’intégration sont remplacés par quelques minutes de déploiement SQL. La gouvernance intégrée assure la traçabilité du schéma et la conformité aux exigences de sécurité, tandis que le modèle reste dans le même périmètre réseau que les données, limitant les frais d’entrée/sortie cloud. Cependant, la généralisation du TSFM dépend de la représentativité du jeu d’entraînement ; des séries très spécifiques ou à forte saisonnalité pourraient nécessiter un fine‑tuning supplémentaire, ce qui n’est pas détaillé dans la documentation publique. De plus, la facturation repose sur le volume de messages traités, ce qui peut devenir coûteux pour des environnements à très haute fréquence si aucune optimisation de la fenêtre d’observation n’est appliquée. Enfin, l’accès en Early Access signifie que les garanties de stabilité et de support restent limitées, imposant aux équipes de prévoir des plans de secours en cas de régression du modèle.