Canais elásticos no Snowpipe Streaming ganham disponibilidade geral

Os canais elásticos do Snowpipe Streaming fornecem um caminho de ingestão implícito dimensionado pelo servidor por pipe. Produtores concorrentes podem enviar dados diretamente para tabelas do Snowflake e tabelas Iceberg gerenciadas sem gerenciar nomes de canais, ordem ou tokens de deslocamento.

Para que serve

Imagine que você tem aplicações concorrentes enviando eventos em tempo real e não quer gerenciar o ciclo de vida ou o mapeamento de canais de streaming.

• Enviar dados em tempo real diretamente para tabelas do Snowflake e Iceberg.
• Ingestão sem gerenciamento manual de nomes de canais ou tokens de deslocamento.
• Suporte a métodos de inclusão do tipo fire-and-forget e síncronos nos SDKs.

Como usar

Use a versão 1.8.0 ou posterior do SDK do Snowpipe Streaming para aproveitar a API de GA dos canais elásticos em Java, Python ou Node.js.

from snowpipe_streaming import StreamingClient

client = StreamingClient()
client.append_rows(
    table_name="minha_tabela",
    data=[
        {"coluna1": "valor1", "coluna2": 123},
        {"coluna1": "valor2", "coluna2": 456}
    ]
)

O que acontece nesse código:

1. Inicializa o cliente de streaming.
2. Envia um lote de linhas diretamente para a tabela de destino usando o endpoint elástico gerenciado.
3. Recebe confirmações duráveis por append.

Limitações e requisitos

• Disponível em GA.
• Exige a versão 1.8.0 ou posterior do SDK do Snowpipe Streaming.
• Os canais elásticos oferecem entrega at-least-once sem garantia de ordenação; use canais nomeados se precisar de exato-uma entrega ordenada.

Como aplicar num pipeline

Substitui etapas intermediárias de mensageria e arquivos de estágio, permitindo que aplicativos envie linhas diretamente para as tabelas da camada bronze do lakehouse com baixa latência.