Snowflake (Legacy)

Aperçu de l'intégration OneSignal Snowflake

​

Aperçu

• Exporter : Envoyez automatiquement les données d’événements de messagerie (push, email, SMS, in-app) depuis OneSignal vers Snowflake pour l’analyse et le reporting.
• Importer : 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.

​

Exporter les événements OneSignal vers Snowflake

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

• Plan Professional OneSignal (non disponible sur les applications gratuites).
• Compte Snowflake
• Assurez-vous que votre compte Snowflake dispose des rôles IMPORT SHARE et CREATE DATABASE.
  • Nous recommandons d’utiliser le rôle ACCOUNTADMIN pour accepter le partage.

​

1. S’inscrire

​

2. Fournir les informations du compte

Copie de l'identifiant du compte Snowflake

• E-mail de OneSignal vous souhaitant la bienvenue dans le programme
• E-mail de Snowflake notifiant que le partage de données est terminé

E-mail de notification de partage de données Snowflake

​

3. Accepter le partage de données dans Snowflake

Interface de partage privé Snowflake

Boîte de dialogue de l'état de réplication des données

Boîte de dialogue de configuration de la base de données

Finalisation de la configuration du partage de données

​

Événements et propriétés

​

Données d’événements de messages

​

Types d’événements de messages

​

Rétention des données

​

Importer des événements depuis Snowflake

• Déclencher des Journeys basés sur l’activité utilisateur
• Personnaliser la messagerie basée sur les 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 depuis OneSignal vers votre instance Snowflake
• Identifiants utilisateur avec les autorisations 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

​

Exemple de schéma de table d’événements

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

​

Support 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 aux opérations OneSignal uniquement

​

Déconnecter le partage de données avec 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