Tous les produits
Search
Centre de documentation

ApsaraDB for OceanBase (Deprecated):Créer une source de données RocketMQ

Dernière mise à jour :Aug 09, 2026

Vous devez configurer les sources de données avant de créer une tâche de migration ou de synchronisation. Cette rubrique explique comment créer une source de données RocketMQ à l'aide du service de transmission de données.

Risques de sécurité

Vous pouvez ajouter automatiquement ou manuellement les blocs CIDR publics pour le service de transmission de données, mais cela présente des risques de sécurité. En utilisant le service de transmission de données, vous reconnaissez avoir compris ces risques potentiels. Vous devez prendre des mesures de sécurité de base, telles que la définition d'un mot de passe complexe pour votre compte, la limitation des ports ouverts des blocs CIDR, l'activation de l'authentification pour la communication entre les API internes, ainsi que la vérification et la suppression régulières des blocs CIDR inutiles.

Le service de transmission de données ajoute ou supprime automatiquement les blocs CIDR dans les listes d'autorisation ou les groupes de sécurité selon les besoins métier et les risques de sécurité. N'utilisez pas les blocs CIDR d'une liste d'autorisation ou d'un groupe de sécurité à d'autres fins que le service de transmission de données. Tout problème résultant d'une telle utilisation est exclu de la garantie du SLA du service de transmission de données. Pour plus d'informations sur l'ajout d'une adresse IP à une liste d'autorisation ou à un groupe de sécurité pour le service de transmission de données, consultez Ajouter une liste d'autorisation.

Prérequis

  • Le service de transmission de données dispose des privilèges nécessaires pour accéder aux ressources cloud. Pour plus d'informations, consultez Accorder des privilèges aux rôles pour la transmission de données.

  • Vous avez créé un groupe dans l'instance RocketMQ. Pour plus d'informations, consultez Créer un groupe.

  • Vous avez créé un topic nommé oms_test_topic dans l'instance RocketMQ.

  • Vous avez activé Authentication-free in VPCs pour le type de contrôle d'accès Intelligent Authentication dans l'instance RocketMQ.

    Intelligent Authentication est le type de contrôle d'accès par défaut pour les instances RocketMQ. Dans ce mode, un client qui se connecte à une instance RocketMQ dans un VPC est authentifié par défaut. Si Authentication-free in VPCs est désactivé, le nom d'utilisateur et le mot de passe de l'instance RocketMQ sont requis pour que le point de terminaison VPC réussisse le test de connexion à la source de données.

Limites

Le service de transmission de données prend en charge les instances RocketMQ des versions 4.x et 5.x, y compris les éditions commerciale et communautaire.

Procédure

  1. Connectez-vous à la console ApsaraDB for OceanBase

    .

  2. Dans le volet de navigation de gauche, choisissez Data Transmission > Data Source Management.

  3. Dans la section Data Sources , cliquez sur New Data Source dans le coin supérieur droit.

  4. Dans la boîte de dialogue New Data Source , sélectionnez RocketMQ pour Data Source Type .

  5. Configurez les paramètres.

    Paramètre

    Description

    Type d'instance

    Seule l'option Alibaba Cloud RocketMQ Instance est prise en charge.

    Identifiant de la source de données

    Nous vous recommandons d'utiliser une combinaison de chiffres et de lettres. L'identifiant ne doit contenir aucun espace et ne peut pas dépasser 32 caractères.

    Cross Alibaba Cloud Account

    Le service de transmission de données vous permet de configurer une tâche pour migrer ou synchroniser des données entre des instances appartenant à différents comptes Alibaba Cloud.

    Sélectionnez cette option selon vos besoins métier. Si vous la sélectionnez, saisissez le compte Alibaba Cloud de l'instance cible. Si vous ne disposez pas des autorisations sur ce compte, demandez d'abord une autorisation. Pour plus d'informations, consultez Demander une autorisation inter-comptes.

    Instances

    La source de données. Sélectionnez une instance Alibaba Cloud RocketMQ dans la liste déroulante.

    Informations sur le point de terminaison RocketMQ

    Le point de terminaison de la base de données RocketMQ, au format adresse IP:numéro de port ou nom de domaine:numéro de port.

    AccessKey

    L'ID AccessKey que vous avez créé dans la console Resource Access Management (RAM) pour l'authentification.

    Pour afficher l'ID AccessKey, survolez l'avatar de l'utilisateur dans le coin supérieur droit de la page et cliquez sur AccessKey Management .

    SecretKey

    Le secret AccessKey que vous avez créé dans la console RAM pour l'authentification.

    Le secret AccessKey n'est affiché qu'une seule fois lors de sa création. Il est irrécupérable en cas d'oubli. Nous vous recommandons de le sauvegarder pour une utilisation ultérieure. Pour plus d'informations, consultez Créer une paire de clés AccessKey.

    Remarques (facultatif)

    Informations supplémentaires concernant la source de données.

  6. Cliquez sur Test Connection pour tester la connexion réseau entre le système de transmission de données et la base de données source.

    Important

    Si vous ne créez pas le topic oms_test_topic , le test échouera.

  7. Une fois le test réussi, cliquez sur OK .

Créer un groupe

Avant de créer une source de données RocketMQ, vous devez créer au préalable le groupe defaultGroup. Sinon, le test de connexion échouera.

  1. Accédez à la page de détails de l'instance RocketMQ.

    1. Connectez-vous à la console Message Queue for Apache RocketMQ .

    2. Dans le volet de navigation de gauche, cliquez sur Instances .

    3. Dans la liste des instances, cliquez sur le nom de l'instance cible. La page Instances s'affiche.

  2. Dans le volet de navigation de gauche, cliquez sur Groups .

  3. Sur la page Groups , cliquez sur Create Group et configurez les paramètres.

    Les paramètres varient selon la version de l'instance RocketMQ. Pour plus d'informations, consultez Gérer les groupes .

    Important

    Lors de la création d'un groupe, l'ID du groupe doit être défini sur defaultGroup.

  4. Une fois les paramètres configurés, cliquez sur OK .

  5. Créez un topic nommé oms_test_topic.

    1. Sur la page de détails de l'instance, cliquez sur Topics dans le volet de navigation de gauche.

    2. Sur la page Topics , cliquez sur Create Topic .

    3. Dans la boîte de dialogue Create Topic , configurez les paramètres.

      Paramètre

      Description

      Nom

      Définissez ce paramètre sur oms_test_topic.

      Méthode de facturation

      Ce paramètre est disponible uniquement pour les instances RocketMQ de version 4.x et prend en charge uniquement Pay-as-you-go .

      Type de message

      • Les instances RocketMQ de version 4.x prennent en charge Normal Message , Transactional Message , Partitionally Ordered Message , Globally Ordered Message et Scheduled/Delayed Message .

      • Les instances RocketMQ de version 5.x prennent en charge Normal Message , Ordered Message , Scheduled/Delayed Message et Transactional Message .

      Description

      Elle peut contenir un maximum de 128 caractères.

    4. Une fois les paramètres configurés, cliquez sur OK .