Snowflake

​

Genel Bakış

• Çıkış: Analiz ve raporlama için OneSignal’den Snowflake’e mesajlaşma etkinliği verilerini (push, e-posta, SMS, uygulama içi) otomatik olarak gönderin.
• Giriş: Otomatik Journey’leri ve kişiselleştirilmiş mesajlaşmayı tetiklemek için Snowflake veri kümelerinizden OneSignal’e özel kullanıcı etkinliklerini senkronize edin.

​

Çıkış kurulumu

• Özel panolar ve raporlar oluşturma
• Kanallar arasında teslimat ve etkileşim eğilimlerini takip etme
• Analiz için OneSignal verilerini diğer iş verileriyle birleştirme

• OneSignal Professional Planı (ücretsiz uygulamalarda mevcut değildir)
• Snowflake hesabı
• Snowflake’te SECURITYADMIN veya ACCOUNTADMIN rolü (kurulum için)

​

1. Snowflake hesap bilgilerinizi toplayın

• Snowflake Host: <account_identifier>.snowflakecomputing.com formatındaki hesap URL’niz
• Veritabanı adı: OneSignal’in etkinlik verilerini yazacağı veritabanı
• Şema adı: OneSignal tabloları için veritabanı içindeki şema (bu OneSignal tarafından otomatik olarak oluşturulacaktır)
• Warehouse adı: Veri yükleme işlemleri için kullanılacak warehouse

​

2. Snowflake’te kurulum betiğini çalıştırın

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. Kimlik doğrulama için anahtar çifti oluşturun

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. OneSignal’i bağlayın

​

5. Snowflake’te verileri görüntüleyin

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

​

Mesaj etkinlikleri ve özellikleri

​

Mesaj etkinlik türleri

​

Etkinlik veri şeması

​

Notlar

• Kaydetme/etkinleştirme sonrası senkronizasyonlar tamamlanması için ek 15-30 dakika alabilir.
• Devre dışı bırakma, devre dışı bırakıldıktan sonra hala bir son senkronizasyonla sonuçlanabilir.
• Verimli veri senkronizasyonunu sağlamak için sistemimiz otomatik olarak hazırlama veri kümelerini oluşturur ve yönetir. fivetran_{iki rastgele kelime}_staging gibi bir desenle adlandırılan bu veri kümeleri, ana şemanıza entegre edilmeden önce işleme sırasında geçici olarak veri depolar. Bu hazırlama veri kümeleri akıcı bir iş akışını sürdürmek için gereklidir ve otomatik olarak yeniden oluşturulacakları için silinmemelidir.

​

Eski sürümden geçiş

​

Temel farklılıklar

​

Şema değişiklikleri

​

Sütun yeniden adlandırmaları

​

Tip çıkarımı

WHERE EXTERNAL_ID = '12345'::VARCHAR

​

Sorguları geçirme

1. Eski veritabanına yapılan referansları yeni Snowflake veritabanınızı işaret edecek şekilde güncelleyin
2. Yukarıda listelenen sütun yeniden adlandırmalarını hesaba katın
3. Gerektiğinde açık tip dönüştürme ekleyin

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;

​

Giriş kurulumu

• Kullanıcı etkinliğine dayalı Journey’leri tetikleme
• Davranışsal verilere dayalı mesajlaşmayı kişiselleştirme

• Giden mesaj etkinlikleri için Event Streams’e erişim (Plan kısıtlamaları ve aşımlar geçerlidir)
• Gelen etkinlik senkronizasyonu için Custom Events’e erişim (Plan kısıtlamaları ve aşımlar geçerlidir)
• Güncellenmiş Hesap Planı (ücretsiz uygulamalarda mevcut değildir)

• Warehouse erişimi olan Snowflake hesabı
• Snowflake tablolarında veya görünümlerinde depolanan Etkinlik verileri
• OneSignal’den Snowflake örneğinize Ağ bağlantısı
• Uygun izinlere sahip Kullanıcı kimlik bilgileri

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

​

Etkinlik veri eşleştirme

​

Örnek Etkinlik Tablosu Şeması

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

​

SQL Sorgu Modu

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

​

Gelişmiş yapılandırma

​

Warehouse Maliyetlerini Yönetme

• Maliyet optimizasyonu için X-Small warehouse boyutu kullanın
• Otomatik askıya alma (60 saniye) ve otomatik devam ettirmeyi yapılandırın
• Yoğun olmayan saatlerde senkronizasyonları planlayın
• Warehouse’u diğer toplu işleme sistemleriyle paylaşmayı düşünün

​

Canlı Senkronizasyon Desteği

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

​

Ağ Güvenliği

​

Sınırlamalar

• Karmaşık analitik sorgular warehouse performansını ve maliyetlerini etkileyebilir
• Kullanıcı/Parola kimlik doğrulaması Kasım 2025’te kullanımdan kaldırılacak
• CENSUS veritabanı yalnızca OneSignal işlemleri için ayrılmıştır

​

SSS

​

Hangi kimlik doğrulama yöntemini kullanmalıyım?

​

Mevcut bir warehouse kullanabilir miyim?

​

Maliyetleri nasıl optimize edebilirim?

• X-Small warehouse boyutu kullanın
• Agresif otomatik askıya alma (60 saniye) yapılandırın
• Yoğun olmayan saatlerde senkronizasyonları planlayın
• Sürekli senkronizasyon yerine saatlik/günlük senkronizasyonlar kullanın