O Flink AI Native Ops é a plataforma de operações de IA de nova geração do Realtime Compute for Apache Flink. Desenvolvido com base em famílias de grandes modelos, como Qwen, DeepSeek e GLM, ele oferece um ponto de entrada dedicado em página inteira, converte o conhecimento em O&M em habilidades integradas e abrange o desenvolvimento de jobs, a inspeção em tempo de execução, o diagnóstico de exceções e sugestões de otimização.
Capacidades principais
|
Capacidade |
Descrição |
|
Conduz o desenvolvimento de jobs, a solução de problemas e o O&M diário em linguagem natural. Suporta referências @ para cinco tipos de entidades: metadados, rascunhos de jobs, rascunhos de ingestão de dados, implantações e clusters de sessão. Permite o uso de comandos / para invocar habilidades integradas. Operações de alteração exibem um plano de execução e só são executadas após a sua confirmação. |
|
|
Gera um plano de inspeção agendada a partir de uma única frase. Suporta ciclos diários, semanais e Cron personalizados. Os escopos de inspeção cobrem todos os jobs, jobs por tag ou jobs específicos. Envia relatórios de inspeção para grupos do DingTalk ou Feishu. |
|
|
As habilidades integradas funcionam sem configuração adicional e cobrem o desenvolvimento de rascunhos, o gerenciamento de implantações, o início e a parada de jobs, além do diagnóstico de jobs. O marketplace de habilidades oferece mais de 20 habilidades; crie habilidades personalizadas para incorporar o conhecimento em O&M da sua equipe. |
|
|
gerencie os canais de mensagens do DingTalk e do Feishu em um único local. Envia automaticamente relatórios de inspeção, resultados de ajuste, diagnósticos de alertas e lembretes de cota para chats em grupo. O openapi está disponível e permite a integração dos resultados às suas próprias plataformas. |
Cenários típicos
|
Função |
Uso típico |
|
Desenvolvedor de dados |
Ajuda a gerar rascunhos de jobs SQL e de ingestão de dados em YAML, validar a sintaxe e implantar jobs. Também explica erros de sintaxe durante o desenvolvimento e fornece sugestões de otimização. |
|
Engenheiro de O&M de jobs ou SRE |
Inspeciona todos os jobs diariamente e recebe relatórios de inspeção. Diagnostica problemas como tempos limite de checkpoint e reinícios repetidos de jobs, e obtém sugestões de correção. Inicia ou interrompe jobs com falha com um único clique. |
|
Líder de equipe ou administrador de plataforma |
Acompanha a saúde geral do workspace por meio de relatórios de inspeção, converte o conhecimento em O&M da equipe em habilidades personalizadas e recebe os resultados de inspeção em grupos do DingTalk ou Feishu. |
Primeiros passos
Faça logon no console do Realtime Compute for Apache Flink e acesse o workspace de destino.
No painel de navegação à esquerda, clique em Switch to AI Native Ops para acessar a página do Flink AI Native Ops.
Não é necessária nenhuma ativação. O sistema concede uma cota única de avaliação gratuita: 30 execuções do Intelligent Assistant e 5 execuções do Intelligent Inspection. Todos os namespaces no workspace atual compartilham essa cota gratuita.
Após o esgotamento da cota gratuita, ative o AI Services para continuar: o sistema concede 100.000 tokens gratuitos por mês, renovados mensalmente, e o uso excedente é cobrado no modelo de pagamento conforme o uso. Para mais informações, consulte AI service billing (pay-as-you-go).
Exemplos de prompts:
Sync the data of the dwd_orders table from Kafka to Hologres and generate a job draft.@Deployment xxx Investigate why the job restarts repeatedly and provide remediation suggestions.Create an inspection plan that inspects all production jobs at 03:00 every day and pushes the results to a DingTalk group.Show the job health of the current workspace.
Segurança e limites de permissão
|
Item |
Descrição |
|
Limite de permissão |
O agente execute operações como o usuário conectado no momento e nunca excede as permissões atuais da conta. |
|
Confirmação antes de alterações |
Operações de alteração, como implantação e início/parada, exigem confirmação antes da execução. |
|
Conteúdo gerado por IA é apenas para referência |
O conteúdo gerado por IA não representa a posição da Alibaba Cloud. Para alterações de configuração e operações de alto risco, avalie cuidadosamente com base no seu contexto real. |
Faturamento
|
Item de faturamento |
Descrição |
|
Avaliação gratuita |
Compartilhada entre todos os namespaces em um único workspace: uma cota única de avaliação gratuita de 30 execuções do Intelligent Assistant e 5 execuções do Intelligent Inspection. |
|
AI Services (pagamento conforme o uso) |
Cada conta da Alibaba Cloud recebe uma cota gratuita de 100.000 tokens por mês em cada região, renovada mensalmente. O uso excedente é cobrado no modelo de pagamento conforme o uso. Essa cota é independente da cota gratuita de 1.000.000 de tokens para AI Function e AI Agents, e uma não consome a cota da outra. |
|
Medição transparente |
Cada execução do Intelligent Assistant e de um plano de inspeção inteligente é cobrada por token. A criação e a configuração de habilidades personalizadas não são contabilizadas. Todos os detalhes de consumo estão disponíveis por capacidade no centro de uso. |
Durante a avaliação gratuita, o sistema usa o modelo com melhor desempenho por padrão. Após ativar o AI Services, selecione um modelo por cenário na caixa de chat. A cobrança será feita pelo preço unitário de cada modelo.
Modelos suportados
A caixa de chat permite selecionar um modelo. Atualmente, há suporte para os seguintes modelos:
|
Série |
Modelo |
|
Qwen |
qwen3,8-max, qwen3,7-max, qwen3,7-plus, qwen3,7-flash |
|
DeepSeek |
deepseek-v4-pro, deepseek-v4-flash-0731 |
|
GLM |
glm-5,2 |
Os modelos são cobrados por token. Para mais informações, consulte AI service billing (pay-as-you-go).
Após o esgotamento da cota de avaliação gratuita, o sistema pausa os planos de inspeção agendada e mantém suas configurações. Os planos são retomados automaticamente após a ativação do AI Services. O sistema não deduz nenhuma cota sem a sua confirmação.
Perguntas frequentes
P: O AI Native Ops acessa dados comerciais?
As capacidades de diagnóstico e inspeção leem apenas métricas de monitoramento, logs e metadados de jobs. As capacidades de desenvolvimento de jobs executam operações SQL e YAML dentro do escopo autorizado e nunca excedem as permissões da conta.
P: O AI Native Ops afeta jobs em execução?
A inspeção e o diagnóstico inteligentes são somente leitura e não afetam os jobs em execução. Operações de alteração, como implantação e início/parada, só têm efeito nos jobs após a confirmação.
P: O que faço após as execuções gratuitas acabarem?
Ative o AI Services para continuar. O sistema concede uma cota gratuita de 100.000 tokens por mês, o uso excedente é cobrado no modelo de pagamento conforme o uso e o service não é interrompido.
P: Como os planos de inspeção agendada existentes são migrados?
O sistema mantém todas as configurações de inspeção após a comercialização. O sistema primeiro desativa as inspeções habilitadas existentes e solicita confirmação em uma caixa de diálogo. Ao habilitá-las novamente, as execuções de avaliação gratuita são consumidas primeiro. Quando as execuções se esgotarem, ative o AI Services para continuar com base no uso por token.
P: O AI Native Ops pode ser usado fora do console?
Sim. É possível enviar relatórios de inspeção por mensagens do DingTalk ou Feishu e integrar as capacidades da plataforma aos seus próprios sistemas por meio do openapi.