Snowflake

Visão geral da integração OneSignal Snowflake

​

Visão geral

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

​

Exportar eventos do OneSignal para o Snowflake

• 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

Localização do identificador da conta Snowflake

​

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.

​

Importar eventos do Snowflake

• 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