Informations de référence sur l'ensemble DBMS_LIVE_FEED

Ce chapitre fournit des informations sur les packages que vous utilisez avec l'outil de chargement de données dans Data Studio. La rubrique DBMS_LIVE_FEED couvre également les procédures incluses dans l'ensemble DBMS_LIVE_FEED.

Rubriques :

Sommaire des sous-programmes DBMS_LIVE_FEED

DBMS_LIVE_FEED Procédures

Sommaire des sous-programmes DBMS_LIVE_FEED
L'ensemble DBMS_LIVE_FEED simplifie les opérations courantes telles que l'exécution d'un flux de données de table en direct sur demande, selon un programme ou à la suite de mises à jour guidées par avis d'une table en fonction des nouveaux objets dans les seaux du magasin d'objets.

Rubrique parent : Page Chargement de données

Sommaire des sous-programmes DBMS_LIVE_FEED

L'ensemble DBMS_LIVE_FEED simplifie les opérations courantes telles que l'exécution d'une alimentation de table active sur demande, selon un programme ou à la suite de mises à jour guidées par avis d'une table en fonction des nouveaux objets dans les seaux du magasin d'objets.

DBMS_LIVE_FEED Sous-programmes d'ensemble

Le tableau suivant répertorie les sous-programmes DBMS_LIVE_FEED et les décrit brièvement.

Sous-programme	Description
create_for_storage_link	Cette procédure crée un flux dynamique pour le lien de stockage.
create_for_directory	Cette procédure crée un flux dynamique pour le répertoire.
create_for_url	Cette procédure crée un flux dynamique à partir de l'URL.
modify_live_feed	Cette procédure modifie un flux dynamique.
drop_live_feed	Cette procédure supprime un flux en direct.
load_new_content	Cette procédure charge le nouveau contenu dans un flux dynamique existant.
get_notification_key	Cette procédure extrait la clé d'avis d'un flux dynamique.
get_confirmation_url	Cette procédure reçoit l'URL de confirmation d'un flux Live.
get_notification_state	Cette procédure reçoit l'état de notification d'un flux dynamique.

Procédure Créer pour lien de stockage

Cette procédure crée un flux de table dynamique à partir d'un lien de stockage en nuage. Un lien de stockage en nuage est une association nommée entre un URI de seau OCI et un nom de données d'identification local.

Syntaxe

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 Paramètres

Si vous accédez aux procédures DBMS_LIVE_FEED, utilisez les paramètres suivants.

Paramètre	Description
`live_feed_name`	Nom du flux Live que vous souhaitez créer.
`storage_link_name`	Nom du lien de stockage en nuage. Le nom du lien doit respecter les conventions de dénomination standard d'Oracle.
`table_name`	Nom de la table cible Autonomous Database dans laquelle le flux de données en direct chargera les données à partir du stockage d'objets en nuage.
`Object_filter`	Nom de la table cible dans laquelle les données du flux dynamique seront chargées dans votre instance Autonomous Database pour accéder au service de stockage d'objets en nuage.
`object_filter_type`	Expression rationnelle pour limiter l'alimentation de table active aux seuls fichiers du seau qui correspondent à l'expression. . Il peut s'agir d'une expression rationnelle ou d'un glob, selon le paramètre `object_filter_type`.
`scheduled`	La valeur par défaut est `TRUE`. Si `TRUE`, vous pouvez configurer une programmation pour l'exécution de l'objet de flux de tables en direct.
`notifications`	La valeur par défaut est `FALSE`. Lorsque `TRUE`, l'outil Live Feed permet à votre livefeed d'être informé par le stockage d'objets qu'il y a de nouveaux fichiers à charger.
`schema`	Nom du schéma. Nom du schéma du flux de données actif. Seul le schéma courant est pris en charge pour le moment.
`table_schema`	Schéma de la table cible.
`object_type`	Type de l'objet. Les types de fichier que vous pouvez charger sont CSV, JSON et Parquet.
`object_format`	Il s'agit de l'une des options SQL Loader. Il accepte le format reçu par la procédure `DBMS_CLOUD.COPY_DATA`.
`scheduler_interval`	Ce paramètre affiche l'intervalle auquel le flux dynamique s'exécute à l'aide de la syntaxe `DBMS_SCHEDULER`.
`job_class`	Classe de travail du programmateur. Les valeurs sont `TPURGENT,TP,HIGH,MEDIUM` et `LOW`.
`start_date`	Date de début de la tâche de flux de production.
`end_date`	Date de fin de la tâche de flux dynamique.

Note

Les paramètres de toutes les procédures décrites ci-dessous sont répertoriés dans le tableau ci-dessus.

Exemple

Dans cet exemple, un flux dynamique nommé MYLIVEFEED est créé sur l'URL indiquée.

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.

Procédure Créer pour répertoire

Cette procédure crée un flux de table dynamique à partir d'un répertoire.

Syntaxe

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

Procédure Créer pour URL

Cette procédure crée un flux de table dynamique à partir d'une URL.

Syntaxe

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

Modifier la procédure Live Feed

Cette procédure modifie un flux de table actif.

Syntaxe

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

Exemple

Dans cet exemple, un flux dynamique nommé MYLIVEFEED est modifié.

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

Procédure Drop Live Feed

Cette procédure supprime un flux de table actif.

Syntaxe

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

Exemple

Dans cet exemple, un flux dynamique nommé MYLIVEFEED est supprimé.

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

Procédure de chargement du nouveau contenu

Cette procédure charge le nouveau contenu dans le flux.

Syntaxe

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

Procédure d'obtention de la clé d'avis

Cette procédure reçoit la clé de notification Live Table Feed. Utilisé pour un flux en direct avec des avis activés pour construire une URL d'avis pour fournir un service en nuage. Suivez les instructions du chapitre Création d'un flux de table dynamique basé sur des avis pour créer un flux dynamique basé sur des avis.

Syntaxe

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

Obtenir l'URL de confirmation

Cette procédure reçoit une URL de confirmation qui vérifie que le point d'extrémité peut recevoir des avis.

Vous devez visiter cette URL pour activer les avis que vous recevez d'un service en nuage. Il n'est pas possible de confirmer l'activation automatique des notifications en raison des restrictions de pare-feu de base de données. Cliquez sur cette URL pour activer les avis, sinon vous ne recevrez aucun avis.

Syntaxe

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

Obtenir l'état de l'avis

Cette procédure reçoit l'état de notification de l'exécution de la tâche Live Feed.

Syntaxe

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

Rubrique parent : Informations de référence sur l'ensemble DBMS_LIVE_FEED

Documentation sur Oracle Cloud Infrastructure

Informations de référence sur l'ensemble DBMS_LIVE_FEED

Sommaire des sous-programmes DBMS_LIVE_FEED