O nó de monitoramento de qualidade no DataWorks permite configurar regras para monitorar a qualidade dos dados das tabelas em suas fontes de dados e detectar dados incorretos. Também é possível personalizar políticas de agendamento para executar tarefas de validação de dados periodicamente. Este tópico descreve como usar um nó de monitoramento de qualidade para monitorar a qualidade dos dados.
Contexto
O recurso Data Quality no DataWorks ajuda a detectar alterações nos dados de origem e identificar dados incorretos gerados durante o processo ETL (Extração, Transformação e Carga). Ele intercepta automaticamente tarefas problemáticas para evitar que dados incorretos se propaguem para etapas posteriores, impedindo que dados inesperados interrompam operações e afetem decisões de negócios. Além disso, reduz significativamente o tempo de solução de problemas e economiza recursos ao evitar reexecuções de tarefas. Para obter mais informações, consulte Data Quality.
Limitações
Tipos de tabela suportados: MaxCompute, E-MapReduce, Hologres, CDH Hive, AnalyticDB for PostgreSQL, AnalyticDB for MySQL e StarRocks.
-
Escopo das tabelas suportadas:
É possível monitorar apenas tabelas em fontes de dados vinculadas ao workspace onde o nó de monitoramento de qualidade está localizado.
-
Cada nó pode monitorar apenas uma tabela, mas é possível configurar várias regras de monitoramento para ela. O escopo de monitoramento varia conforme o tipo de tabela:
Para tabelas não particionadas, toda a tabela é monitorada por padrão.
Para tabelas particionadas, especifique uma partição para monitorar usando uma expressão de filtro de partição.
NotaPara monitorar várias tabelas, crie múltiplos nós.
-
Limitações operacionais:
As regras de monitoramento de qualidade criadas no Data Studio só podem ser executadas, modificadas e implantadas dentro do próprio Data Studio. Embora essas regras sejam visíveis no módulo Data Quality, não é possível acioná-las por agendamento nem gerenciá-las a partir desse módulo.
Se você modificar as regras de monitoramento em um nó de monitoramento de qualidade e depois implantar o nó, as regras de monitoramento geradas anteriormente serão substituídas.
Pré-requisitos
-
Um mecanismo de computação está vinculado ao seu workspace e a tabela que você deseja monitorar já foi criada nele.
Antes de executar uma tarefa de monitoramento de qualidade de dados, crie a tabela que o nó de monitoramento verificará. Para obter mais informações, consulte Bind a computing engine e Develop a node.
-
Um grupo de recursos foi criado.
Os nós de monitoramento de qualidade só podem ser executados em um grupo de recursos serverless. Para obter mais informações, consulte Manage resource groups.
(Opcional, para usuários RAM) O usuário RAM responsável pelo desenvolvimento da tarefa foi adicionado ao workspace correspondente e recebeu a função Development ou Workspace Administrator. A função Workspace Administrator possui permissões amplas e deve ser concedida com cautela. Para obter mais informações sobre como adicionar e autorizar membros, consulte Add members to a workspace.
Etapa 1: Criar um nó de monitoramento de qualidade
Acesse a página Workspaces no console do DataWorks. Na barra de navegação superior, selecione a região desejada. Localize o workspace desejado e escolha na coluna Actions.
No painel de navegação à esquerda, clique em
para acessar o Desenvolvimento de Dados. Ao lado de Project Directory, clique em
e escolha . Siga as instruções na tela para inserir o caminho e o nome do nó e criá-lo.
Etapa 2: Configurar regras de monitoramento de qualidade
1. Selecionar a tabela a ser monitorada
Na página do editor do nó de monitoramento de qualidade, clique em Add Table. Na caixa de diálogo Add Table, selecione a tabela a ser monitorada. Utilize o filtro More para localizar a tabela mais rapidamente.
Caso sua tabela não apareça na lista, acesse My Data no Data Map.
2. Configurar o escopo de dados de monitoramento
Tabela não particionada: Toda a tabela é monitorada por padrão. Pule esta etapa.
Tabela particionada: Selecione os dados da partição a serem monitorados. É possível utilizar scheduling parameters. Clique em Preview para verificar se a expressão de filtro de partição foi resolvida corretamente.
3. Configurar regras de monitoramento de qualidade de dados
Crie novas regras ou importe regras existentes. As regras configuradas são ativadas por padrão.
Ao criar regras em um nó de monitoramento de qualidade, utilize o recurso DataWorks Copilot rule recommendation para gerar inteligentemente regras de qualidade com base nas informações da sua tabela. Em seguida, aceite ou rejeite as sugestões conforme necessário.
O DataWorks Copilot está em prévia pública em algumas regiões. Se ele não estiver disponível na região onde seu workspace está localizado, crie ou importe regras manualmente conforme descrito neste tópico.
-
Criar uma nova regra
Clique em Create Rule para criar uma regra de monitoramento de qualidade baseada em um modelo ou SQL personalizado. As seções a seguir descrevem esses métodos.
Modelo integrado
Siga estas etapas para criar rapidamente uma regra de monitoramento de qualidade a partir de um modelo de regra.
NotaTambém é possível encontrar o modelo de regra necessário na lista de modelos integrados à esquerda e clicar em + Use para criá-lo.
Clique na aba + Built-in Template Rule no lado direito da caixa de diálogo. No painel Built-in Templates à esquerda, expanda uma categoria de modelo, como Table Row Count, localize o modelo desejado e clique em + Use. No formulário à direita, configure os parâmetros da regra e clique em OK.
Modelo personalizado
Antes de usar este método, crie primeiro um modelo de regra personalizado em . Em seguida, crie regras de monitoramento de qualidade a partir desse modelo. Para obter mais informações, consulte Create and manage custom rule templates.
As etapas a seguir mostram como criar uma regra de qualidade de dados a partir de um modelo personalizado.
NotaTambém é possível encontrar o modelo de regra necessário na lista de modelos personalizados à esquerda e clicar em + Use para criá-lo.
Na caixa de diálogo Create Rule, clique na aba + Custom Template Rule. Configure Rule Name, Rule Template, Quality Dimension, FLAG Parameter, SQL, Comparison Method e Monitoring Threshold (incluindo limiares normal e vermelho) e clique em OK.
SQL personalizado
Este método permite definir uma lógica personalizada de validação de qualidade de dados para uma tabela.
Clique na aba + Custom SQL na parte superior. No formulário à direita, configure Rule Name, Rule Template (selecione Custom SQL), Quality Dimension, FLAG Parameter, SQL, Comparison Method (escolha Manual Settings ou Intelligent Dynamic Threshold) e Monitoring Threshold e clique em OK.
-
Importar regras existentes
Se já existirem regras de monitoramento para a tabela alvo no módulo Data Quality, importe-as para clonar as regras rapidamente. Caso não existam regras, acesse o Data Quality para criá-las primeiro. Para obter mais informações, consulte Configure rules: By table (single table).
NotaEste método suporta a importação em massa de várias regras e permite configurar regras de monitoramento no nível de campo da tabela.
Clique em Import Rule. Pesquise e selecione as regras a serem importadas por ID ou nome da regra, modelo de regra ou escopo associado (tabela inteira ou campos específicos).
Após selecionar as regras, clique em OK para concluir a importação.
Após a implantação de um nó de monitoramento de qualidade, as regras contidas nele podem ser visualizadas no módulo Data Quality, mas operações de gerenciamento, como modificação ou exclusão, não são permitidas nesse local.
4. Configurar recursos de execução
Selecione os recursos de execução para as verificações de regras de qualidade. Essa seleção determina a fonte de dados onde a tarefa de monitoramento de qualidade será executada. Por padrão, trata-se da fonte de dados onde a tabela monitorada está localizada.
Se você selecionar outra fonte de dados, confirme que ela possui permissões de acesso à tabela.
Etapa 3: Configurar políticas de tratamento
Na seção Handling Policy da página do editor de nós, configure políticas de tratamento e assinaturas de notificação para exceções detectadas pelas regras de monitoramento de qualidade.
Categorias de exceção
|
Categoria de exceção |
Descrição |
|
Regra forte: Falha na verificação |
|
|
Regra forte: Exceção crítica |
|
|
Regra forte: Exceção de aviso |
|
|
Regra fraca: Falha na verificação |
|
|
Regra fraca: Exceção crítica |
|
|
Regra fraca: Exceção de aviso |
Políticas de tratamento de exceções
Configure políticas de tratamento para exceções geradas pelas verificações de regras:
-
Não ignorar: Se uma categoria específica de exceção for detectada (por exemplo, uma regra forte acionar uma exceção crítica), configure o sistema para parar o nó atual e definir seu status como Falha.
NotaApós a falha do nó atual, os nós subsequentes não serão executados. Isso bloqueia o pipeline de produção e evita a propagação de dados problemáticos.
Adicione várias categorias de exceção para verificação.
Essa política é normalmente usada quando uma exceção tem grande impacto e precisa bloquear tarefas subsequentes.
Ignorar: Ignore a exceção e continue a executar os nós subsequentes.
Métodos de notificação de exceções
Configure como receber notificações sobre exceções (por exemplo, por e-mail). Quando ocorre uma exceção, a plataforma envia uma notificação pelo método especificado para que você possa tratar a exceção prontamente.
A plataforma suporta vários métodos de notificação, que podem variar na interface. Observe o seguinte:
Notificações por E-mail, E-mail e SMS e Telefone só podem ser enviadas para usuários da conta atual. Certifique-se de que os endereços de e-mail e números de telefone dos destinatários estejam configurados corretamente. Para obter mais informações, consulte View and set alert contacts.
Para outros métodos, insira a URL do webhook para receber notificações. Para obter instruções sobre como obter essa URL, consulte Obtain a webhook URL.
Etapa 4: Configurar agendamento
Para executar a tarefa do nó periodicamente, clique em Scheduling Settings no lado direito da página do editor de nós e configure as propriedades de agendamento de acordo com seus requisitos de negócios. Para obter mais informações, consulte Configure scheduling for a node.
Etapa 5: Depurar a tarefa
Realize as seguintes operações de depuração conforme necessário para verificar se a tarefa é executada conforme o esperado.
-
(Opcional) Selecione o grupo de recursos de execução e atribua valores aos parâmetros personalizados.
No lado direito do nó de monitoramento de qualidade, clique em Run Configuration e configure o Resource Group for Scheduling a ser usado na execução de depuração.
Se sua tarefa usar parâmetros de agendamento, atribua valores às variáveis na seção Script Parameters para depuração. Para obter mais informações sobre a lógica de atribuição de parâmetros, consulte Debug a task.
-
Salve e execute a tarefa.
Clique no ícone
na barra de ferramentas superior para salvar a tarefa. Clique no ícone
para executar a tarefa.Após a conclusão da tarefa, visualize os resultados da execução na parte inferior da página do editor de nós. Se a execução falhar, solucione o problema com base na mensagem de erro.
Etapa 6: Implantar a tarefa
Após configurar a tarefa do nó, implante-a. Após a implantação, o nó é executado periodicamente de acordo com sua configuração de agendamento.
Ao implantar um nó de monitoramento de qualidade, as regras de qualidade configuradas nele também são implantadas.
Na barra de ferramentas superior, clique no ícone
para salvar o nó.Na barra de ferramentas superior, clique no ícone
para implantar o nó.
Para obter mais informações sobre como implantar nós, consulte Deploy nodes and workflows.
Próximas etapas
Operação e manutenção de tarefas: Após a implantação, a tarefa é executada periodicamente com base em sua configuração de agendamento. Clique em O&M no canto superior direito da página do editor de nós para acessar o Operation Center e visualizar detalhes de agendamento e execução da tarefa, como o status de execução do nó e detalhes das regras acionadas. Para obter mais informações, consulte Manage scheduled tasks.
Data Quality: Após a implantação de uma regra de monitoramento de qualidade, acesse o módulo Data Quality para visualizar os detalhes da regra. No entanto, não é possível realizar operações de gerenciamento, como modificar ou excluir a regra, nesse local. Para obter mais informações, consulte Data Quality.