Snowflake

​

Aperçu

• Sortant : Envoyez automatiquement les données d’événements de messagerie (push, email, SMS, in-app) de OneSignal vers Snowflake pour l’analyse et les rapports.
• Entrant : Synchronisez les événements utilisateur personnalisés de vos ensembles de données Snowflake vers OneSignal pour déclencher des Journeys automatisés et une messagerie personnalisée.

​

Configuration sortante

• Créer des tableaux de bord et des rapports personnalisés
• Suivre les tendances de livraison et d’engagement entre les canaux
• Combiner les données OneSignal avec d’autres données commerciales pour l’analyse

• Créer des tableaux de bord et des rapports personnalisés
• Suivre les tendances de livraison et d’engagement entre les canaux
• Combiner les données OneSignal avec d’autres données commerciales pour l’analyse

• Plan Professional de OneSignal (non disponible pour les applications gratuites)
• Compte Snowflake
• Rôle SECURITYADMIN ou ACCOUNTADMIN dans Snowflake (pour la configuration)

​

1. Rassemblez les détails de votre compte Snowflake

• Hôte Snowflake : L’URL de votre compte au format <account_identifier>.snowflakecomputing.com
• Nom de la base de données : La base de données où OneSignal écrira les données d’événements
• Nom du schéma : Le schéma dans la base de données pour les tables OneSignal (sera créé automatiquement par OneSignal)
• Nom de l’entrepôt : L’entrepôt à utiliser pour les opérations de chargement de données

​

2. Exécutez le script de configuration dans 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. Générez une paire de clés pour l’authentification

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. Connectez OneSignal

​

5. Afficher les données dans Snowflake

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

​

Événements et propriétés de message

​

Types d’événements de message

​

Schéma des données d’événement

​

Notes

• Les synchronisations après l’enregistrement/l’activation peuvent prendre 15 à 30 minutes supplémentaires pour se terminer.
• La désactivation peut toujours entraîner une dernière synchronisation finale après la désactivation.
• Pour garantir une synchronisation efficace des données, notre système crée et gère automatiquement des ensembles de données intermédiaires. Ces ensembles de données, nommés selon un modèle comme fivetran_{deux mots aléatoires}_staging, stockent temporairement les données pendant le traitement avant qu’elles ne soient intégrées dans votre schéma principal. Ces ensembles de données intermédiaires sont essentiels pour maintenir un flux de travail rationalisé et ne doivent pas être supprimés, car ils seront automatiquement recréés.

​

Migration depuis l’ancienne version

​

Différences clés

​

Changements de schéma

​

Renommage de colonnes

​

Inférence de type

WHERE EXTERNAL_ID = '12345'::VARCHAR

​

Migration des requêtes

1. Mettez à jour les références à la base de données héritée pour pointer vers votre nouvelle base de données Snowflake
2. Tenez compte des renommages de colonnes listés ci-dessus
3. Ajoutez un casting de type explicite si nécessaire

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;

​

Configuration entrante

• Déclencher des Journeys basés sur l’activité des utilisateurs
• Personnaliser la messagerie en fonction des données comportementales

• Accès aux Event Streams pour les événements de message sortants (Les limitations de forfait et les dépassements s’appliquent)
• Accès aux Événements personnalisés pour la synchronisation des événements entrants (Les limitations de forfait et les dépassements s’appliquent)
• Forfait de compte mis à jour (non disponible sur les applications gratuites)

• Compte Snowflake avec accès à l’entrepôt
• Données d’événements stockées dans des tables ou vues Snowflake
• Connectivité réseau de OneSignal vers votre instance Snowflake
• Identifiants utilisateur avec les permissions appropriées

-- 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;

​

Mappage des données d’événement

​

Schéma de table d’événements exemple

-- 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
);

​

Mode requête 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;

​

Configuration avancée

​

Gestion des coûts de l’entrepôt

• Utilisez une taille d’entrepôt X-Small pour l’optimisation des coûts
• Configurez la suspension automatique (60 secondes) et la reprise automatique
• Planifiez les synchronisations pendant les heures creuses
• Envisagez de partager l’entrepôt avec d’autres systèmes de traitement par lots

​

Prise en charge des synchronisations en direct

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

​

Sécurité réseau

​

Limitations

• Les requêtes analytiques complexes peuvent impacter les performances et les coûts de l’entrepôt
• L’authentification Utilisateur/Mot de passe sera obsolète en novembre 2025
• La base de données CENSUS est réservée uniquement aux opérations OneSignal

​

FAQ

​

Quelle méthode d’authentification dois-je utiliser ?

​

Puis-je utiliser un entrepôt existant ?

​

Comment puis-je optimiser les coûts ?

• Utilisez une taille d’entrepôt X-Small
• Configurez une suspension automatique agressive (60 secondes)
• Planifiez les synchronisations pendant les heures creuses
• Utilisez des synchronisations horaires/quotidiennes au lieu d’une synchronisation continue