Snowflake

​

Visão geral

• Saída: Envie automaticamente dados de eventos de mensagens (push, e-mail, SMS, in-app) do OneSignal para o Snowflake para análise e relatórios.
• Entrada: Sincronize eventos personalizados de usuários dos seus conjuntos de dados do Snowflake para o OneSignal para acionar Jornadas automatizadas e mensagens personalizadas.

​

Configuração de saída

• Criar dashboards e relatórios personalizados
• Rastrear tendências de entrega e engajamento em todos os canais
• Combinar dados do OneSignal com outros dados de negócios para análise

• OneSignal Plano Professional (não disponível em aplicativos gratuitos)
• Conta Snowflake
• Função SECURITYADMIN ou ACCOUNTADMIN no Snowflake (para configuração)

​

1. Reúna os detalhes da sua conta Snowflake

• Snowflake Host: A URL da sua conta no formato <account_identifier>.snowflakecomputing.com
• Nome do banco de dados: O banco de dados onde o OneSignal gravará os dados de eventos
• Nome do schema: O schema dentro do banco de dados para as tabelas do OneSignal (será criado automaticamente pelo OneSignal)
• Nome do warehouse: O warehouse a ser usado para operações de carregamento de dados

​

2. Execute o script de configuração no Snowflake

begin;

   -- create variables for user / role / warehouse / database (needs to be uppercase for objects)
   set role_name = 'ONESIGNAL_ROLE';
   set user_name = 'ONESIGNAL_USER';
   set warehouse_name = 'ONESIGNAL_WAREHOUSE';
   set database_name = 'ONESIGNAL';

   -- change role to securityadmin for user / role steps
   use role securityadmin;

   -- create role for onesignal
   create role if not exists identifier($role_name);
   grant role identifier($role_name) to role SYSADMIN;

   -- create a user for onesignal
   create user if not exists identifier($user_name)
   default_role = $role_name
   default_warehouse = $warehouse_name;

   grant role identifier($role_name) to user identifier($user_name);

   -- set binary_input_format to BASE64
   ALTER USER identifier($user_name) SET BINARY_INPUT_FORMAT = 'BASE64';

   -- set timestamp_input_format to AUTO for the user
   ALTER USER identifier($user_name) SET TIMESTAMP_INPUT_FORMAT = 'AUTO';

   -- change role to sysadmin for warehouse / database steps
   use role sysadmin;

   -- create a warehouse for onesignal
   create warehouse if not exists identifier($warehouse_name)
   warehouse_size = xsmall
   warehouse_type = standard
   auto_suspend = 60
   auto_resume = true
   initially_suspended = true;

   -- create database for onesignal
   create database if not exists identifier($database_name);

   -- grant onesignal role access to warehouse
   grant USAGE
   on warehouse identifier($warehouse_name)
   to role identifier($role_name);

   -- grant onesignal access to database
   grant CREATE SCHEMA, MONITOR, USAGE
   on database identifier($database_name)
   to role identifier($role_name);

 commit;

​

3. Gere o par de chaves para autenticação

openssl genrsa 2048 | openssl pkcs8 -topk8 -inform PEM -out rsa_key.p8 -nocrypt

openssl genrsa 2048 | openssl pkcs8 -topk8 -v2 aes256 -inform PEM -out rsa_key.p8

openssl rsa -in rsa_key.p8 -pubout -out rsa_key.pub

ALTER USER ONESIGNAL_USER SET RSA_PUBLIC_KEY='<YOUR_PUBLIC_KEY_CONTENT>';

​

4. Conecte o OneSignal

​

5. Visualize dados no Snowflake

-- View recent message events
SELECT *
FROM <your-database>.<your-schema>.message_events
ORDER BY _CREATED DESC
LIMIT 100;

​

Eventos e propriedades de mensagem

​

Tipos de evento de mensagem

​

Schema de dados de evento

​

Notas

• Sincronizações após salvar/ativar podem levar 15-30 minutos adicionais para completar.
• Desativar ainda pode resultar em uma sincronização final após desativação.
• Para garantir sincronização eficiente de dados, nosso sistema cria e gerencia automaticamente datasets de staging. Estes datasets, nomeados com um padrão como fivetran_{duas palavras aleatórias}_staging, armazenam temporariamente dados durante o processamento antes de serem integrados ao seu schema principal. Estes datasets de staging são essenciais para manter um fluxo de trabalho otimizado e não devem ser deletados, pois serão automaticamente recriados.

​

Migração do legado

​

Principais diferenças

​

Alterações no schema

​

Renomeações de colunas

​

Inferência de tipos

WHERE EXTERNAL_ID = '12345'::VARCHAR

​

Migração de consultas

1. Atualize referências ao banco de dados legado para apontar para seu novo banco de dados Snowflake
2. Considere as renomeações de colunas listadas acima
3. Adicione conversão explícita de tipos onde necessário

CREATE VIEW your_schema.message_events_compat AS
SELECT
  *,
  EVENT_TIMESTAMP AS EVENT_IMPRESSION_TIMESTAMP,
  LANGUAGE AS SUBSCRIPTION_LANGUAGE,
  MESSAGE_CONTENTS AS MESSAGE_BODY
FROM ONESIGNAL_DB.ONESIGNAL_EVENTS_XXXXX.MESSAGE_EVENTS;

​

Configuração de entrada

• Acionar Jornadas com base na atividade do usuário
• Personalizar mensagens com base em dados comportamentais

• Acesso a Event Streams para eventos de mensagem de saída (Limitações de plano e excedentes se aplicam)
• Acesso a Custom Events para sincronização de eventos de entrada (Limitações de plano e excedentes se aplicam)
• Plano de Conta Atualizado (não disponível em apps gratuitos)

• Conta Snowflake com acesso ao warehouse
• Dados de eventos armazenados em tabelas ou visualizações do Snowflake
• Conectividade de rede do OneSignal para sua instância Snowflake
• Credenciais de usuário com permissões apropriadas

-- Create a role for the census user
CREATE ROLE CENSUS_ROLE;

-- Ensure the sysadmin role inherits any privileges the census role is granted
GRANT ROLE CENSUS_ROLE TO ROLE SYSADMIN;

-- Create a warehouse for the census role, optimizing for cost over performance
CREATE WAREHOUSE CENSUS_WAREHOUSE WITH
    WAREHOUSE_SIZE = XSMALL
    AUTO_SUSPEND = 60
    AUTO_RESUME = TRUE
    INITIALLY_SUSPENDED = FALSE;

GRANT USAGE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT OPERATE ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;
GRANT MONITOR ON WAREHOUSE CENSUS_WAREHOUSE TO ROLE CENSUS_ROLE;

-- Create the census user
CREATE USER CENSUS WITH
    DEFAULT_ROLE = CENSUS_ROLE
    DEFAULT_WAREHOUSE = CENSUS_WAREHOUSE
    PASSWORD = '<strong-unique-password>';

GRANT ROLE CENSUS_ROLE TO USER CENSUS;

-- Grant access to your event data (replace with your actual database/schema)
GRANT USAGE ON DATABASE "<your-database>" TO ROLE CENSUS_ROLE;
GRANT USAGE ON SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE TABLES IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON ALL VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;
GRANT SELECT ON FUTURE VIEWS IN SCHEMA "<your-database>"."<your-schema>" TO ROLE CENSUS_ROLE;

-- Create a private bookkeeping database
CREATE DATABASE "CENSUS";
GRANT ALL PRIVILEGES ON DATABASE "CENSUS" TO ROLE CENSUS_ROLE;

CREATE SCHEMA "CENSUS"."CENSUS";
GRANT ALL PRIVILEGES ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;
GRANT CREATE STAGE ON SCHEMA "CENSUS"."CENSUS" TO ROLE CENSUS_ROLE;

​

Mapeamento de dados de evento

​

Esquema de tabela de eventos de exemplo

-- Example Snowflake event table
CREATE TABLE analytics.user_events (
    event_id STRING,
    event_name STRING NOT NULL,
    user_id STRING NOT NULL,
    event_timestamp TIMESTAMP_TZ DEFAULT CURRENT_TIMESTAMP(),
    event_properties VARIANT,
    session_id STRING,
    device_type STRING
);

​

Modo de consulta SQL

-- Example: Recent high-value events
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_properties
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, CURRENT_TIMESTAMP())
    AND event_properties:value::NUMBER > 100
ORDER BY event_timestamp DESC;

​

Configuração avançada

​

Gerenciamento de custos do warehouse

• Use o tamanho de warehouse X-Small para otimização de custos
• Configure auto-suspend (60 segundos) e auto-resume
• Agende sincronizações durante horários de baixo uso
• Considere compartilhar o warehouse com outros sistemas de processamento em lote

​

Suporte a sincronizações ao vivo

ALTER TABLE "analytics"."user_events" SET CHANGE_TRACKING = TRUE;

​

Segurança de rede

​

Limitações

• Consultas analíticas complexas podem impactar o desempenho e os custos do warehouse
• A autenticação por usuário/senha será descontinuada em novembro de 2025
• O banco de dados CENSUS é reservado apenas para operações do OneSignal

​

FAQ

​

Qual método de autenticação devo usar?

​

Posso usar um warehouse existente?

​

Como posso otimizar custos?

• Use o tamanho de warehouse X-Small
• Configure auto-suspend agressivo (60 segundos)
• Agende sincronizações durante horários de baixo uso
• Use sincronizações horárias/diárias em vez de sincronização contínua