Snowflake

Aperçu de l'intégration OneSignal Snowflake

​

Aperçu

• Export : Envoyez automatiquement les données d’événements de messagerie (push, e-mail, SMS, in-app) de OneSignal vers Snowflake pour l’analyse et les rapports.
• Import : Synchronisez les événements utilisateur personnalisés depuis 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 commerciales pour l’analyse

• OneSignal Forfait professionnel (non disponible sur les applications gratuites).
• Compte Snowflake
• Assurez-vous que votre compte Snowflake possède les 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 de compte

Copie de l'identifiant de 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 statut de réplication des données

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

Achèvement de la configuration du partage de données

​

Événements et propriétés

​

Données d’événements de message

​

Types d’événements de message

​

Rétention des données

​

Importer des événements depuis Snowflake

• 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 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 d’entrepôt

• Utilisez la 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 de l’entrepôt et les coûts
• L’authentification utilisateur/mot de passe sera dépréciée 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 la 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