Tous les produits
Search
Centre de documentation

ApsaraMQ for RocketMQ:Intégration des messages

Dernière mise à jour :Aug 09, 2026

Message Integration est une plateforme complète de messagerie et d'intégration de données qui simplifie la connectivité des données entre les environnements cloud et sur site.

Contexte

Lors de leur transformation numérique, les entreprises font souvent face à des défis tels que la fragmentation de l'intégration des informations, la diversité des formats de données qui entrave le transfert, l'absence de moyen pratique pour partager les données et les services backend, ainsi que l'absence de canal sécurisé entre les ressources cloud et sur site. Message Integration répond à ces enjeux en tant que plateforme complète de messagerie et d'intégration de données. Elle prend en charge l'intégration entre les environnements cloud et sur site, ainsi qu'entre différentes régions.

Message Integration fournit une plateforme de streaming d'événements complète et low-code, dédiée aux services de messagerie. Elle couvre l'intégration des messages, la connexion des données, le traitement des données et l'intégration des services via une interface visuelle dotée de capacités de conception et d'orchestration. Elle permet également la connectivité inter-régions, inter-instances et inter-applications, réduisant considérablement les coûts d'intégration et de développement.

Overview and introduction

Fonctionnalités

  • Intégration de sources de données diverses

    Message Integration connecte les données entre Alibaba Cloud, les environnements multi-cloud et hybrides. Elle prend en charge l'ingestion des journaux depuis les services cloud, l'intégration des sources de données depuis les applications gérées par l'utilisateur et l'intégration inter-cloud. Les sources d'ingestion prises en charge incluent les journaux, les bases de données et les middleware de messagerie.

  • Nettoyage des données et exportation

    Message Integration propose une configuration ETL (Extract-Transform-Load) basée sur une interface utilisateur. Nettoyez, formatez et transformez les messages après leur ingestion dans les files d'attente de messages, puis exportez les données traitées vers les systèmes aval.

  • Traitement personnalisé serverless

    En tirant parti de la plateforme Serverless et des capacités de codage personnalisé de Function Compute (FC), Message Integration vous permet d'écrire une logique métier personnalisée pour le traitement et la distribution des données.

Limites

Le tableau suivant répertorie les limites de Message Integration.

Limites

Description

Nombre de tâches

Le nombre total de tâches (y compris l'entrée et la sortie des messages) dans une seule région ne peut pas dépasser 20. Pour demander une limite supérieure, submit a ticket.

Nom de la tâche

Le nom doit commencer par une lettre ou un chiffre. Le reste du nom peut contenir des lettres, des chiffres et des traits d'union (-). Il peut comporter jusqu'à 127 caractères. Les noms dépassant 127 caractères sont automatiquement tronqués.

Correspondance de modèle d'événement

En mode stringExpression, chaque champ peut contenir jusqu'à cinq expressions dans la structure de données map.

Transformation d'événement

  • template : Jusqu'à 10 240 caractères.

  • value : Jusqu'à 1 024 caractères.

Perte de données dans des cas extrêmes

Pour plus d'informations, consultez Politiques de nouvelle tentative et files d'attente de lettres mortes.

Termes — Entrée des messages (Source)

L'entrée des messages est le composant d'intégration de données de Message Integration. Elle ingère les données provenant de multiples sources — messages, journaux, données relationnelles et non relationnelles — dans les services de messagerie. Elle prend en charge l'intégration inter-centres de données et inter-cloud, et vous permet d'exploiter, de gérer et de surveiller les données intégrées de manière indépendante. Vous pouvez également filtrer les données entrantes au niveau de la source.

Image 4.png

Termes — Sortie des messages (Destination)

La sortie des messages exporte les données des services de messagerie vers divers services de destination. Elle distribue les messages de manière fiable et nettoie et filtre les données lors de la distribution.

Image 2.png

Termes — Traitement des données (Transform)

Le traitement des données est un composant optionnel que vous pouvez configurer pour les tâches d'entrée ou de sortie des messages. Basé sur EventBridge et Function Compute, il propose sept modes de correspondance — correspondance par valeur fixe, par préfixe, par suffixe, par exclusion, par valeur numérique, par tableau et par condition combinée — et cinq transformateurs — événement complet, événement partiel, constante, modèle et modèle Function Compute — pour permettre la transformation, le traitement et l'analyse des messages.

Termes — Tâche

Généralement, une tâche se compose d'une source, d'une destination et de règles de filtrage et de transformation configurées. Elle constitue l'unité d'exécution de Message Integration, s'appuyant sur la fonctionnalité de flux d'événements d'EventBridge.

Chaque tâche comprend une configuration des ressources (paramètres de source et de destination) et un traitement des données optionnel. Pour plus d'informations, consultez Termes — Traitement des données (Transform).

Important

Après avoir créé une tâche, vous ne pouvez pas modifier le type de ressource pour l'entrée ou la sortie des messages.