Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Analytics Consumption Zone (ACZ) exporta datos de entidad seleccionados de Azure Data Manager for Energy a la cuenta de Azure Data Lake Storage Gen2. ACZ almacena los datos de Azure Data Manager for Energy en formato abierto Delta Parquet. Los servicios como Microsoft Fabric y Azure Databricks pueden leer este formato directamente.
Importante
La zona de consumo de Analytics está actualmente en versión preliminar. Para conocer los términos legales que se aplican a las características de Azure que se encuentran en versión beta, versión preliminar o que aún no se han publicado en disponibilidad general, consulte Términos de uso complementarios para las versiones preliminares de Microsoft Azure.
Durante la versión preliminar, ACZ solo está disponible en instancias de nivel de desarrollador y requiere el uso de listas de permitidos. Siga las instrucciones de Enable Analytics Consumption Zone (Habilitar zona de consumo de Analytics) y póngase en contacto con su representante de Microsoft.
¿Qué es ACZ?
ACZ es una capa de sincronización administrada. Exporta los datos de entidades de su instancia de Azure Data Manager for Energy a una cuenta de almacenamiento de Azure Data Lake Storage Gen2 de su propiedad. Después, puede conectar esos datos a herramientas de análisis, informes y aprendizaje automático.
Características clave de ACZ:
- Almacenamiento propiedad del cliente: cree y administre una cuenta de almacenamiento Data Lake Storage Gen2 donde van los datos. Usted es responsable de seleccionar una cuenta de almacenamiento de destino en la zona geográfica si tiene requisitos de residencia de los datos.
- Formato abierto: sus exportaciones de datos se realizan en formato Delta Parquet. Los motores de análisis admiten ampliamente este formato.
- Selective sync: elija los tipos de entidad que se van a sincronizar. Las opciones incluyen tipos de catálogo y tipos de dominio de Wellbore Administración de datos Service (DDMS).
- Sincronización histórica e incremental: obtiene una instantánea inicial de los datos existentes de ACZ. A continuación, ACZ sincroniza los cambios a medida que se producen.
- Controlado por API: puede configurar y administrar ACZ por completo a través de las API REST.
Architecture
En el diagrama siguiente se muestra el flujo de datos de ACZ.
Funcionamiento de ACZ
Tipos de entidad admitidos
ACZ sincroniza dos categorías de tipos de entidad de Azure Data Manager for Energy.
| Category | Description | Tipos de ejemplo |
|---|---|---|
| Tipos de catálogo | Datos principales y datos de referencia del servicio de almacenamiento |
osdu:wks:master-data--Well:*, osdu:wks:reference-data--UnitOfMeasure:* |
| Tipos de DDMS de Wellbore | Entidades de Wellbore DDMS | osdu:wks:work-product-component--WellLog:* |
Cuando se crea una instancia de ACZ, se especifican los tipos de entidad que se van a sincronizar proporcionando:
-
catalogKinds: una lista de patrones de tipo de catálogo (por ejemplo,osdu:wks:master-data--Well:*). -
wellboreDDMSKinds: una lista de patrones de tipo DDMS de Wellbore (por ejemplo,osdu:wks:work-product-component--WellLog:*).
Estos patrones de tipo actúan como filtros que determinan qué registros de Azure Data Manager for Energy exporta y mantiene sincronizados ACZ.
Uso de la marca allCatalogSync
La allCatalogSync marca es un parámetro booleano opcional que puede especificar al crear una instancia de ACZ. Cuando se establece en true, sincroniza todos los tipos de catálogo de la partición de datos.
Comportamientos clave:
-
allCatalogSyncse especifica fuera de la secciónconfigurationen el cuerpo de la solicitud. - Cuando
allCatalogSync: true, ACZ exporta todos los tipos de catálogo automáticamente. - Las matrices
catalogKindsywellboreDDMSKindsde la configuración se ignoran en los datos de catálogo. - Las descargas masivas de archivos DDMS de Wellbore no se ven afectadas por esta marca. Los archivos solo se descargan para los tipos enumerados explícitamente en
wellboreDDMSKinds.
Configuraciones de ejemplo:
// Selective catalog sync - only Wells and Fields
{
"allCatalogSync": false,
"configuration": {
"catalogKinds": [
"osdu:wks:master-data--Well:*",
"osdu:wks:master-data--Field:*"
]
}
}
// Sync all catalog kinds using allCatalogSync flag
{
"allCatalogSync": true,
"configuration": {
// catalogKinds is ignored when allCatalogSync is true
}
}
// Sync all catalog kinds, but Wellbore DDMS files only for specified kinds
{
"allCatalogSync": true,
"configuration": {
"wellboreDDMSKinds": [
"osdu:wks:work-product-component--WellLog:*"
]
}
}
Tipos de versión
Al crear una instancia de ACZ, elija cómo controlar las versiones de entidad.
| Tipo | Description |
|---|---|
| LATEST_VERSION | Exporta solo la versión más reciente de cada entidad. Valor predeterminado y recomendado. |
| ALL_VERSIONS | Exporta todas las versiones de cada entidad. Mantiene el historial de versiones completo. |
Estados de ciclo de vida
Cada ACZ pasa por estos estados:
| Situación | Description |
|---|---|
| ACTIVO | Operativo. ACZ sincroniza los cambios de forma incremental. |
| error | Error que detuvo la instalación o sincronización. |
| ACCESS_DENIED | ACZ no puede acceder a la cuenta de almacenamiento de destino de Data Lake Storage Gen2. |
Instantánea histórica
Al crear una nueva instancia de ACZ, el servicio toma una instantánea histórica. Esta instantánea exporta todos los registros existentes que coinciden con los tipos de entidad configurados (catalogKinds y wellboreDDMSKinds). La instantánea avanza a través de los siguientes estados:
| Situación | Description |
|---|---|
| TRATAMIENTO | Exportación activa de datos. |
| COMPLETADO | Todos los datos históricos exportados. |
| error | Se produjo un error. |
Una vez finalizada la instantánea, ACZ cambia al modo incremental. Captura registros nuevos y actualizados casi en tiempo real.
Cómo controla ACZ los cambios de datos
ACZ propaga los registros creados, actualizados y eliminados de Azure Data Manager for Energy a las tablas Delta.
- Creaciones y actualizaciones: al crear un registro o cambiar su bloque de datos, Azure Data Manager for Energy crea una nueva versión. ACZ detecta el cambio y escribe una nueva fila en la tabla Delta.
-
Actualizaciones solo de metadatos: cuando una operación
PATCHcambia la lista de control de acceso, la configuración de retención legal o las etiquetas sin crear una nueva versión, ACZ detecta este cambio y ejecuta una operación de inserción o actualización de combinación en la fila existente. -
Eliminaciones lógicas: Cuando elimina lógicamente un registro en Azure Data Manager for Energy, ACZ establece el campo
isActiveenFalseen la fila en lugar de eliminarlo. Las eliminaciones temporales conservan el historial de las consultas de auditoría y viaje en el tiempo. - Purges: al purgar un registro en Azure Data Manager for Energy, ACZ quita permanentemente el registro de la tabla Delta. La fila se elimina y no se puede recuperar de los datos de ACZ.
Advertencia
ACZ es una sincronización unidireccional de solo lectura de Azure Data Manager for Energy a Data Lake Storage Gen2:
- Los datos solo fluyen de Azure Data Manager para energía a Data Lake Storage Gen2.
- No modifique, elimine ni agregue archivos directamente en las carpetas ACZ de Data Lake Storage Gen2.
- Los cambios manuales en los datos de ACZ dañan la sincronización y provocan incoherencias de datos.
- ACZ administra todas las operaciones de Delta Lake (registros de transacciones, puntos de comprobación y compactación).
Para el análisis y los informes, trate los datos exportados como de solo lectura. Todas las modificaciones de datos deben producirse en Azure Data Manager for Energy.
Formato de salida de datos
ACZ escribe datos en formato Delta Lake con archivos codificados en Parquet (DELTA_PARQUET). Delta Lake admite transacciones con atomicidad, consistencia, aislamiento y durabilidad. También admite lecturas incrementales eficientes y viajes en el tiempo.
estructura de carpetas de Data Lake Storage Gen2
ACZ organiza los datos en la cuenta de almacenamiento de Data Lake Storage Gen2 por carpeta. Cada instancia de ACZ tiene su propia carpeta dentro del contenedor o dentro de la ruta base, si ha especificado una. ACZ divide en particiones las tablas de Delta Lake del catálogo por tipo. Una carpeta por tipo de entidad DDMS e identificador de registro.
Diseño de carpetas
Detalles clave
| Elemento | Description |
|---|---|
| Carpeta de nivel superior | Con el nombre <acz-id> dentro del contenedor, o debajo de <base-path> si se especifica. Una carpeta por instancia de ACZ. |
osducatalog/ |
Una tabla Delta para todos los tipos de catálogo. Particionado por tipo (por ejemplo, kind=osdu:wks:master-data--Well:1.0.0). |
_delta_log/ |
Registro de transacciones de Delta Lake. Realiza un seguimiento de todos los cambios de tabla para las transacciones ACID y el viaje en el tiempo. |
| Carpetas de entidades DDMS | Una carpeta por tipo de entidad DDMS (por ejemplo, work-product-component--WellLog). Contiene archivos Parquet específicos de DDMS por tipo de entidad y identificador de registro. |
| Archivos de Parquet | Archivos de datos comprimidos por Snappy. Las actualizaciones crean nuevos archivos. ACZ ejecuta VACUUM y OPTIMIZE para compactar archivos pequeños y eliminar los antiguos. |
Esquema de tabla delta
La tabla Delta tiene los siguientes campos:
| Campo | Tipo | Description |
|---|---|---|
id |
String | Id. de registro de OSDU®. |
version |
String | Número de versión. |
kind |
String | Tipo OSDU® completamente cualificado. |
data |
String | Bloque de datos (JSON). |
meta |
String | Metadatos (JSON). |
acl |
String | Lista de control de acceso. |
legal |
String | Etiquetas legales. |
tags |
String | Etiquetas definidas por el usuario. |
createUser |
String | Usuario que creó el registro. |
createTime |
Marca de tiempo | Cuando se creó el registro. |
ingestTime |
Marca de tiempo | Cuando ACZ ingirió el registro: |
isActive |
Booleano |
True si está activo.
False si se elimina temporalmente. |
Nota:
Las entidades DDMS de Wellbore también disponen de los campos fileDownloadTime, fileDownloadState y fileDownloadFolder para el seguimiento de archivos.
Límites y acceso
Límites de la versión preliminar
| Restricción | Limit |
|---|---|
| Número máximo de instancias de ACZ por partición de datos | tres |
| Unicidad del nombre de ACZ | Debe ser único dentro de una partición de datos. |
| Formato de destino | Solo Delta Parquet |
| Tipo de almacenamiento | Solo para Data Lake Storage Gen2 |
| Compatibilidad con niveles de instancia | Solo nivel para desarrolladores durante la fase preliminar |
Autenticación y autorización
ACZ requiere:
-
Acceso a la API: para llamar a las API de ACZ, debe pertenecer a los
users@{data-partition-id}.dataservices.energygrupos yusers.datalake.ops@{data-partition-id}.dataservices.energy. - Acceso de almacenamiento: la identidad administrada necesita el rol Colaborador de datos de Storage Blob (o equivalente) en el contenedor de Data Lake Storage Gen2. Durante la versión preliminar, comparta los detalles de identidad con Microsoft para agregar la identidad a la lista de permitidos.
- Azure Data Manager para el acceso a energía: la identidad administrada debe asignarse al recurso de Azure Data Manager for Energy.