Gerencie a Snowflake Feature Store como código com o CLI snow feature

O workflow declarativo da Snowflake Feature Store está em disponibilidade geral (GA). A novidade permite definir recursos de Feature Store como arquivos locais em YAML ou Python e gerenciá-los usando um modelo de Infraestrutura como Código (IaC) com o comando snow feature do Snowflake CLI.

Para que serve

Imagine que você precisa manter dezenas de features de machine learning sincronizadas entre ambientes de desenvolvimento, homologação e produção sem rodar scripts Python imperativos de forma manual. Com a abordagem declarativa, você pode armazenar a definição da sua Feature Store em repositórios Git, fazer revisões de código (PRs) e automatizar as implantações via CI/CD.

Você pode:

• Versionar entidades, fontes de dados, feature views e feature groups em arquivos YAML ou Python.
• Visualizar um plano de execução (diff) antes de aplicar mudanças no Snowflake.
• Promover alterações entre ambientes de forma consistente e segura.

Como usar

Instale a biblioteca necessária no seu ambiente e inicialize o projeto:

# Instalar o pacote necessário
pip install -U "snowflake-ml-python[feature_store]"

# Criar e inicializar o projeto local
mkdir meu_feature_store
cd meu_feature_store
snow feature init

# Planejar e aplicar as alterações
snow feature plan
snow feature apply

O que acontece nesse código:

1. Instala a biblioteca snowflake-ml-python com suporte a Feature Store.
2. Inicializa a estrutura de diretórios (sources/) e o arquivo manifest.yml baseados na conexão ativa do Snowflake.
3. O comando snow feature plan compara o estado local com o ambiente remoto no Snowflake e gera um arquivo de plano com a diferença das alterações.
4. O comando snow feature apply executa as alterações planejadas no Snowflake.

Para interagir com o serviço online de streaming e consultas pontuais:

# Criar serviço online
snow feature online-service create --producer-role MEU_PRODUTOR --consumer-role MEU_CONSUMIDOR

# Ingerir eventos e consultar features
snow feature ingest CLICKSTREAM_EVENTS --data eventos.json
snow feature query USER_CLICK_STATS_DECL --version V1 --keys '[{"USER_ID":"u1"}]'

O que acontece nesse código:

1. Cria a infraestrutura para servir features de baixa latência em um schema específico.
2. Envia eventos em formato JSON para a fonte de streaming especificada.
3. Consulta os valores calculados de features para as chaves informadas.

Limitações e requisitos

• Requer a biblioteca snowflake-ml-python[feature_store] no mesmo interpretador do Snowflake CLI.
• Operações destrutivas (como recriar ou deletar feature views) são bloqueadas por padrão no comando apply. É preciso passar a flag --destructive para autorizá-las.
• A detecção de exclusão de objetos ausentes nos arquivos locais fica desativada por padrão no comando plan. Use a flag --delete para identificar objetos excluídos.

Como aplicar num pipeline

Integre o comando snow feature plan nas verificações de Pull Request da sua esteira de CI/CD para validar as alterações antes da fusão do código. Ao aprovar e fundir na branch principal, execute snow feature apply no pipeline de implantação para atualizar o ambiente de produção automaticamente.