DBMS_LIVE_FEED-Packagereferenz

Dieses Kapitel enthält Informationen zu den Packages, die Sie mit dem Dataload-Tool in Data Studio verwenden. Das Thema DBMS_LIVE_FEED behandelt auch die Prozeduren im Package DBMS_LIVE_FEED.

Zusammenfassung der DBMS_LIVE_FEED-Unterprogramme

Das Package DBMS_LIVE_FEED vereinfacht allgemeine Vorgänge, wie die Ausführung eines Livetabellenfeeds nach Bedarf, nach einem Zeitplan oder als Ergebnis einer benachrichtigungsgesteuerten Aktualisierung einer Tabelle auf Basis neuer Objekte in Objektspeicher-Buckets.

DBMS_LIVE_FEED-Packageunterprogramme

In der folgenden Tabelle werden die DBMS_LIVE_FEED-Unterprogramme aufgeführt und kurz beschrieben.

Unterprogramm Beschreibung
create_for_storage_link

Mit diesem Verfahren wird ein Livefeed für den Speicherlink erstellt.

create_for_directory

Mit dieser Prozedur wird ein Livefeed für das Verzeichnis erstellt.

create_for_url

Mit dieser Prozedur wird ein Livefeed aus der URL erstellt.

modify_live_feed

Mit diesem Verfahren wird ein Livefeed geändert.

drop_live_feed

Dieses Verfahren löscht einen Live-Feed.

load_new_content

Mit diesem Verfahren werden neue Inhalte in einen vorhandenen Livefeed geladen.

get_notification_key

Dieses Verfahren ruft den Benachrichtigungsschlüssel aus einem Livefeed ab.

get_confirmation_url

Dieses Verfahren erhält eine Bestätigungs-URL von einem Livefeed.

get_notification_state

Diese Prozedur erhält den Benachrichtigungsstatus von einem Livefeed.

Für Speicher erstellen - Linkprozedur

Mit dieser Prozedur wird ein Livetabellenfeed aus einem Cloud-Speicherlink erstellt. Ein Cloud-Speicherlink ist eine benannte Verknüpfung zwischen einer OCI-Bucket-URI und einem lokalen Zugangsdatennamen.

Syntax
procedure create_for_storage_link(live_feed_name     IN VARCHAR2,
                                           table_name         IN VARCHAR2,
                                           storage_link_name  IN VARCHAR2,
                                           schema             IN VARCHAR2 DEFAULT NULL,
                                           table_schema       IN VARCHAR2 DEFAULT NULL,
                                           column_list        IN CLOB     DEFAULT NULL,
                                           object_type        IN VARCHAR2 DEFAULT NULL,
                                           object_format      IN VARCHAR2 DEFAULT NULL,
                                           object_filter      IN VARCHAR2 DEFAULT NULL,
                                           object_filter_type IN VARCHAR2 DEFAULT NULL,
                                           scheduled          IN BOOLEAN  DEFAULT NULL,
                                           scheduler_interval IN VARCHAR2 DEFAULT NULL,
                                           notifications      IN BOOLEAN  DEFAULT NULL,
                                           job_class          IN VARCHAR2 DEFAULT NULL,
                                           start_date         IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,
                                           end_date           IN TIMESTAMP WITH TIME ZONE DEFAULT NULL);

DBMS_ LIVE_FEED-Parameter

Wenn Sie auf DBMS_LIVE_FEED-Prozeduren zugreifen, verwenden Sie die folgenden Parameter.

Parameter Beschreibung

live_feed_name

Der Name des Livefeeds, den Sie erstellen möchten.

storage_link_name

Der Name des Cloud-Speicherlinks. Der Name des Links muss den standardmäßigen Oracle-Benennungskonventionen entsprechen.

table_name

Der Name der Autonomous Database-Zieltabelle, in die der Livefeed Daten aus dem Cloud-Objektspeicher lädt.

Object_filter

Der Name der Zieltabelle, in die Daten aus dem Livefeed in die Autonomous Database-Instanz geladen werden, um auf den Cloud-Objektspeicher zuzugreifen.

object_filter_type

Der reguläre Ausdruck, mit dem der Livetabellenfeed auf die Dateien im Bucket begrenzt wird, die mit dem Ausdruck übereinstimmen. Je nach Parameter object_filter_type kann es sich um einen regulären Ausdruck oder einen Glob handeln.

scheduled

Der Standardwert ist TRUE. Wenn Sie TRUE verwenden, können Sie einen Zeitplan für die Ausführung des Livetabellenfeedobjekts einrichten.

notifications

Der Standardwert ist FALSE. Wenn Sie TRUE verwenden, kann Ihr Livefeed mit dem Livefeed-Tool vom Objektspeicher benachrichtigt werden, dass neue Dateien geladen werden müssen.

schema

Der Name für das Schema.

Der Name des Schemas des Livefeeds. Derzeit wird nur das aktuelle Schema unterstützt.

table_schema

Das Schema der Zieltabelle.

object_type

Typ des Objekts. Sie können die Dateien CSV, JSON und Parquet laden.

object_format

Dies ist eine der SQL Loader-Optionen.

Es akzeptiert das von der Prozedur DBMS_CLOUD.COPY_DATA empfangene Format.

scheduler_interval

Dieser Parameter zeigt das Intervall an, in dem der Livefeed mit der Syntax DBMS_SCHEDULER ausgeführt wird.

job_class

Die Scheduler-Jobklasse. Die Werte sind TPURGENT,TP,HIGH,MEDIUM und LOW.

start_date

Das Startdatum für den Livefeed-Job.

end_date

Das Enddatum des Livefeedjobs.

Hinweis

Die Parameter aller unten beschriebenen Verfahren sind in der obigen Tabelle aufgeführt.

Beispiel

In diesem Beispiel wird ein Livefeed mit dem Namen MYLIVEFEED für die angegebene URL erstellt.

SQL> BEGIN
   dbms_live_feed.create_for_storage_link(
     live_feed_name => 'MYLIVEFEED',
     storage_link_name => 'DATATOOLS_LF_BUCKET',
     table_name => 'MALTESE',
     object_filter => 'fndcalday?.csv',
     object_filter_type => 'GLOB',
     scheduled => false,
     notifications => false);
end;
/;
PL/SQL procedure successfully completed.

Prozedur "Für Verzeichnis erstellen"

Mit dieser Prozedur wird ein Livetabellenfeed aus einem Verzeichnis erstellt.

Syntax

procedure create_for_directory(live_feed_name     IN VARCHAR2,
                                 table_name         IN VARCHAR2,
                                 directory_name     IN VARCHAR2,
                                 schema             IN VARCHAR2 DEFAULT NULL,
                                 table_schema       IN VARCHAR2 DEFAULT NULL,
                                 column_list        IN CLOB     DEFAULT NULL,
                                 object_type        IN VARCHAR2 DEFAULT NULL,
                                 object_format      IN VARCHAR2 DEFAULT NULL,
                                 object_filter      IN VARCHAR2 DEFAULT NULL,
                                 object_filter_type IN VARCHAR2 DEFAULT NULL,
                                 scheduled          IN BOOLEAN  DEFAULT NULL,
                                 scheduler_interval IN VARCHAR2 DEFAULT NULL,
                                 notifications      IN BOOLEAN  DEFAULT NULL,
                                 job_class          IN VARCHAR2 DEFAULT NULL,
                                 start_date         IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,
                                 end_date           IN TIMESTAMP WITH TIME ZONE DEFAULT NULL);

Für URL-Prozedur erstellen

Mit dieser Prozedur wird ein Livetabellenfeed aus einer URL erstellt.

Syntax

 procedure create_for_url(live_feed_name     IN VARCHAR2,
                           table_name         IN VARCHAR2,
                           url                IN VARCHAR2,
                           credential_name    IN VARCHAR2,
                           schema             IN VARCHAR2 DEFAULT NULL,
                           table_schema       IN VARCHAR2 DEFAULT NULL,
                           column_list        IN CLOB     DEFAULT NULL,
                           object_type        IN VARCHAR2 DEFAULT NULL,
                           object_format      IN VARCHAR2 DEFAULT NULL,
                           object_filter      IN VARCHAR2 DEFAULT NULL,
                           object_filter_type IN VARCHAR2 DEFAULT NULL,
                           scheduled          IN BOOLEAN  DEFAULT NULL,
                           scheduler_interval IN VARCHAR2 DEFAULT NULL,
                           notifications      IN BOOLEAN  DEFAULT NULL,
                           job_class          IN VARCHAR2 DEFAULT NULL,
                           start_date         IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,
                           end_date           IN TIMESTAMP WITH TIME ZONE DEFAULT NULL);

Livefeed-Prozedur ändern

Mit diesem Verfahren wird ein Livetabellenfeed geändert.

Syntax

procedure modify_live_feed(live_feed_name     IN VARCHAR2,
                             schema             IN VARCHAR2 DEFAULT NULL,
                             scheduled          IN BOOLEAN  DEFAULT NULL,
                             scheduler_interval IN VARCHAR2 DEFAULT NULL,
                             notifications      IN BOOLEAN  DEFAULT NULL,
                             job_class          IN VARCHAR2 DEFAULT NULL,
                             start_date         IN TIMESTAMP WITH TIME ZONE DEFAULT NULL,
                             end_date           IN TIMESTAMP WITH TIME ZONE DEFAULT NULL);

Beispiel

In diesem Beispiel wird ein Livefeed mit dem Namen MYLIVEFEED geändert.

begin
   dbms_live_feed.modify_live_feed(
     live_feed_name => 'MYLIVEFEED',
     scheduled => true,
     scheduler_interval => 'FREQ=daily;INTERVAL=1',
     notifications => true);
end;
/

Livefeed-Prozedur löschen

Dieses Verfahren löscht einen Livetabellenfeed.

Syntax

procedure drop_live_feed(live_feed_name     IN VARCHAR2,
                                  schema             IN VARCHAR2 DEFAULT NULL);

Beispiel

In diesem Beispiel wird ein Livefeed mit dem Namen MYLIVEFEED gelöscht.

begin
   dbms_live_feed.drop_live_feed(live_feed_name => 'MYLIVEFEED');
end;
/

Prozedur "Neuen Inhalt laden"

Diese Prozedur lädt neue Inhalte in den Feed.

Syntax

 procedure load_new_content(live_feed_name IN VARCHAR2,
                                     schema         IN VARCHAR2 DEFAULT NULL);

Prozedur "Benachrichtigungsschlüssel abrufen"

Dieses Verfahren erhält den Benachrichtigungsschlüssel für Livetabellenfeed. Es wird für einen Livefeed mit aktivierten Benachrichtigungen verwendet, um eine Benachrichtigungs-URL für die Bereitstellung eines Cloud-Service zu erstellen. Befolgen Sie die Anweisungen im Kapitel Benachrichtigungsbasierten Live-Tabellenfeed erstellen, um einen benachrichtigungsbasierten Livefeed zu erstellen.

Syntax

function get_notification_key(live_feed_name IN VARCHAR2,
                                       schema         IN VARCHAR2 DEFAULT NULL)
    return VARCHAR2;

Bestätigungs-URL abrufen

Diese Prozedur erhält eine Bestätigungs-URL, die prüft, ob der Endpunkt Benachrichtigungen empfangen kann.

Sie müssen diese URL aufrufen, um Benachrichtigungen zu aktivieren, die Sie von einem Cloud-Service erhalten. Die Aktivierung von Benachrichtigungen kann aufgrund von Einschränkungen der Datenbankfirewall nicht automatisch bestätigt werden. Klicken Sie auf diese URL, um Benachrichtigungen zu aktivieren. Andernfalls erhalten Sie keine Benachrichtigungen.

Syntax

function get_confirmation_url(live_feed_name IN VARCHAR2,
                                       schema         IN VARCHAR2 DEFAULT NULL)
    return VARCHAR2;

Benachrichtigungsstatus abrufen

Diese Prozedur erhält den Status der Benachrichtigung über die Ausführung des Livefeed-Jobs.

Syntax

 function get_notification_state(live_feed_name IN VARCHAR2,
                                          schema         IN VARCHAR2 DEFAULT NULL)
    return VARCHAR2;