Utiliser la messagerie persistante avec les messages stockés dans un magasin d'objets en nuage

L'ensemble DBMS_PIPE offre des fonctionnalités étendues sur Autonomous AI Database pour prendre en charge les messages persistants, où les messages sont stockés dans le magasin d'objets en nuage.

À propos de la messagerie persistante avec DBMS_PIPE

La messagerie persistante avec DBMS_PIPE permet à une ou plusieurs sessions de base de données de communiquer dans la même région ou entre les régions avec des messages stockés dans le magasin d'objets en nuage.

Messages persistants dans DBMS_PIPE :

• Permet d'envoyer et de récupérer des messages très volumineux.

• Prendre en charge l'envoi d'un grand nombre de messages de canalisation.

• Prendre en charge l'envoi et la réception de messages au sein d'une seule base de données, entre plusieurs bases de données et entre des bases de données de différentes régions.

• Prendre en charge plusieurs canaux à l'aide du même URI d'emplacement de magasin d'objets en nuage.

Les canaux de messagerie persistants peuvent être créés dans n'importe quel type DBMS_PIPE pris en charge :

• Conduit implicite : Créé automatiquement lorsqu'un message est envoyé avec un nom de canal inconnu à l'aide de la fonction DBMS_PIPE.SEND_MESSAGE.
• Converbe explicite : Créé à l'aide de la fonction DBMS_PIPE.CREATE_PIPE avec un nom de canal spécifié par l'utilisateur.
• Conseil public : Accessible par tout utilisateur disposant de l'autorisation EXECUTE sur l'ensemble DBMS_PIPE.
• Converbe privé : Accessible par les sessions avec le même utilisateur que le créateur du canal.

Note :

Oracle recommande de créer une barre verticale explicite avant d'envoyer ou de recevoir des messages avec une messagerie persistante. La création d'un canal explicite avec DBMS_PIPE.CREATE_PIPE garantit que le canal est créé avec les autorisations d'accès voulues, publiques ou privées (en définissant le paramètre private).

Voici le flux de travail général pour DBMS_PIPE avec messagerie persistante :

Description de l'illustration database-pipe-persistent-messaging.svg

Les applications existantes utilisant DBMS_PIPE peuvent continuer à fonctionner avec un minimum de modifications. Vous pouvez configurer des applications existantes qui utilisent DBMS_PIPE avec un objet de données d'identification et un URI d'emplacement à l'aide d'un déclencheur de connexion ou à l'aide d'un autre sous-programme d'initialisation. Après avoir défini les données d'identification et l'URI d'emplacement DBMS_PIPE, aucune autre modification n'est nécessaire pour utiliser la messagerie persistante. Toute utilisation ultérieure du canal stocke les messages dans le magasin d'objets en nuage au lieu de la mémoire de base de données. Vous pouvez ainsi modifier la méthode de stockage des messages du stockage en mémoire au stockage d'objets en nuage persistant, avec des modifications minimes.

Présentation et fonctionnalités de la messagerie persistante

Fonctions de DBMS_PIPE utilisant la messagerie persistante :

• Les messages peuvent être envoyés et extraits sur plusieurs instances du service Base de données d'intelligence artificielle autonome dans la même région ou entre des régions.

• Les messages persistants sont garantis pour être écrits ou lus par un seul processus. Cela évite l'incohérence du contenu des messages en raison de lectures et d'écritures simultanées. DBMS_PIPE permet qu'une seule opération, l'envoi d'un message ou la réception d'un message soit active à un moment donné et ces opérations sont protégées par un mécanisme de verrouillage. Toutefois, si une opération n'est pas possible en raison d'une opération en cours, le processus réessaie périodiquement jusqu'à ce que la valeur timeout soit atteinte.

• DBMS_PIPE utilise DBMS_CLOUD pour accéder au magasin d'objets en nuage. Les messages peuvent être stockés dans n'importe quel magasin d'objets en nuage pris en charge. Pour plus d'informations, voir Formats d'URI du service de stockage d'objets en nuage.

• DBMS_PIPE utilise DBMS_CLOUD pour accéder au magasin d'objets en nuage et tous les types de données d'identification pris en charge sont disponibles :
  • DBMS_CLOUD.CREATE_CREDENTIAL : Pour plus d'informations, voir Procédure CREATE_CREDENTIAL.

DBMS_PIPE Privilèges Autorisation et sécurité

Les procédures DBMS_PIPE s'exécutent avec les droits de l'appelant. Les tuyaux privés appartiennent à l'utilisateur courant et un tuyau privé créé par un utilisateur ne peut être utilisé que par le même utilisateur. Cela s'applique à la fois aux canaux en mémoire et aux canaux de messagerie persistants où les messages sont stockés dans le magasin d'objets en nuage. L'envoi et la réception de messages s'exécutent dans le schéma de l'appelant.

À l'aide de canaux privés, où les messages sont stockés dans le magasin d'objets en nuage, un objet de données d'identification est requis pour l'authentification avec le magasin d'objets en nuage identifié par le paramètre location_uri. L'utilisateur appelant doit disposer du privilège EXECUTE sur l'objet de données d'identification spécifié avec le paramètre credential_name utilisé pour accéder au magasin d'objets.

Pour utiliser un canal public, l'utilisateur, session de base de données, doit disposer du privilège d'exécution sur DBMS_PIPE. Pour un canal public utilisant une messagerie persistante et stockant des messages dans le magasin d'objets en nuage, l'utilisateur, la session de base de données, doit disposer du privilège d'exécution sur DBMS_CLOUD et d'exécution sur l'objet de données d'identification (ou vous pouvez créer un objet de données d'identification autorisé à accéder à l'URI d'emplacement qui contient le message).

DBMS_PIPE Limite

L'ensemble DBMS_PIPE ne prend pas en charge l'envoi de messages entre des bases de données qui utilisent des jeux de caractères différents. Par exemple, si vous avez une instance Autonomous AI Database qui utilise AL32UTF8 et une autre instance qui utilise WE8MSWIN1252, vous ne pouvez pas envoyer de messages avec DBMS_PIPE entre ces deux bases de données. Dans ce cas, le système générera l'erreur ORA-12704 si vous tentez d'envoyer des messages avec DBMS_PIPE entre ces deux bases de données.

Pour plus d'informations, voir Sélection de jeux de caractères pour Base de données d'IA autonome.

Créer un canal persistant explicite et envoyer un message

Décrit les étapes de création d'un tuyau persistant avec un nom de tuyau spécifié (tuyau explicite).

1. Stockez vos données d'identification du magasin d'objets à l'aide de la procédure DBMS_CLOUD.CREATE_CREDENTIAL. Par exemple :

   BEGIN
     DBMS_CLOUD.CREATE_CREDENTIAL(
       credential_name => 'my_persistent_pipe_cred',
       username => '[e-mail]',
       password => 'password'
     );
   END;
   /

   Cette opération stocke les données d'identification dans la base de données dans un format chiffré. Vous pouvez utiliser n'importe quel nom pour les données d'identification. Notez que cette étape n'est requise qu'une seule fois, sauf si les données d'identification du magasin d'objets changent. Après avoir stocké les données d'identification, vous pouvez utiliser le même nom pour accéder au magasin d'objets en nuage afin d'envoyer et de recevoir des messages avec DBMS_PIPE.

   Pour des informations détaillées sur les paramètres, consultez CREATE_CREDENTIAL Procédure. Pour le service Oracle Cloud Infrastructure Object Storage, il est nécessaire que les données d'identification utilisent l'authentification Oracle Cloud Infrastructure native.

   Note :

   Certains outils tels que SQL*Plus et SQL Developer utilisent le caractère perluète (&) comme caractère spécial. Si votre mot de passe contient une perluète, utilisez la commande SET DEFINE OFF dans ces outils, comme dans l'exemple, pour désactiver le caractère spécial et faire en sorte que les données d'identification soient créées correctement.
2. Créez un canal explicite pour envoyer et extraire des messages. Par exemple, créez une barre verticale nommée ORDER_PIPE.

   DECLARE
     r_status INTEGER;
   BEGIN
       r_status := DBMS_PIPE.CREATE_PIPE(pipename => 'ORDER_PIPE');
   END;
   /

   Pour plus d'informations, voir Fonction CREATE_PIPE.

3. Vérifiez que le tuyau est créé.

   SELECT ownerid, name, type FROM v$db_pipes 
          WHERE name = 'ORDER_PIPE';

   OWNERID NAME       TYPE    
   ------- ---------- ------- 
        80 ORDER_PIPE PRIVATE 

4. Utilisez les procédures DBMS_PIPE pour définir les données d'identification d'accès par défaut et l'URI d'emplacement afin de stocker les messages persistants dans le magasin d'objets en nuage.

   BEGIN
       DBMS_PIPE.SET_CREDENTIAL_NAME('my_persistent_pipe_cred');
       DBMS_PIPE.SET_LOCATION_URI('https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname1/'); 
   END;
   /

   Ces procédures définissent le nom des données d'identification par défaut et l'URI d'emplacement par défaut à utiliser avec les procédures DBMS_PIPE.

   Si vous utilisez Oracle Cloud Infrastructure Object Storage pour stocker des messages, vous pouvez utiliser les URI natifs d'Oracle Cloud Infrastructure ou des URI Swift. Toutefois, le type de l'URI d'emplacement et des données d'identification doit correspondre comme suit :

   • Si vous utilisez un format d'URI natif pour accéder à Oracle Cloud Infrastructure Object Storage, vous devez utiliser l'authentification des clés de signature Oracle Cloud Infrastructure natives dans l'objet de données d'identification.

   • Si vous utilisez le format d'URI Swift pour accéder à Oracle Cloud Infrastructure Object Storage, vous devez utiliser une authentification par jeton d'authentification dans l'objet de données d'identification.

   Pour plus d'informations, voir Procédure SET_CREDENTIAL_NAME et Fonction GET_LOCATION_URI.

5. Emballez et envoyez un message sur le tuyau.

   DECLARE
     l_result INTEGER;
     l_date   DATE;
   BEGIN
       l_date := sysdate;
       DBMS_PIPE.PACK_MESSAGE(l_date);         -- date of order
       DBMS_PIPE.PACK_MESSAGE('C123');         -- order number
       DBMS_PIPE.PACK_MESSAGE(5);              -- number of items in order
       DBMS_PIPE.PACK_MESSAGE('Printers');     -- type of item in order
   
    
       l_result := DBMS_PIPE.SEND_MESSAGE(
                       pipename => 'ORDER_PIPE',
                       credential_name => DBMS_PIPE.GET_CREDENTIAL_NAME,
                       location_uri => DBMS_PIPE.GET_LOCATION_URI);
        
       IF l_result = 0 THEN
           DBMS_OUTPUT.put_line('DBMS_PIPE sent order successfully');
       END IF;
    
   END;
   /

   Pour plus d'informations, voir Procédures PACK_MESSAGE dans Informations de référence sur les ensembles et les types PL/SQL pour Oracle Database 19c ou Informations de référence sur les ensembles et les types PL/SQL pour Oracle Database 26ai et Fonction SEND_MESSAGE.

Extraire un message persistant sur la même base de données

Décrit les étapes d'extraction d'un message persistant à partir d'un canal explicite sur la même instance de base de données d'intelligence artificielle autonome (instance où le message a été envoyé).

Sur une instance Autonomous AI Database, vous pouvez recevoir des messages envoyés à un canal à partir d'une autre session. Les procédures DBMS_PIPE sont des procédures de droits de l'appelant et sont exécutées en tant qu'utilisateur appelé courant.

Les tuyaux privés appartiennent à l'utilisateur courant qui crée le tuyau. Les tuyaux privés ne sont accessibles que par le même utilisateur qui a créé le tuyau. Cela s'applique aux canaux utilisant des messages en mémoire et aux canaux utilisant des messages persistants avec des messages stockés dans le magasin d'objets en nuage.

Les canaux publics sont accessibles par toute session de base de données ayant le privilège d'exécution sur DBMS_PIPE. Cela s'applique aux canaux utilisant des messages en mémoire et aux canaux utilisant des messages persistants avec des messages stockés dans le magasin d'objets en nuage.

1. Vérifiez que le tuyau est créé.

   SELECT ownerid, name, type FROM v$db_pipes 
          WHERE name = 'ORDER_PIPE';
   

   OWNERID NAME       TYPE    
   ------- ---------- ------- 
        80 ORDER_PIPE PRIVATE 

   Lorsque vous êtes sur la même instance Autonomous AI Database et que le canal existe, vous n'avez pas besoin d'exécuter DBMS_PIPE.CREATE_PIPE avant de recevoir un message. Cela s'applique lorsque le canal a été créé sur la même instance, comme indiqué dans Créer un canal persistant explicite et envoyer un message.

2. Recevez un message du tuyau.

   DECLARE
       message1  DATE;
       message2  VARCHAR2(100);
       message3  INTEGER;
       message4  VARCHAR2(100);
       l_result  INTEGER;
   
   BEGIN
   
       DBMS_PIPE.SET_CREDENTIAL_NAME('my_persistent_pipe_cred');
       DBMS_PIPE.SET_LOCATION_URI('https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname1/'); 
       l_result := DBMS_PIPE.RECEIVE_MESSAGE (
                     pipename => 'ORDER_PIPE',
                     timeout  => DBMS_PIPE.MAXWAIT,
                     credential_name => DBMS_PIPE.GET_CREDENTIAL_NAME,
                     location_uri => DBMS_PIPE.GET_LOCATION_URI);
    
       IF l_result = 0 THEN
           DBMS_PIPE.unpack_message(message1);
           DBMS_PIPE.unpack_message(message2);
           DBMS_PIPE.unpack_message(message3);
           DBMS_PIPE.unpack_message(message4);
    
           DBMS_OUTPUT.put_line('Order Received Successfully On: ' || TO_CHAR(sysdate, 'dd-mm-yyyy hh24:mi:ss'));
           DBMS_OUTPUT.put_line('Date of Order: ' || message1);
           DBMS_OUTPUT.put_line('Order Number: ' || message2);
           DBMS_OUTPUT.put_line('Number of Items In Order: ' || message3);
           DBMS_OUTPUT.put_line('Item Type in Order: ' || message4);
       END IF;
    
   END;
   /

   Lorsque vous êtes sur la même instance de base de données d'intelligence artificielle autonome, les données d'identification existent déjà et vous n'avez pas besoin d'exécuter DBMS_CLOUD.CREATE_CREDENTIAL pour recevoir un message. Cela s'applique lorsque le canal a été créé sur la même instance, comme indiqué dans Créer un canal persistant explicite et envoyer un message.

Pour plus d'informations, voir Procédure SET_CREDENTIAL_NAME et Fonction GET_LOCATION_URI.

Pour plus d'informations, voir Fonction RECEIVE_MESSAGE.

Extraire un message persistant en créant un canal sur une autre base de données

Décrit les étapes d'extraction d'un message persistant stocké dans le magasin d'objets en nuage avec un canal explicite sur une instance de base de données d'intelligence artificielle autonome différente de l'instance qui a envoyé le message.

1. Stockez vos données d'identification du magasin d'objets à l'aide de la procédure DBMS_CLOUD.CREATE_CREDENTIAL. Par exemple :

   BEGIN
     DBMS_CLOUD.CREATE_CREDENTIAL(
       credential_name => 'my_persistent_pipe_cred',
       username => '[e-mail]',
       password => 'password'
     );
   END;
   /

   Cette opération stocke les données d'identification dans la base de données dans un format chiffré. Vous pouvez utiliser n'importe quel nom pour les données d'identification. Notez que cette étape n'est requise qu'une seule fois, sauf si les données d'identification du magasin d'objets changent. Une fois les données d'identification stockées, vous pouvez utiliser le même nom pour accéder au magasin d'objets en nuage afin d'envoyer et de recevoir des messages avec DBMS_PIPE.

   Pour des informations détaillées sur les paramètres, consultez CREATE_CREDENTIAL Procédure.

   Note :

   Certains outils tels que SQL*Plus et SQL Developer utilisent le caractère perluète (&) comme caractère spécial. Si votre mot de passe contient une perluète, utilisez la commande SET DEFINE OFF dans ces outils, comme dans l'exemple, pour désactiver le caractère spécial et faire en sorte que les données d'identification soient créées correctement.
2. Créez une barre verticale explicite portant le même nom que la barre verticale qui a envoyé le message. Par exemple, créez une barre verticale nommée ORDER_PIPE.

   DECLARE
     r_status INTEGER;
   BEGIN
       r_status := DBMS_PIPE.CREATE_PIPE(pipename => 'ORDER_PIPE');
   END;
   /

   Voir Fonction CREATE_PIPE.

3. Vérifiez que le tuyau est créé.

   SELECT ownerid, name, type FROM v$db_pipes 
          WHERE name = 'ORDER_PIPE';
   

   OWNERID NAME       TYPE    
   ------- ---------- ------- 
        80 ORDER_PIPE PRIVATE 

4. Utilisez les procédures DBMS_PIPE pour définir les données d'identification d'accès par défaut et l'URI d'emplacement pour le magasin d'objets afin que DBMS_PIPE puisse accéder au message persistant.

   BEGIN
       DBMS_PIPE.SET_CREDENTIAL_NAME('my_persistent_pipe_cred');
       DBMS_PIPE.SET_LOCATION_URI('https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname1/'); 
   END;
   /

   Ces procédures définissent le nom des données d'identification par défaut et l'URI d'emplacement par défaut à utiliser avec les procédures DBMS_PIPE.

   Si vous utilisez Oracle Cloud Infrastructure Object Storage pour stocker des messages, vous pouvez utiliser les URI natifs d'Oracle Cloud Infrastructure ou des URI Swift. Toutefois, le type de l'URI d'emplacement et des données d'identification doit correspondre comme suit :

   • Si vous utilisez un format d'URI natif pour accéder à Oracle Cloud Infrastructure Object Storage, vous devez utiliser l'authentification des clés de signature Oracle Cloud Infrastructure natives dans l'objet de données d'identification.

   • Si vous utilisez le format d'URI Swift pour accéder à Oracle Cloud Infrastructure Object Storage, vous devez utiliser une authentification par jeton d'authentification dans l'objet de données d'identification.

   Pour plus d'informations, voir Procédure SET_CREDENTIAL_NAME et Fonction GET_LOCATION_URI.

5. Recevoir un message à partir du canal persistant.

   DECLARE
       message1  DATE;
       message2  VARCHAR2(100);
       message3  INTEGER;
       message4  VARCHAR2(100);
       l_result  INTEGER;
   
   BEGIN
   
       DBMS_PIPE.SET_CREDENTIAL_NAME('my_persistent_pipe_cred');
       DBMS_PIPE.SET_LOCATION_URI('https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname1/'); 
       l_result := DBMS_PIPE.RECEIVE_MESSAGE (
                     pipename => 'ORDER_PIPE',
                     timeout  => DBMS_PIPE.MAXWAIT,
                     credential_name => DBMS_PIPE.GET_CREDENTIAL_NAME,
                     location_uri => DBMS_PIPE.GET_LOCATION_URI);
    
       IF l_result = 0 THEN
           DBMS_PIPE.unpack_message(message1);
           DBMS_PIPE.unpack_message(message2);
           DBMS_PIPE.unpack_message(message3);
           DBMS_PIPE.unpack_message(message4);
    
           DBMS_OUTPUT.put_line('Order Received Successfully On: ' || TO_CHAR(sysdate, 'dd-mm-yyyy hh24:mi:ss'));
           DBMS_OUTPUT.put_line('Date of Order: ' || message1);
           DBMS_OUTPUT.put_line('Order Number: ' || message2);
           DBMS_OUTPUT.put_line('Number of Items In Order: ' || message3);
           DBMS_OUTPUT.put_line('Item Type in Order: ' || message4);
       END IF;
    
   END;
   /

   Pour plus d'informations, voir Fonction RECEIVE_MESSAGE.

Supprimer un tuyau persistant

Décrit les étapes de suppression d'une canalisation persistante.

Les canaux persistants envoient et reçoivent des messages en stockant des messages dans le magasin d'objets en nuage. Utilisez DBMS_PIPE.REMOVE_PIPE pour supprimer une canalisation persistante sur une instance Autonomous AI Database.

1. Appelez la fonction DBMS_PIPE.REMOVE_PIPE pour supprimer une barre verticale.

   DECLARE
      l_result  INTEGER;
   BEGIN
        l_result := DBMS_PIPE.REMOVE_PIPE('ORDER_PIPE');
   END;
   /

   La fonction REMOVE_PIPE supprime le canal de l'instance Autonomous AI Database où il s'exécute, mais REMOVE_PIPE n'a pas d'incidence sur les autres instances Autonomous AI Database avec un canal portant le même nom qui utilise le même URI d'emplacement.

2. Dans l'instance de base de données d'intelligence artificielle autonome, exécutez DBMS_PIPE.REMOVE_PIPE, vérifiez que le canal est supprimé.

   SELECT ownerid, name, type FROM v$db_pipes 
          WHERE name = 'ORDER_PIPE';
   

   No rows selected

---

Titre et Copyright

Copyright ©2024,2025,

Oracle et/ou ses sociétés affiliées.