Nota
O acesso a esta página requer autorização. Pode tentar iniciar sessão ou alterar os diretórios.
O acesso a esta página requer autorização. Pode tentar alterar os diretórios.
O Analytics Consumption Zone (ACZ) exporta dados selecionados de entidades do Azure Data Manager for Energy para a sua conta Azure Data Lake Storage Gen2. O ACZ grava dados do Azure Data Manager for Energy no formato aberto Delta Parquet. Serviços como Microsoft Fabric e Azure Databricks podem ler este formato diretamente.
Importante
Analytics Consumption Zone está atualmente em versão preliminar. Para termos legais que se aplicam a funcionalidades do Azure que estejam em beta, pré-visualização ou que ainda não tenham sido lançadas em disponibilidade geral, consulte Termos Suplementares de Utilização para Prévisualizações do Microsoft Azure.
Durante a pré-visualização, o ACZ está disponível apenas em instâncias de nível Developer e requer o uso de listas de autorizações. Siga as orientações em Ativar Zona de Consumo de Análises e contacte o seu representante da Microsoft.
O que é o ACZ?
ACZ é uma camada de sincronização gerida. Ele exporta os dados de entidade da sua instância do Azure Data Manager for Energy para uma conta de armazenamento do Azure Data Lake Storage Gen2 de que é proprietário. Depois pode ligar esses dados a ferramentas de análise, relatórios e aprendizagem automática.
Principais características da ACZ:
- Armazenamento pertencente ao cliente: Cria e gere uma conta de armazenamento do Data Lake Storage Gen2 para a qual os seus dados são enviados. És responsável por selecionar uma conta de armazenamento dentro do destino geográfico se tiveres requisitos de residência de dados.
- Formato aberto: Os seus dados são exportados em formato Delta Parquet. Os motores de análise suportam amplamente este formato.
- Sincronização seletiva: Pode escolher quais os tipos de entidades a sincronizar. As opções incluem tipos de catálogo e tipos do Wellbore Domain Gestão de Dados Service (DDMS).
- Sincronização histórica e incremental: Obtém-se um instantâneo inicial dos dados existentes do ACZ. Depois, a ACZ sincroniza as alterações à medida que ocorrem.
- Orientado por APIs: Configura e gere o ACZ inteiramente através de APIs REST.
Arquitetura
O diagrama seguinte mostra o fluxo de dados ACZ.
Como funciona o ACZ
Tipos de entidade suportados
A ACZ sincroniza duas categorias de Azure Data Manager para tipos de entidades de Energia.
| Categoria | Description | Exemplos de tipos |
|---|---|---|
| Tipos de catálogo | Dados primários e dados de referência do serviço de armazenamento |
osdu:wks:master-data--Well:*, osdu:wks:reference-data--UnitOfMeasure:* |
| Tipos de DDMS de poço | Entidades do Wellbore DDMS | osdu:wks:work-product-component--WellLog:* |
Quando cria uma instância ACZ, especifica que tipos de entidades sincronizar, fornecendo:
-
catalogKinds: Uma lista de padrões de tipos de catálogo (por exemplo,osdu:wks:master-data--Well:*). -
wellboreDDMSKinds: Uma lista de padrões do tipo DDMS de Wellbore (por exemplo,osdu:wks:work-product-component--WellLog:*).
Este tipo de padrões funciona como filtros que determinam quais os registos do Azure Data Manager for Energy que o ACZ exporta e mantém sincronizados.
Utilize o sinalizador allCatalogSync
O allCatalogSync flag é um parâmetro booleano opcional que pode especificar quando cria uma instância ACZ. Quando definido para true, sincroniza todos os tipos de catálogo da partição de dados.
Principais comportamentos:
-
allCatalogSyncé especificado fora da secçãoconfigurationno corpo do pedido. - Quando
allCatalogSync: true, o ACZ exporta automaticamente todos os tipos de catálogo. - As matrizes
catalogKindsewellboreDDMSKindsna configuração são ignoradas no caso dos dados de catálogo. - Os downloads de ficheiros em massa do Wellbore DDMS não são afetados por esta flag. Os ficheiros só são descarregados para os tipos explicitamente listados em
wellboreDDMSKinds.
Exemplos de configurações:
// 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 versões
Quando crias uma instância ACZ, escolhes como lidar com as versões das entidades.
| Tipo | Description |
|---|---|
| LATEST_VERSION | Exporta apenas a versão mais recente de cada entidade. Padrão e recomendado. |
| ALL_VERSIONS | Exporta todas as versões de cada entidade. Mantém o histórico completo das versões. |
Estados do ciclo de vida
Cada ACZ percorre estes estados:
| Situação | Description |
|---|---|
| ATIVO | Operacional. A ACZ sincroniza as mudanças de forma incremental. |
| FALHOU | Um erro interrompeu a configuração ou sincronização. |
| ACCESS_DENIED | A ACZ não consegue aceder à conta de destino do Data Lake Storage Gen2. |
Panorama histórica
Ao criar uma nova instância ACZ, o serviço faz uma captura instantânea do histórico. Este snapshot exporta todos os registos existentes que correspondem aos tipos de entidade configurados (catalogKinds e wellboreDDMSKinds). A captura instantânea passa pelos seguintes estados:
| Situação | Description |
|---|---|
| PROCESSAMENTO | A exportar ativamente dados. |
| CONCLUÍDO | Todos os dados históricos exportados. |
| FALHOU | Ocorreu um erro. |
Após o término do snapshot, o ACZ passa para o modo incremental. Captura registos novos e atualizados quase em tempo real.
Como a ACZ lida com alterações de dados
A ACZ propaga registos criados, atualizados e eliminados do Azure Data Manager for Energy para as tabelas Delta.
- Criações e atualizações: Quando cria um registo ou altera o seu bloco de dados, Azure Gestor de Dados para Energia cria uma nova versão. O ACZ deteta a alteração e escreve uma nova linha na tabela Delta.
-
Atualizações apenas de metadados: Quando uma
PATCHoperação altera a lista de controlo de acesso, o legal ou as etiquetas sem criar uma nova versão, o ACZ deteta esta alteração e executa um upsert de fusão na linha existente. -
Soft deletes: Quando eliminas suavemente um registo no Gestor de Dados Azure Energia, o ACZ define o campo
isActiveparaFalsena linha em vez de o remover. Eliminações suaves preservam o histórico para auditorias e consultas de viagem no tempo. - Purges: Quando purga um registo no Azure Data Manager for Energy, o ACZ remove permanentemente o registo da tabela Delta. A linha é apagada e não pode ser recuperada dos dados ACZ.
Warning
ACZ é uma sincronização unidirecional, só de leitura do Azure Data Manager for Energy para o Data Lake Storage Gen2:
- Os dados fluem apenas de Azure Data Manager for Energy para Data Lake Storage Gen2.
- Não modifique, elimine ou adicione ficheiros diretamente nas pastas ACZ no Data Lake Storage Gen2.
- Alterações manuais aos dados ACZ corrompem a sincronização e causam inconsistências nos dados.
- A ACZ gere todas as operações do Delta Lake (registos de transações, pontos de verificação e compactação).
Para análises e relatórios, trate os dados exportados como apenas de leitura. Todas as modificações de dados devem ocorrer no Azure Data Manager for Energy.
Formato de saída de dados
A ACZ escreve dados no formato Delta Lake com ficheiros codificados em Parquet (DELTA_PARQUET). O Delta Lake suporta transações com atomicidade, consistência, isolamento e durabilidade. Também suporta viagens no tempo e leituras incrementais eficientes.
Estrutura de pastas Data Lake Storage Gen2
A ACZ organiza os dados na sua conta de armazenamento Data Lake Storage Gen2 por pasta. Cada instância ACZ tem a sua própria pasta dentro do contentor ou no caminho base, se tiver especificado um. As partições ACZ catalogam tabelas Delta Lake por tipo. Uma pasta por cada tipo de entidade DDMS e ID de registo.
Disposição das pastas
Detalhes principais
| Elemento | Description |
|---|---|
| Pasta de nível superior | Nomeado <acz-id> por baixo do contentor, ou por baixo <base-path> , se especificado. Uma pasta por instância ACZ. |
osducatalog/ |
Uma tabela Delta para todos os tipos de catálogo. Particionado por tipo (por exemplo, kind=osdu:wks:master-data--Well:1.0.0). |
_delta_log/ |
O registo de transações da Delta Lake. Regista todas as alterações de tabela para transações ACID e viagens no tempo. |
| Pastas de entidades DDMS | Uma pasta por tipo de entidade DDMS (por exemplo, work-product-component--WellLog). Armazena ficheiros Parquet específicos do DDMS por tipo de entidade e ID do registo. |
| Arquivos Parquet | Ficheiros de dados comprimidos com Snappy. As atualizações criam novos ficheiros. O ACZ executa VACUUM e OPTIMIZE para compactar ficheiros pequenos e remover os antigos. |
Esquema de tabela delta
A tabela Delta tem os seguintes campos:
| Campo | Tipo | Description |
|---|---|---|
id |
String | ID de registo OSDU®. |
version |
String | Número da versão. |
kind |
String | Tipo OSDU® totalmente qualificado. |
data |
String | Bloco de dados (JSON). |
meta |
String | Metadados (JSON). |
acl |
String | Lista de controle de acesso. |
legal |
String | Etiquetas legais. |
tags |
String | Etiquetas definidas pelo utilizador. |
createUser |
String | Usuário que criou o registro. |
createTime |
Marca temporal | Quando o disco foi criado. |
ingestTime |
Marca temporal | Quando o ACZ ingeriu o registo. |
isActive |
booleano |
True se ativo.
False se for apagado de forma suave. |
Note
As entidades DDMS Wellbore também têm fileDownloadTime, fileDownloadState, e fileDownloadFolder campos para rastreamento de ficheiros.
Limites e acesso
Limites de pré-visualização
| Restrição | Limite |
|---|---|
| Número máximo de instâncias ACZ por partição de dados | Three |
| Unicidade do nome ACZ | Deve ser único dentro de uma partição de dados |
| Formato alvo | Apenas Delta Parquet |
| Tipo de armazenamento | Apenas Data Lake Storage Gen2 |
| Suporte por níveis de instância | Nível de programador disponível apenas durante a fase de pré-visualização |
Autenticação e autorização
O ACZ exige:
-
Acesso à API: Para invocar as APIs ACZ, deve pertencer aos grupos
users@{data-partition-id}.dataservices.energyeusers.datalake.ops@{data-partition-id}.dataservices.energy. - Acesso ao armazenamento: A identidade gerida necessita do papel Storage Blob Data Contributor (ou equivalente) no contentor Data Lake Storage Gen2. Durante a pré-visualização, partilhe os detalhes de identidade com a Microsoft para adicionar a identidade à lista de autorizações.
- Azure Gestor de Dados para acesso à Energia: A identidade gerida deve ser atribuída ao Gestor de Dados Azure para recursos energéticos.