Este tópico descreve como usar o recurso de inspeção inteligente do Flink.
Visão geral
A inspeção inteligente é um serviço de diagnóstico de integridade de jobs que combina inspeções agendadas e manuais. Ela oferece uma visão panorâmica da integridade, identificação da causa raiz de anomalias e otimização de custo-benefício para detectar proativamente riscos potenciais. Um relatório de inspeção contém uma pontuação de integridade, cartões de risco, análise de causa raiz e sugestões de correção. Acesse o assistente de IA com um clique para obter ajuda na correção.
A inspeção inteligente analisa jobs por meio de IA nas seguintes dimensões:
Integridade do job: se o job apresenta reinícios frequentes, exceções do TaskManager ou outros problemas.
Estabilidade do checkpoint: se a taxa de sucesso e a duração do checkpoint estão dentro dos limiares de integridade.
Backpressure e latência: se os operadores apresentam backpressure e se a latência dos dados excede as expectativas.
Pré-requisitos
Você recebe uma cota única de teste gratuito ao acessar o Flink AI Native Ops. Todos os projetos do workspace atual compartilham essa cota. Quando a cota se esgotar, ative o AI Services na região correspondente para continuar. O uso é cobrado por token. Para mais informações, consulte AI service billing (pay-as-you-go).
Ative o AI Services antes de configurar os canais de notificação push de IM.
Limites
As inspeções abrangem jobs de streaming e jobs em lote com status RUNNING ou FAILED. O sistema não inspeciona jobs interrompidos.
É possível criar apenas um plano de inspeção agendada por workspace.
Acessar a página de inspeção inteligente
Faça logon no console do Realtime Compute for Apache Flink.
Na coluna Actions do workspace de destino, clique em Console.
No painel de navegação à esquerda, clique em Switch to AI Native Ops para acessar a página do Flink AI Native Ops (plataforma inteligente de O&M).
Clique em AI Native Ops para acessar a página do Flink AI Native Ops (plataforma inteligente de O&M).
No painel de navegação à esquerda, clique em Intelligent Inspection.
Ativar ou desativar a inspeção agendada
Para continuar, acesse a página de inspeção inteligente.
Ative a inspeção agendada no cartão de status: clique em Enable no lado direito do cartão. Após a ativação da inspeção agendada, o sistema executa as inspeções automaticamente de acordo com a configuração. Para interromper a inspeção agendada, clique em Disable.
O cartão de status exibe a configuração atual, incluindo o horário da inspeção, o escopo da inspeção e o horário da próxima inspeção.
Configure a inspeção agendada
A inspeção agendada suporta dois métodos de configuração: gerada por IA e baseada em formulário.
Na página Intelligent Inspection, clique em Scheduled Inspection Configuration.
-
Na caixa de diálogo de configuração, use um dos seguintes métodos:
Gerada por IA: Descreva os requisitos de inspeção em linguagem natural, como o horário e o ciclo da inspeção, além do escopo (todos os jobs, jobs específicos ou tags específicas). A IA gera uma configuração de inspeção com base na descrição e a exibe em um cartão de confirmação. Confirme e salve a configuração. Para ajustar a configuração, mude para o modo de formulário e modifique os itens individualmente.
Baseada em formulário: Defina a frequência da inspeção, o escopo da inspeção e os canais de notificação. A frequência da inspeção suporta opções diárias, semanais e Cron personalizado. É possível selecionar até 10 canais de notificação. Se nenhum canal for selecionado, o sistema não envia relatórios de inspeção via push.
Após clicar em Save Configuration, o cartão de status exibirá o horário da próxima inspeção.
Enviar relatórios de inspeção por push para grupos de IM
O sistema envia automaticamente relatórios de inspeção, resultados de ajustes, diagnósticos de alertas e lembretes de cota via push para grupos do DingTalk ou Feishu. A configuração de canais e a entrega de mensagens não consomem cota.
No painel de navegação à esquerda da página do Flink AI Native Ops, clique em IM Channels e, em seguida, clique em Add IM Channel, escolha DingTalk ou Feishu e insira a URL do webhook de um robô de grupo personalizado. Opcionalmente, defina um segredo de assinatura. Após a criação do canal, clique em Test Send e ative a opção Default Channel.
Em Scheduled Inspection Configuration, selecione os canais de destino em Notification Channels.
Após a conclusão de uma inspeção, o sistema envia o relatório via push para os canais selecionados. Após a ativação de um canal padrão, ele também atua como canal de notificação push padrão para planos de inspeção e lembretes de uso.
Ative o AI Services antes de configurar os canais de notificação push de IM.
Inspeção manual
Além das inspeções agendadas, acione manualmente uma inspeção imediata:
Na área de inspeção manual da página de inspeção inteligente, clique em Inspect Now.
Selecione o escopo da inspeção e confirme.
Durante a execução, a página exibe o status de execução e a duração estimada. Após a conclusão da inspeção, visualize o resultado na lista de relatórios de inspeção.
Visualizar relatórios de inspeção
Lista de relatórios
Na área de relatórios de inspeção da página de inspeção inteligente, selecione um intervalo de tempo na lista suspensa no canto superior direito (Last 7 Days, Last 30 Days ou Last 90 Days).
-
A lista de relatórios exibe as seguintes informações:
Coluna
Descrição
Trigger Time
O horário de acionamento da tarefa de inspeção.
Type
Agendada ou manual.
Scope
O escopo da inspeção, por exemplo, All Jobs.
Completion Time
O horário de conclusão da inspeção.
Status
O status de execução da inspeção, por exemplo, Completed.
Risks
O número de riscos por nível de gravidade, divididos em Critical e Warning.
Actions
Clique em View para acessar a página de detalhes do relatório.
Para planos de inspeção com canais de notificação configurados, o sistema também envia os relatórios via push para os grupos de IM correspondentes.
Detalhes do relatório
Clique em View na coluna Actions da lista de relatórios para acessar a página de detalhes do relatório. A página de detalhes do relatório permite a visualização e a exportação, e inclui:
Estatísticas de risco: o número de riscos por nível de gravidade, exibido em três cores.
Gráfico de radar de dimensões: o status de integridade de cada dimensão de inspeção.
Lista de cartões de jobs com risco: jobs com riscos, ordenados por gravidade. Cada cartão exibe o problema de risco, a análise de causa raiz e as sugestões de correção.
Correção com um clique
Em um cartão de job com risco, clique em Handle Now para uma sugestão de correção específica. O sistema redireciona você para a página de conversa do assistente de IA com o contexto preenchido automaticamente (por exemplo, "Diagnose and fix the risk issue of job xxx"). O assistente de IA retorna o resultado do diagnóstico e ajuda na correção.