Extracciones de consumo configurable
Las extracciones de consumo configurable son extracciones de datos de medida para un juego de suscripciones de consumo relacionadas de manera opcional con un determinado participante en el mercado.
Las opciones de configuración de estas extracciones son:
-
Tipo de participante en el mercado, en función de las tablas Participante en el mercado de punto de servicio o Participante en el mercado de suscripción de consumo y la relación de mercado
-
Tipos de suscripciones de consumo asociados con el participante en el mercado (por lo general, un sistema de información de clientes que recibe determinantes de factura)
-
Combinaciones exclusivas de unidad de medida, discriminación horaria e identificador de cantidad de servicio asociadas con las suscripciones de consumo
-
Identificadores específicos que se utilizan para identificar las suscripciones de consumo, los puntos de servicio y los dispositivos asociados con los datos de medida extraídos
-
Parámetros de fecha y hora y frecuencia de extracción
-
Nomenclatura de ficheros de extracción y opciones de compresión
Las extracciones de consumo se exportan a un fichero en una ubicación especificada: un servidor de aplicaciones (en una implantación local) o una ubicación de Oracle Cloud Infrastructure Object Storage.
Las extracciones de consumo se crean mediante las solicitudes de extracción de consumo. Consulte Solicitudes de extracción de consumo en la guía del usuario de negocio.
En esta sección se describe la configuración que es necesario realizar con estos tipos de extracciones de consumo.
Tipos de extracción de consumo
Los tipos de extracción de consumo se utilizan para configurar las extracciones de consumo. Consulte Tipo de extracción de consumo en la guía del usuario administrativo para obtener más información sobre cómo crear estos registros.
El objeto de negocio Extraer consumo de suscripción de consumo a fichero (D1-ExtractUSConsumptionToFile) se utiliza para crear tipos de extracción de consumo configurable. Consulte la ayuda embebida correspondiente a este objeto de negocio para obtener más información sobre los parámetros definidos para los tipos de extracción de consumo.
Los tipos de extracción de consumo Extraer consumo de suscripción de consumo a fichero definen los parámetros siguientes:
- Los participantes en el mercado para los que se extraerán datos de medida. Los participantes en el mercado se definen en función de su tipo (Participante en el mercado de punto de servicio o Participante en el mercado de suscripción de consumo) y el tipo de relación de mercado (minorista, distribuidor, proveedor, etcétera) y un participante en el mercado concreto. Nota: si el campo Específico de participante en el mercado se define como "No", el participante en el mercado que se utiliza se basa en el destinatario de consumo de la suscripción de consumo o en su tipo de suscripción de consumo.
- El tipo de consumo (intervalo o escalar)
- Uno o varios tipos de suscripción de consumo y una combinación de UM/discriminación horaria/identificador de cantidad de servicio exclusiva
- Los tipos de ID específicos para incluir en el fichero de extracción de la suscripción de consumo, punto de servicio, punto de servicio secundario (si procede) y dispositivo
- Los parámetros de ejecución son:
- La fecha y la hora a la que se han extraído los datos para este tipo de extracción de consumo.
- Un tipo de solicitud. Los tipos de solicitud que se utilizan con las solicitudes de consumo deben crearse con el objeto de negocio Tipo de solicitud de extracción de consumo (D2-IntervalDataExtRepoType) y deben hacer referencia al objeto de negocio Extracción de consumo (D2-IntervalDataExtRepository) en el campo Objeto de negocio de solicitud. (Consulte la descripción general de las solicitudes The Big Picture of Requests en la guía del usuario administrativo Application Framework Administrative User Guide).
- La frecuencia de las extracciones de este tipo (ad hoc o diaria)
- Los controles de lotes que se utilizan con el proceso de extracción (consulte Controles de lotes a continuación)
- Los parámetros de fichero son:
- La ubicación donde se guardarán los ficheros de extracción (consulte el apartado sobre el almacenamiento de ficheros externos External File Storage en la guía del usuario administrativo Application Framework Administrative User Guide).
- Una carpeta secundaria opcional en la ubicación de fichero
- Opciones de nomenclatura de ficheros (que incluyen un prefijo opcional y un registro de fecha y hora)
- Si el fichero de extracción se comprime o no (la compresión de ficheros se realiza mediante gzip)
Controles de lotes
El proceso de extracción de los datos y la creación de los ficheros de exportación se realiza mediante los controles de lotes siguientes:
- Extraer intervalos suscripción consumo actuales en fichero (D1-ECUSI): se utiliza con las extracciones diarias de consumo de intervalo. Este proceso necesita que se generen los datos de asignación de instantánea de intervalo para cada tamaño de intervalo que se extraiga. Esto incrementa la eficiencia a la hora de trasladar los datos de intervalo a columnas de intervalo diario. Para obtener más información, consulte Asignación de instantáneas de intervalo.
- Extraer a fichero intervalo suscripción consumo sustitución (D1-ERUSI): se utiliza con las extracciones de consumo de intervalo histórico de sustitución. Este proceso se ejecuta con los registros de captura de datos de cambio en la tabla Proceso general (consulte Captura de datos de cambio con corrección posterior de medida inicial a continuación).
- Extraer a fichero lectura escalar actual suscripción consumo (D1-ECUSS): se utiliza con las extracciones diarias de consumo escalar.
- Extraer a fichero lectura escalar sustitución suscripción (D1-ERUSI): se utiliza con las extracciones de consumo de intervalo escalar de sustitución. Este proceso se ejecuta con los registros de captura de datos de cambio en la tabla Proceso general (consulte Captura de datos de cambio con corrección posterior de medida inicial a continuación).
Estos controles de lotes se ejecutan para un tipo de extracción de consumo y un rango de fechas concretos. Este procesamiento por lotes se divide en threads por ID de suscripción de consumo.
Consulte Solicitudes de extracción de consumo - Controles de lotes en la sección Definición de opciones de DataConnect del capítulo Integraciones para obtener información general sobre el procesamiento por lotes de extracciones de consumo.
Captura de datos de cambio con corrección posterior de medida inicial
Estos algoritmos se encargan de mantener la fecha/hora de los componentes de medición en función de la fecha y hora de la última medida del componente de medición. También comprueban cuál es el tipo de extracción de consumo aplicable al componente de medición de la medida inicial actual e identifican si la medida inicial es para una fecha y hora que se han extraído con anterioridad.
Algoritmo |
Descripción |
Tipo de consumo |
---|---|---|
D1-UPD-DTMC |
Actualizar última fecha/hora de medida en componente de medición con sincronización de consumo |
Intervalo |
D1-UDTSCMCRE |
Actualizar última fecha/hora en componente de medición escalar con sincronización consumo |
Escalar |
D1-UPD-DTMCF |
Actualizar última fecha/hora en componente de medición de una medida futura |
Intervalo |
D1-UPDDTSCMC |
Actualizar última fecha/hora en componente de medición escalar |
Escalar |
Si una medida inicial corresponde a una fecha y hora que ya se han extraído con anterioridad, estos algoritmos crean registros de captura de datos de cambio en la tabla Proceso general que registran el código de lote, el número de ejecución de lote y el ID de la medida inicial. Los procesos por lotes de "Sustitución" se ejecutan al margen de estos registros.
- Capturar cambios de medida históricos de tipo de extracción de consumo: verdadero
Formato de fichero - Intervalo
El proceso de extracción de intervalo genera ficheros JavaScript Object Notation (JSON) con los datos descritos en esta tabla.
Tenga en cuenta que los ficheros de extracción de intervalo pueden almacenar un máximo de 300 intervalos. Esto significa que los ficheros de exportación pueden almacenar:
- 12,5 días de datos por horas
- 3 días de datos de 15 minutos
- 1 día de datos de 5 minutos
Campo |
Valor de muestra |
Comentarios |
---|---|---|
usId |
995647003500 |
ID de suscripción de consumo definido por el tipo de extracción de consumo |
usType |
E-RES |
Tipo de suscripción de consumo |
pSpId |
458081 |
ID de punto de servicio principal, nulo cuando no hay ningún punto de servicio principal. |
spId |
458081_001 |
ID de punto de servicio secundario Es el ID de punto de servicio definido por el tipo de extracción de consumo |
dvcId |
SN823287793219 |
ID de dispositivo definido por el tipo de extracción de consumo |
uomTouSqi |
KWH// |
Unidad de medida/discriminación horaria/identificador de cantidad de servicio separados por barras diagonales ("/") |
tz |
Hora del Este de Estados Unidos |
Zona horaria del punto de servicio. Es el nombre de la zona horaria procedente de la tabla CI_TIME_ZONE, no el código de la zona horaria. |
intPerDay |
288 |
Número de intervalos del día; será 1 hora menos o 1 hora más de los intervalos de los cambios del horario de verano. |
intSize |
300 |
Duración de cada intervalo en segundos |
mktPart |
DIRECT_ENERGY |
ID del participante en el mercado (si procede) |
stDttm |
2020-01-01T00:00:00-05:00 |
Comienzo del día, similar a la medida inicial; representa el comienzo del primer intervalo. |
q1 |
1.325 |
Valor de medida del primer intervalo; la fecha/hora de medida de este intervalo sería stDttm más intSize. |
c1 |
301000 |
Condición de medida del primer intervalo. Nulo cuando "Habitual" (501000) |
q2 |
1.230 |
|
c2 |
301000 |
|
... |
q/c 3 a 299 aquí |
|
q300 |
.9134 |
|
c300 |
30100 |
Ejemplo:
{"usId":"995647003500", "usType":"E-RES", "pSpId":"458081", "spId":"458081_001", "dvcId":"SN823287793219", "uomTouSqi":"KWH//",
"tz":"US/Eastern", "intPerDay":"288", "intSize":"300", "mktPart":"DIRECT_ENERGY",
"stDttm":"2020-01-01T00:00:00-05:00", "q1":"1.325", "c1":"301000", "q2":"1.325",
"c2":"301000" "q3":"1.325", "c3":"301000",
<intervening intervals>, "q300":"1.325", "c300":"301000"}
Formato de fichero - Escalar
El proceso de extracción escalar genera ficheros JavaScript Object Notation (JSON) con los datos descritos en esta tabla.
Nombre |
Valor de muestra |
Comentarios |
---|---|---|
c |
301000 |
Condición de medida de la lectura escalar Nulo cuando "Habitual" (501000) |
dvcId |
SN823287793219 |
ID de dispositivo definido por el tipo de extracción de consumo |
enDttm |
2020-01-02T00:00:00-05:00 |
Fecha/hora de finalización de la lectura |
mktPart |
DIRECT_ENERGY |
ID del participante en el mercado (si procede) |
pSpId |
458081 |
|
q |
1.325 |
Valor de medida de la lectura escalar |
r |
678645 |
Lectura de dial del contador |
spId |
458081_001 |
ID de punto de servicio definido por el tipo de extracción de consumo |
stDttm |
2020-01-01T00:00:00-05:00 |
Fecha/hora de inicio de la lectura (la fecha/hora de finalización de la lectura anterior) |
tz |
Hora del Este de Estados Unidos |
Zona horaria del punto de servicio. Es el nombre de la zona horaria procedente de la tabla CI_TIME_ZONE, no el código de la zona horaria. |
uomTouSqi |
KWH// |
Unidad de medida/discriminación horaria/identificador de cantidad de servicio separados por barras diagonales ("/") |
usId |
995647003500 |
ID de suscripción de consumo definido por el tipo de extracción de consumo |
usType |
E-RES |
Tipo de suscripción de consumo |
Ejemplo (3 registros):
{"usId":"995647003500", "usType":"E-RES", "pSpId":"458081", "spId":"458081_001", "dvcId":"SN823287793219", "uomTouSqi":"KWH//",
"tz":"US/Eastern", "mktPart":"DIRECT_ENERGY", "stDttm":"2020-01-01T00:00:00-05:00",
"enDttm":"2020-01-02T00:00:00-05:00", "q":"1.325", "c":"301000", "r":"678645"}
{"usId":"995647003500", "usType":"E-RES", "pSpId":"458081", "spId":"458081_001", "dvcId":"SN823287793219", "uomTouSqi":"KWH//",
"tz":"US/Eastern", "mktPart":"DIRECT_ENERGY", "stDttm":"2020-01-01T00:00:00-05:00",
"enDttm":"2020-01-02T00:00:00-05:00", "q":"1.325", "c":"301000", "r":"678645"}
{"usId":"995647003500", "usType":"E-RES", "pSpId":"458081", "spId":"458081_001", "dvcId":"SN823287793219", "uomTouSqi":"KWH//",
"tz":"US/Eastern", "mktPart":"DIRECT_ENERGY", "stDttm":"2020-01-01T00:00:00-05:00",
"enDttm":"2020-01-02T00:00:00-05:00", "q":"1.325", "c":"301000", "r":"678645"}
{"usId":"995647003500", "usType":"E-RES", "pSpId":"458081", "spId":"458081_001", "dvcId":"SN823287793219", "uomTouSqi":"KWH//",
"tz":"US/Eastern", "mktPart":"DIRECT_ENERGY", "stDttm":"2020-01-01T00:00:00-05:00",
"enDttm":"2020-01-02T00:00:00-05:00", "q":"1.325", "c":"301000", "r":"678645"}
Ampliación del procesamiento de extracción
Es posible que algunas implantaciones busquen ampliar o personalizar el proceso de extracción en función de determinados requisitos.
Ampliación de la lista de ID para utilizar
Los tipos de extracción de consumo definen tipos de ID para utilizar con las suscripciones de consumo, los puntos de servicio, los puntos de servicio secundarios (si procede) y los dispositivos. Si una implantación desea ampliar los tipos de ID disponibles, será necesario añadir los valores adecuados a los indicadores de lista de valores que se utilizan con cada tipo de ID. En la tabla siguiente se muestran los códigos de lista de valores que se utilizan con los campos de identificadores para usar.
Tipo de ID |
Indicador de lista de valores |
---|---|
ID de suscripción de consumo |
Tipo de identificador de suscripción de consumo (US_ID_TYPE_FLG) |
ID de punto de servicio (utilizado con los puntos de servicio principal y secundario) |
Tipo de identificador de punto de servicio (SP_ID_TYPE_FLG) |
ID de dispositivo |
Tipo de identificador de dispositivo (DVC_ID_TYPE_FLG) |
Procesamiento de registros y creación de ficheros de salida
El proceso de extracción utiliza las funciones de Procesos en segundo plano orientados por plug-in, pero trabaja de una manera algo diferente. En lugar de utilizar el algoritmo Seleccionar registros para recuperar los ID de los registros individuales para procesar, ese algoritmo devuelve un rango de identificadores de suscripción de consumo para extraer y el algoritmo Procesar registros ejecuta la consulta detallada para extraer el rango de identificadores de suscripción de consumo.
Esto tiene dos ventajas:
-
En el algoritmo Procesar registros, no hay límites en cuanto a la longitud de la consulta.
-
La recuperación de datos de muchas suscripciones de consumo en un único momento es mucho más eficiente.
Esto significa que las personalizaciones se pueden hacer creando un control de lotes personalizado y duplicando el script de proceso de registros de Groovy. Se pueden hacer cambios en el script de Groovy personalizado para el SQL de extracción si se desea recuperar información adicional o proporcionar criterios de selección adicionales. Si se necesita hacer algún cambio en el formato del fichero, se puede hacer dentro de la lógica de procesamiento de registros que rellena el fichero.