Documentación de Oracle Cloud Infrastructure

Referencia de Paquete DBMS_LIVE_FEED

En este capítulo se proporciona información sobre los paquetes que se utilizan con la herramienta de carga de datos de Data Studio. El tema DBMS_LIVE_FEED también abarca los procedimientos incluidos en el paquete DBMS_LIVE_FEED.

Temas:

Resumen de subprogramas DBMS_LIVE_FEED

  • Resumen de los subprogramas DBMS_LIVE_FEED
    El paquete DBMS_LIVE_FEED simplifica las operaciones comunes, como la ejecución de una fuente de tabla activa a demanda, según un programa o como resultado de actualizaciones controladas por notificaciones en una tabla basada en objetos nuevos en cubos de almacén de objetos.

Tema principal: Página Carga de datos

Resumen de subprogramas DBMS_LIVE_FEED

El paquete DBMS_LIVE_FEED simplifica las operaciones comunes, como la ejecución de una fuente de tabla activa a demanda, según un programa o como resultado de actualizaciones controladas por notificación en una tabla basada en nuevos objetos en cubos de almacén de objetos.

Subprogramas de Paquete DBMS_LIVE_FEED

En la siguiente tabla se muestran los subprogramas DBMS_LIVE_FEED y se describen brevemente.

Subprograma Descripción
create_for_storage_link

Este procedimiento crea una fuente activa para el enlace de almacenamiento.
create_for_directory

Este procedimiento crea una fuente activa para el directorio.
create_for_url

Este procedimiento crea una fuente activa a partir de la URL.
modify_live_feed

Este procedimiento modifica una fuente activa.
drop_live_feed

Este procedimiento elimina una fuente activa.
load_new_content

Este procedimiento carga contenido nuevo en una fuente activa existente.
get_notification_key

Este procedimiento recupera la clave de notificación de una fuente activa.
get_confirmation_url

Este procedimiento recibe la URL de confirmación de una fuente activa.
get_notification_state

Este procedimiento recibe el estado de notificación de una fuente activa.

Procedimiento de creación de enlace de almacenamiento

Este procedimiento crea una fuente de tabla activa a partir de un enlace de almacenamiento en la nube. Un enlace de almacenamiento en la nube es una asociación con nombre entre un URI de cubo de OCI y un nombre de credencial local.

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

Parámetros de DBMS_ LIVE_FEED

Si está accediendo a los procedimientos DBMS_LIVE_FEED, utilice los siguientes parámetros.

parámetro Descripción

live_feed_name

Nombre de la fuente activa que desea crear.

storage_link_name

Nombre del enlace de almacenamiento en la nube. El nombre del enlace debe seguir las reglas de nomenclatura estándar de Oracle.

table_name

Nombre de la tabla de destino de Autonomous Database en la que la fuente activa cargará datos de Cloud Object Storage.

Object_filter

Nombre de la tabla de destino en la que se cargarán los datos de la fuente activa en la instancia de Autonomous Database para acceder a Cloud Object Storage.

object_filter_type

Expresión regular para limitar la fuente de tabla activa solo a los archivos del cubo que coinciden con la expresión. . Puede ser una expresión regular o glob, según el parámetro object_filter_type.

scheduled

El valor por defecto es TRUE. Si TRUE, puede configurar un programa para ejecutar el objeto de fuente de tabla activa.

notifications

El valor por defecto es FALSE. Cuando TRUE, la herramienta de fuente activa permite que el almacenamiento de objetos notifique a la fuente activa que hay nuevos archivos que cargar.

schema

Nombre del esquema.

Nombre del esquema de la fuente activa. Solo está soportado el esquema actual en este momento.

table_schema

Esquema de la tabla de destino.

object_type

Tipo de objeto. Los tipos de archivos que puede cargar son CSV, JSON y Parquet.

object_format

Esta es una de las opciones del cargador SQL.

Acepta el formato recibido por el procedimiento DBMS_CLOUD.COPY_DATA.

scheduler_interval

Este parámetro muestra el intervalo en el que se ejecuta la fuente activa mediante la sintaxis DBMS_SCHEDULER.

job_class

Clase de trabajo del programador. Los valores son TPURGENT,TP,HIGH,MEDIUM y LOW.

start_date

Fecha de inicio del trabajo de fuente activa.

end_date

Fecha de finalización del trabajo de fuente activa.
Nota

Los parámetros de todos los procedimientos descritos a continuación se muestran en la tabla anterior.

Ejemplo

En este ejemplo, se crea una fuente activa denominada MYLIVEFEED en la URL proporcionada. 

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.

Crear para procedimiento de directorio

Este procedimiento crea una fuente de tabla activa desde un directorio.

Sintaxis

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

Procedimiento Crear para URL

Este procedimiento crea una fuente de tabla activa a partir de una URL.

Sintaxis

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

Modificar procedimiento de fuente activa

Este procedimiento modifica una fuente de tabla activa.

Sintaxis

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

Ejemplo

En este ejemplo, se modifica una fuente activa denominada MYLIVEFEED. 

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

Procedimiento de borrado de fuente activa

Este procedimiento borra una fuente de tabla activa.

Sintaxis

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

Ejemplo

En este ejemplo, se borra una fuente activa denominada MYLIVEFEED. 

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

Cargar nuevo procedimiento de contenido

Este procedimiento carga contenido nuevo en la fuente.

Sintaxis

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

Obtener procedimiento de clave de notificación

Este procedimiento recibe la clave de notificación de fuente de tabla activa. Se utiliza para una fuente activa con notificaciones activadas para crear una URL de notificación para proporcionar un servicio en la nube. Siga las instrucciones del capítulo Creación de una fuente de tabla activa basada en notificación para crear una fuente activa basada en notificación.

Sintaxis

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

Obtener URL de confirmación

Este procedimiento recibe una URL de confirmación que verifica que el punto final pueda recibir notificaciones.

Debe visitar esta URL para activar las notificaciones que recibe de un servicio en la nube. No se puede confirmar la activación automática de notificaciones debido a restricciones de firewall de base de datos. Haga clic en esta URL para activar las notificaciones; de lo contrario, no recibirá ninguna notificación.

Sintaxis

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

Obtener estado de notificación

Este procedimiento recibe el estado de notificación de la ejecución del trabajo de fuente activa.

Sintaxis

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