Persistentes Messaging mit Nachrichten verwenden, die im Cloud-Objektspeicher gespeichert sind

Das Package DBMS_PIPE verfügt über erweiterte Funktionen in Autonomous Database, um persistentes Messaging zu unterstützen, bei dem Nachrichten im Cloud-Objektspeicher gespeichert werden.

Informationen zum persistenten Messaging mit DBMS_PIPE

Durch persistentes Messaging mit DBMS_PIPE können eine oder mehrere Datenbanksessions in derselben Region oder regionsübergreifend mit Nachrichten kommunizieren, die im Cloud-Objektspeicher gespeichert sind.

Persistente Nachrichten in DBMS_PIPE:

• Erlauben Sie, sehr große Nachrichten zu senden und abzurufen.

• Unterstützen Sie das Senden einer großen Anzahl von Pipe-Nachrichten.

• Unterstützung für das Senden und Empfangen von Nachrichten in einer einzigen Datenbank, über mehrere Datenbanken und über Datenbanken in verschiedenen Regionen hinweg.

• Unterstützen Sie mehrere Pipes mit derselben Speicherort-URI des Cloud-Objektspeichers.

Persistente Messaging Pipes können in einem der unterstützten DBMS_PIPE-Typen erstellt werden:

• Implizite Pipe: Wird automatisch erstellt, wenn eine Nachricht mit einem unbekannten Pipe-Namen mit der Funktion DBMS_PIPE.SEND_MESSAGE gesendet wird.
• Explizite Pipe: Wird mit der Funktion DBMS_PIPE.CREATE_PIPE mit einem benutzerdefinierten Pipe-Namen erstellt.
• Öffentliche Pipe: Zugriff für alle Benutzer mit der Berechtigung EXECUTE für das Package DBMS_PIPE.
• Private Pipe: Zugriff durch Sessions mit demselben Benutzer wie der Pipe-Ersteller.

Hinweis:

Oracle empfiehlt, eine explizite Pipe zu erstellen, bevor Sie Nachrichten mit persistentem Messaging senden oder empfangen. Durch das Erstellen einer expliziten Pipe mit DBMS_PIPE.CREATE_PIPE wird sichergestellt, dass die Pipe mit den gewünschten Zugriffsberechtigungen (öffentlich oder privat) erstellt wird (durch Festlegen des Parameters private).

Im Folgenden wird der allgemeine Workflow für DBMS_PIPE mit persistentem Messaging dargestellt:

Beschreibung der Abbildung database-pipe-persistent-messaging.eps

Vorhandene Anwendungen, die DBMS_PIPE verwenden, können weiterhin mit minimalen Änderungen arbeiten. Sie können vorhandene Anwendungen, die DBMS_PIPE verwenden, mit einem Zugangsdatenobjekt und einer Speicherort-URI konfigurieren, indem Sie einen Anmelde-Trigger oder eine andere Initialisierungsroutine verwenden. Nachdem Sie die Zugangsdaten und die Speicherort-URI DBMS_PIPE festgelegt haben, sind keine weiteren Änderungen erforderlich, um persistentes Messaging zu verwenden. Bei jeder nachfolgenden Verwendung der Pipe werden die Nachrichten im Cloud-Objektspeicher anstatt im Datenbankspeicher gespeichert. Auf diese Weise können Sie die Speichermethode für Nachrichten von In-Memory in persistenten Cloud-Objektspeicher mit minimalen Änderungen ändern.

Persistent Messaging – Überblick und Features

Features von DBMS_PIPE mit persistentem Messaging:

• Nachrichten können über mehrere Autonomous Database-Instanzen in derselben Region oder regionsübergreifend gesendet und abgerufen werden.

• Persistente Nachrichten werden garantiert entweder von genau einem Prozess geschrieben oder gelesen. Dadurch wird eine Inkonsistenz des Nachrichteninhalts aufgrund gleichzeitiger Lese- und Schreibvorgänge verhindert. DBMS_PIPE lässt nur einen Vorgang zu, bei dem das Senden einer Nachricht oder eine empfangende Nachricht zu einem bestimmten Zeitpunkt aktiv ist. Diese Vorgänge werden durch einen Sperrmechanismus geschützt. Wenn ein Vorgang jedoch aufgrund eines laufenden Vorgangs nicht möglich ist, wiederholt sich der Prozess in regelmäßigen Abständen, bis der Wert timeout erreicht ist.

• DBMS_PIPE verwendet DBMS_CLOUD, um auf den Cloud-Objektspeicher zuzugreifen. Nachrichten können in einem der unterstützten Cloud-Objektspeicher gespeichert werden. Weitere Informationen finden Sie unter URI-Formate für Cloud-Objektspeicher.

• DBMS_PIPE verwendet DBMS_CLOUD, um auf den Cloud-Objektspeicher zuzugreifen, und alle unterstützten Zugangsdatentypen sind verfügbar:
  • DBMS_CLOUD.CREATE_CREDENTIAL: Weitere Informationen finden Sie unter Prozedur CREATE_CREDENTIAL.

DBMS_PIPE Berechtigungen - Autorisierung und Sicherheit

Die DBMS_PIPE-Prozeduren werden mit den Rechten des ausführenden Benutzers ausgeführt. Private Pipes sind Eigentum des aktuellen Benutzers, und eine private Pipe, die von einem Benutzer erstellt wird, kann nur von demselben Benutzer verwendet werden. Dies gilt sowohl für In-Memory-Pipes als auch für persistente Messaging-Pipes, in denen Nachrichten im Cloud-Objektspeicher gespeichert werden. Senden und Empfangen von Nachrichten werden im Schema des ausführenden Benutzers ausgeführt.

Mit privaten Pipes, in denen Nachrichten im Cloud-Objektspeicher gespeichert werden, ist ein Zugangsdatenobjekt für die Authentifizierung mit dem Cloud-Objektspeicher erforderlich, der mit dem Parameter location_uri identifiziert wird. Der aufrufende Benutzer muss über die Berechtigung EXECUTE für das Zugangsdatenobjekt verfügen, das mit dem Parameter credential_name angegeben wird, der für den Zugriff auf den Objektspeicher verwendet wird.

Um eine öffentliche Pipe verwenden zu können, muss der Benutzer, die Datenbanksession, über die Ausführungsberechtigung für DBMS_PIPE verfügen. Bei einer öffentlichen Pipe, die persistentes Messaging verwendet und Nachrichten im Cloud-Objektspeicher speichert, muss der Benutzer, die Datenbanksession, über die Ausführungsberechtigung für DBMS_CLOUD und die Ausführungsberechtigung für das Zugangsdatenobjekt verfügen (oder Sie können ein Zugangsdatenobjekt erstellen, das auf die Speicherort-URI zugreifen kann, in der die Nachricht enthalten ist).

DBMS_PIPE Einschränkung

Das Package DBMS_PIPE unterstützt nicht das Senden von Nachrichten zwischen Datenbanken, die unterschiedliche Zeichensätze verwenden. Beispiel: Wenn Sie eine Autonomous Database-Instanz verwenden, die AL32UTF8 verwendet, und eine andere Instanz, die WE8MSWIN1252 verwendet, können Sie keine Nachrichten mit DBMS_PIPE zwischen diesen beiden Datenbanken senden. In diesem Fall löst das System den Fehler ORA-12704 aus, wenn Sie versuchen, Nachrichten mit DBMS_PIPE zwischen diesen beiden Datenbanken zu senden.

Weitere Informationen finden Sie unter Zeichensatzauswahl für Autonomous Database.

Explizite persistente Pipe erstellen und Nachricht senden

Beschreibt die Schritte zum Erstellen einer persistenten Pipe mit einem angegebenen Pipe-Namen (Explicit Pipe).

1. Speichern Sie Ihre Objektspeicherzugangsdaten mit der Prozedur DBMS_CLOUD.CREATE_CREDENTIAL. Beispiel:

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

   Dieser Vorgang speichert die Zugangsdaten in einem verschlüsselten Format in der Datenbank. Sie können einen beliebigen Namen als Zugangsdatenname verwenden. Beachten Sie, dass dieser Schritt nur einmal erforderlich ist, es sei denn, Ihre Objektspeicherzugangsdaten werden geändert. Nachdem Sie die Zugangsdaten gespeichert haben, können Sie mit demselben Zugangsdatennamen auf den Cloud-Objektspeicher zugreifen, um Nachrichten mit DBMS_PIPE zu senden und zu empfangen.

   Weitere Informationen zu den Parametern finden Sie unter Prozedur CREATE_CREDENTIAL. Für Oracle Cloud Infrastructure Object Storage müssen die Zugangsdaten eine native Oracle Cloud Infrastructure-Authentifizierung verwenden.

   Hinweis:

   Einige Tools wie SQL*Plus und SQL Developer verwenden das Et-Zeichen (&) als Sonderzeichen. Wenn das Et-Zeichen in Ihrem Kennwort enthalten ist, verwenden Sie den Befehl SET DEFINE OFF in diesen Tools, wie im Beispiel gezeigt, um das Sonderzeichen zu deaktivieren und die Zugangsdaten korrekt zu erstellen.
2. Erstellen Sie eine explizite Pipe, um Nachrichten zu senden und abzurufen. Beispiel: Erstellen Sie eine Pipe mit dem Namen ORDER_PIPE.

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

   Weitere Informationen finden Sie unter Funktion CREATE_PIPE.

3. Prüfen Sie, ob die Pipe erstellt wurde.

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

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

4. Verwenden Sie DBMS_PIPE-Prozeduren, um die Standardzugriffszugangsdaten und die Speicherort-URI festzulegen, um persistente Nachrichten im Cloud-Objektspeicher zu speichern.

   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;
   /

   Diese Prozeduren legen den Standardzugangsdatenamen und die Standardspeicherort-URI für die Verwendung mit DBMS_PIPE-Prozeduren fest.

   Wenn Sie Nachrichten mit Oracle Cloud Infrastructure Object Storage speichern, können Sie Oracle Cloud Infrastructure-native URIs oder Swift-URIs verwenden. Der Speicherort-URI und die Zugangsdaten müssen jedoch wie folgt mit dem Typ übereinstimmen:

   • Wenn Sie ein natives URI-Format für den Zugriff auf Oracle Cloud Infrastructure Object Storage verwenden, müssen Sie die native Authentifizierung für Oracle Cloud Infrastructure-Signaturschlüssel im Zugangsdatenobjekt verwenden.

   • Wenn Sie mit dem Swift-URI-Format auf Oracle Cloud Infrastructure Object Storage zugreifen, müssen Sie eine Authentifizierung mit Authentifizierungstoken im Zugangsdatenobjekt verwenden.

   Weitere Informationen finden Sie unter Prozedur SET_CREDENTIAL_NAME und Funktion GET_LOCATION_URI.

5. Packen und senden Sie eine Nachricht auf der Pipe.

   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;
   /

   Weitere Informationen finden Sie unter PACK_MESSAGE Procedures in der Oracle Database 19c PL/SQL Packages and Types Reference oder in der Oracle Database 23ai PL/SQL Packages and Types Reference und in der SEND_MESSAGE Function.

Persistente Nachricht in derselben Datenbank abrufen

Beschreibt die Schritte zum Abrufen einer persistenten Nachricht aus einer expliziten Pipe in derselben Autonomous Database-Instanz (der Instanz, in der die Nachricht gesendet wurde).

Auf einer Autonomous Database-Instanz können Sie Nachrichten empfangen, die von einer anderen Session an eine Pipe gesendet wurden. Die DBMS_PIPE-Prozeduren sind Prozeduren für die Rechte des ausführenden Benutzers und werden als der aktuell aufgerufene Benutzer ausgeführt.

Private Pipes gehören dem aktuellen Benutzer, der die Pipe erstellt. Auf private Pipes kann nur derselbe Benutzer zugreifen, der die Pipe erstellt hat. Dies gilt für Pipes, die In-Memory-Nachrichten verwenden, und für Pipes, die persistentes Messaging mit Nachrichten verwenden, die im Cloud-Objektspeicher gespeichert sind.

Auf öffentliche Pipes kann von jeder Datenbanksession zugegriffen werden, die über Ausführungsberechtigungen für DBMS_PIPE verfügt. Dies gilt für Pipes, die In-Memory-Nachrichten verwenden, und für Pipes, die persistentes Messaging mit Nachrichten verwenden, die im Cloud-Objektspeicher gespeichert sind.

1. Prüfen Sie, ob die Pipe erstellt wurde.

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

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

   Wenn Sie sich in derselben Autonomous Database-Instanz befinden und die Pipe vorhanden ist, müssen Sie DBMS_PIPE.CREATE_PIPE nicht ausführen, bevor Sie eine Nachricht erhalten. Dies gilt, wenn die Pipe auf derselben Instanz erstellt wurde (siehe Explizite persistente Pipe erstellen und Nachricht senden).

2. Erhalten Sie eine Nachricht von der Pipe.

   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;
   /

   Wenn Sie sich in derselben Autonomous Database-Instanz befinden, sind die Zugangsdaten bereits vorhanden, und Sie müssen DBMS_CLOUD.CREATE_CREDENTIAL nicht ausführen, um eine Nachricht zu erhalten. Dies gilt, wenn die Pipe auf derselben Instanz erstellt wurde (siehe Explizite persistente Pipe erstellen und Nachricht senden).

Weitere Informationen finden Sie unter Prozedur SET_CREDENTIAL_NAME und Funktion GET_LOCATION_URI.

Weitere Informationen finden Sie unter Funktion RECEIVE_MESSAGE.

Persistente Nachrichten durch Erstellen einer Pipe in einer anderen Datenbank abrufen

Beschreibt die Schritte zum Abrufen einer persistenten Nachricht, die im Cloud-Objektspeicher mit einer expliziten Pipe in einer Autonomous Database-Instanz gespeichert ist und sich von der Instanz unterscheidet, die die Nachricht gesendet hat.

1. Speichern Sie Ihre Objektspeicherzugangsdaten mit der Prozedur DBMS_CLOUD.CREATE_CREDENTIAL. Beispiel:

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

   Dieser Vorgang speichert die Zugangsdaten in einem verschlüsselten Format in der Datenbank. Sie können einen beliebigen Namen als Zugangsdatenname verwenden. Beachten Sie, dass dieser Schritt nur einmal erforderlich ist, es sei denn, Ihre Objektspeicherzugangsdaten werden geändert. Nachdem Sie die Zugangsdaten gespeichert haben, können Sie mit demselben Zugangsdatennamen auf den Cloud-Objektspeicher zugreifen, um Nachrichten mit DBMS_PIPE zu senden und zu empfangen.

   Weitere Informationen zu den Parametern finden Sie unter Prozedur CREATE_CREDENTIAL.

   Hinweis:

   Einige Tools wie SQL*Plus und SQL Developer verwenden das Et-Zeichen (&) als Sonderzeichen. Wenn das Et-Zeichen in Ihrem Kennwort enthalten ist, verwenden Sie den Befehl SET DEFINE OFF in diesen Tools, wie im Beispiel gezeigt, um das Sonderzeichen zu deaktivieren und die Zugangsdaten korrekt zu erstellen.
2. Erstellen Sie eine explizite Pipe mit demselben Namen wie die Pipe, die die Nachricht gesendet hat. Beispiel: Erstellen Sie eine Pipe mit dem Namen ORDER_PIPE.

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

   Siehe Funktion CREATE_PIPE.

3. Prüfen Sie, ob die Pipe erstellt wurde.

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

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

4. Verwenden Sie DBMS_PIPE-Prozeduren, um die Standardzugriffszugangsdaten und die Speicherort-URI für den Objektspeicher festzulegen, sodass DBMS_PIPE auf die persistente Nachricht zugreifen kann.

   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;
   /

   Diese Prozeduren legen den Standardzugangsdatenamen und die Standardspeicherort-URI für die Verwendung mit DBMS_PIPE-Prozeduren fest.

   Wenn Sie Nachrichten mit Oracle Cloud Infrastructure Object Storage speichern, können Sie Oracle Cloud Infrastructure-native URIs oder Swift-URIs verwenden. Der Speicherort-URI und die Zugangsdaten müssen jedoch wie folgt mit dem Typ übereinstimmen:

   • Wenn Sie ein natives URI-Format für den Zugriff auf Oracle Cloud Infrastructure Object Storage verwenden, müssen Sie die native Authentifizierung für Oracle Cloud Infrastructure-Signaturschlüssel im Zugangsdatenobjekt verwenden.

   • Wenn Sie mit dem Swift-URI-Format auf Oracle Cloud Infrastructure Object Storage zugreifen, müssen Sie eine Authentifizierung mit Authentifizierungstoken im Zugangsdatenobjekt verwenden.

   Weitere Informationen finden Sie unter Prozedur SET_CREDENTIAL_NAME und Funktion GET_LOCATION_URI.

5. Erhalten Sie eine Nachricht von der persistenten Pipe.

   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;
   /

   Weitere Informationen finden Sie unter Funktion RECEIVE_MESSAGE.

Persistente Pipe entfernen

Beschreibt die Schritte zum Entfernen einer persistenten Pipe.

Persistente Pipes senden und empfangen Nachrichten, indem sie Nachrichten im Cloud-Objektspeicher speichern. Verwenden Sie DBMS_PIPE.REMOVE_PIPE, um eine persistente Pipe auf einer Autonomous Database-Instanz zu entfernen.

1. Rufen Sie die Funktion DBMS_PIPE.REMOVE_PIPE auf, um eine Pipe zu entfernen.

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

   Die Funktion REMOVE_PIPE entfernt die Pipe aus der Autonomous Database-Instanz, in der sie ausgeführt wird. REMOVE_PIPE wirkt sich jedoch nicht auf andere Autonomous Database-Instanzen mit einer Pipe mit demselben Namen aus, die denselben Speicherort-URI verwendet.

2. Prüfen Sie, ob die Pipe in der Autonomous Database-Instanz DBMS_PIPE.REMOVE_PIPE ausgeführt wurde.

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

   No rows selected

---

Titel und Copyright-Informationen

Copyright ©2024,2024,

Oracle und/oder verbundene Unternehmen.