Automatize análises com tarefas do Genie Code em Lakeflow Jobs

As tarefas do Genie Code permitem executar um agente autônomo baseado em linguagem natural como parte de um job no Lakeflow. O agente roda com aprovação automática habilitada, lê dados, chama ferramentas e retorna um link para a conversa gerada.

Para que serve

Imagine que você precisa rodar análises recorrentes e gerar relatórios sem intervenção manual. Com essa tarefa, você pode:

• Resumir resultados de jobs executados durante a noite e enviar por e-mail.
• Analisar dados de entrada para sinalizar anomalias.
• Investigar tickets e propor correções.
• Gerar relatórios de auditoria de conformidade.

Como usar

No painel de Lakeflow Jobs, adicione uma nova tarefa e selecione o tipo Genie Code. No campo de prompt, escreva a instrução em linguagem natural que o agente deve executar.

Check the most recent results in the batch_errors table. If error_count is above 5, create a summary of the errors by type and severity, then post a summary to #data-ops Slack channel.

O que acontece nesse código:

1. O agente lê os resultados recentes da tabela especificada.
2. Ele verifica se a contagem de erros excede o limite definido de cinco.
3. Caso exceda, ele gera um resumo por tipo e severidade.
4. Por fim, ele publica a mensagem no canal do Slack configurado.

Você também pode parametrizar o prompt utilizando variáveis de job:

Summarize yesterday's sales for {{region}} and flag anomalies.

O que acontece nesse código:

1. O Databricks substitui a referência {{region}} pelo valor do parâmetro configurado no job.
2. O agente executa a análise de vendas considerando apenas a região especificada.

Limitações e requisitos

• Recurso geralmente disponível (GA).
• Os workspaces precisam ter acesso às capacidades de agentes do Genie Code.
• O modo de aprovação automática (auto-approve) está sempre ativo em tarefas de job e não pode ser desativado.
• Os prompts devem cumprir as políticas de uso do Genie Code.

Como aplicar num pipeline

Essa tarefa pode ser integrada ao final de um fluxo de engenharia de dados (Bronze → Silver → Gold) para analisar os dados gerados, enviar relatórios automáticos ou acionar alertas condicionais.