Realtime Compute for Apache Flink:Configurar regras de alerta

Alertas de eventos de sistema

Inscreva-se em eventos de sistema para jobs individuais ou múltiplos.

1. Faça login no console do Cloud Monitor.

2. No painel de navegação à esquerda, escolha Event Center > Event Subscription.

3. Na aba Subscription Policy, clique em Create Subscription Policy.

4. Na página Create Subscription Policy, configure os parâmetros a seguir. Para outros parâmetros, consulte Gerencie inscrições de eventos (Recomendado).

   Deixar Application group , Event Content ou Event Resources em branco aplica a inscrição a todos os workspaces da sua conta.

   Parâmetro	Descrição
   Subscription Type	Selecione System Events.
   Products	Selecione Flink.
   Event name	Eventos suportados: JOB_FAILED, ECS.SystemFailure e ECS.SystemMaintenance.
   Event Content	Opcionalmente, restrinja o alerta a recursos específicos: <br>- Workspace ID: aplica a regra a todos os jobs nesse workspace. Para obter o ID do seu workspace, consulte Visualize informações do workspace <br>- Namespace name: aplica a regra a todos os jobs nesse namespace. <br>- Deployment name: aplica a regra a implantações de jobs específicas. Separe vários nomes por vírgulas (,). Use o ID da implantação quando existirem nomes duplicados. <br>- Deployment ID: aplica a regra a implantações de jobs específicas. Separe vários IDs por vírgulas (,). Obtenha o ID da implantação na página de detalhes da implantação.

   

Alertas de eventos de workflow

Inscreva-se em eventos de mudança de estado de workflow. Para detalhes sobre workflows, consulte Gerencie workflows.

Etapa 1: Obter o ID do recurso da tarefa de workflow

1. Faça login no console do Cloud Monitor.

2. No painel de navegação à esquerda, escolha Event Center > System Event.

3. Na aba Event Monitoring, defina SelectProduct como Flink, defina SelectEvent Name como flink:Workflow:TaskStateChange e clique em Search.

4. Nos resultados, localize o ID do recurso da sua tarefa de workflow. O ID do recurso segue este formato:

   As mudanças de estado de tarefas de workflow geralmente aparecem no Cloud Monitor com alguns minutos de atraso.

   Espaço reservado	Descrição
   <AlibabaCloudAccountID>	O ID da conta Alibaba Cloud proprietária do workspace do Flink.
   <workspaceId-namespaceId>	O ID do workspace e o nome do namespace unidos por um hífen (-). Para o ID do workspace, consulte Visualize informações do workspace.
   <workflowDefinitionName>	O nome do workflow.
   <taskDefinitionName>	O nome da tarefa do workflow.

   acs:flink:cn-hangzhou:<AlibabaCloudAccountID>:resourceId/workspaceId/<workspaceId-namespaceId>#workflowDefinitionName/<workflowDefinitionName>#taskDefinitionName/<taskDefinitionName>

   Você também pode construir o ID do recurso diretamente usando este formato, em vez de pesquisá-lo.

   

Etapa 2: Crie uma inscrição de evento

1. No painel de navegação à esquerda, escolha Event Center > Event Subscription.

2. Na aba Subscription Policy, clique em Create Subscription Policy.

3. Configure os parâmetros a seguir. Para outros parâmetros, consulte Gerencie inscrições de eventos (Recomendado).

   Parâmetro	Valor
   Subscription Type	System Events
   Products	Flink
   Event name	flink:Workflow:TaskStateChange
   Event Content	Filtre pelo estado de transição alvo. Exemplos: toState: FAILED, toState: SUCCESS, fromState: SCHEDULED, toState: RUNNING.
   Event Resources	Insira o ID do recurso da Etapa 1. Separe vários IDs por vírgulas (,).
   Event Type, Event Level, Application group	Deixe em branco.

Configuração de job único (Development Console)

Configure regras de alerta para um job específico no Development Console, seja do zero ou a partir de um modelo.

1. Faça login no Management Console do Realtime Compute for Apache Flink e clique em Console na coluna Actions do seu workspace.

2. No painel de navegação à esquerda, escolha O&M > Deployments e clique na sua implantação de job.

3. Selecione a aba Alarm e, em seguida, a subaba Alarm Rules.

4. Clique em Add Rule > Custom Rule (ou Create Rule by Template).

5. Insira as informações da regra de alerta. Seção Content Configure as condições que disparam o alerta. O Flink compara periodicamente os valores reais das métricas com o limiar e dispara um alerta quando uma condição é atendida. Exemplo: Monitorar Checkpoint Count in 5 Minutes com intervalo de tempo de 10 minutos, limiar de 2 e comparador <= — o Flink verifica a cada minuto durante uma janela de 10 minutos e dispara um alerta se a contagem mínima de checkpoints bem-sucedidos em qualquer período de 5 minutos cair para 2 ou menos. Effective Time A janela de tempo em que a regra de alerta está ativa. O padrão é o dia todo. Restrinja a horários específicos, se necessário, como horário comercial (9h–18h). Alarm Rate O intervalo entre notificações de alerta repetidas, em minutos. Intervalo: 1–1440 minutos (24 horas).

   Seção Rule

   Parâmetro	Descrição
   Name	O nome da regra de alerta. Deve começar com uma letra e pode conter letras minúsculas, dígitos e sublinhados (_). Comprimento: 3–64 caracteres.
   Description	Notas opcionais sobre a regra.

   Parâmetro	Descrição
   Metric	A métrica a ser monitorada. Consulte Referência de métricas para opções disponíveis e suas lógicas de alerta.
   Time Interval	A duração da janela de dados históricos consultada em cada verificação, em minutos.
   Comparator	>= compara o valor máximo da métrica com o limiar; alerta quando max_value >= threshold. <= compara o valor mínimo da métrica; alerta quando min_value <= threshold.
   Thresholds	O valor a ser comparado com a métrica. Monitore sua aplicação em condições normais para determinar uma linha de base apropriada antes de definir este valor.

   Notification section

   Parâmetro	Descrição
   Notification	Selecione um ou mais métodos de notificação: DingTalk, Email, SMS, Webhook ou Phone. Cada método selecionado deve ter um objeto de notificação correspondente configurado. Para notificações por Phone, certifique-se de que o número do destinatário esteja verificado — se a tag Unverified aparecer na aba Contacts, clique nela para concluir a verificação. Importante Garanta que o método de notificação escolhido tenha um objeto de notificação correspondente configurado. Para DingTalk, isso significa adicionar um objeto de notificação de robô DingTalk após selecione DingTalk como método.
   Notification object	Selecione um ou mais objetos de notificação. Clique em Notification object management para crie objetos. Para detalhes, consulte Perguntas frequentes sobre workspace e namespace.

   Advanced Settings

   Opção	Descrição
   Alarm Noise Reduction	Quando ativado, os alertas disparam apenas quando o limiar é atingido continuamente. Isso evita ruídos causados por problemas temporários, como failovers breves durante o agendamento de cluster ou ajuste automático.
   No Data Alarms	Dispara um alerta se nenhum dado de monitoramento for relatado dentro da duração especificada. Causas comuns: exceções no JobManager, paradas de job ou falhas no pipeline de relatórios.

6. Clique em OK. A regra de alerta é ativada automaticamente e aparece na lista de regras de alerta. Você pode parar, edite ou exclua regras na lista.

Configuração de job único/múltiplos jobs (consoles Prometheus)

1. Faça login no Management Portal do Realtime Compute for Apache Flink.

2. Na coluna Actions do seu workspace, escolha More > Monitoring Indicator Configuration para acesse o console do ARMS.

   O nome do workspace, o ID do workspace e o nome da instância Prometheus correspondente são exibidos na parte superior.

   

3. No painel de navegação à esquerda, clique em Alert rules e clique em Create Prometheus Alert Rule.

   

   • Check Type: Suporta alertas baseados em limiares estáticos e PromQL personalizado (excluindo métricas integradas do Flink).

   • Filter Conditions: Suporta a configuração de alertas para múltiplos jobs. Para Namespace, insira o nome do namespace. Se você selecione All, a regra se aplica a todos os namespaces no workspace. Para Deployment, insira o Deployment Job ID do job desejado no namespace. Você pode encontrar esse ID na aba Deployment Details do job Flink. Se você selecione All, a regra se aplica a todos os jobs no namespace.

   Para mais informações sobre outros parâmetros de configuração, consulte Crie uma regra de alerta Prometheus. Você também pode crie um modelo de regra de alerta Prometheus. Para mais informações, consulte Crie um modelo de regra de alerta Prometheus.