Amazon Redshift

​

Genel Bakış

​

Gereksinimler

• Access to Event Streams for outbound message events (Plan limitations and overages apply)
• Access to Custom Events for inbound event syncing (Plan limitations and overages apply)
• Updated Account Plan (not available on free apps)

​

Amazon Redshift

• Ağ erişimi olan Redshift kümesi
• Uygun izinlere sahip veritabanı kullanıcısı
• Yapılandırılmış davranışsal veriler içeren etkinlik tabloları
• OneSignal’den Redshift kümenize ağ bağlantısı

​

Kurulum

-- Create OneSignal user with strong password
CREATE USER CENSUS WITH PASSWORD '<strong-unique-password>';

-- Create private bookkeeping schema for sync state (skip if read-only mode)
CREATE SCHEMA CENSUS;

-- Grant full access to bookkeeping schema (skip if read-only mode)
GRANT ALL ON SCHEMA CENSUS TO CENSUS;

-- Ensure access to existing objects in bookkeeping schema (skip if read-only mode)
GRANT ALL PRIVILEGES ON ALL TABLES IN SCHEMA CENSUS TO CENSUS;

-- Grant schema access (repeat for each schema with event data)
GRANT USAGE ON SCHEMA "<your_schema>" TO CENSUS;

-- Grant read access to existing tables
GRANT SELECT ON ALL TABLES IN SCHEMA "<your_schema>" TO CENSUS;

-- Grant read access to future tables
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT SELECT ON TABLES TO CENSUS;

-- Grant execute permissions on functions
GRANT EXECUTE ON ALL FUNCTIONS IN SCHEMA "<your_schema>" TO CENSUS;
ALTER DEFAULT PRIVILEGES IN SCHEMA "<your_schema>" GRANT EXECUTE ON FUNCTIONS TO CENSUS;

​

Event data mapping

​

Örnek Etkinlik Tablosu Şeması

-- Example Redshift event table
CREATE TABLE analytics.user_events (
    event_id BIGINT IDENTITY(1,1),
    event_name VARCHAR(100) NOT NULL,
    user_id VARCHAR(255) NOT NULL,
    event_timestamp TIMESTAMP DEFAULT GETDATE(),
    event_data SUPER,
    session_id VARCHAR(255),
    created_at TIMESTAMP DEFAULT GETDATE()
)
DISTKEY(user_id)
SORTKEY(event_timestamp);

​

SQL Sorgu Modu

-- Example: Recent high-value events
SELECT
    event_name,
    user_id,
    event_timestamp,
    event_data
FROM analytics.user_events
WHERE event_timestamp >= DATEADD(day, -7, GETDATE())
    AND JSON_EXTRACT_PATH_TEXT(event_data, 'value')::NUMERIC > 100
ORDER BY event_timestamp DESC;

​

dbt Entegrasyonu

​

Seçenek 1: Ayrıntılı İzinler

-- In your dbt model
{{ config(
    post_hook="GRANT SELECT ON {{ this }} TO CENSUS"
) }}

​

Seçenek 2: Varsayılan Ayrıcalıklar (Önerilen)

-- Must be run by Redshift superuser
ALTER DEFAULT PRIVILEGES FOR USER "<your_dbt_run_user>"
IN SCHEMA "<your_dbt_target_schema>"
GRANT SELECT ON TABLES TO CENSUS;

​

Gelişmiş Ağ Yapılandırması

​

SSH Tüneli Kurulumu

1. SSH kullanıcısı oluşturma: SSH ana bilgisayarınızda özel bir kullanıcı oluşturun
2. Tüneli yapılandırma: OneSignal entegrasyon ayarlarında “Use SSH Tunnel” seçeneğini etkinleştirin
3. Anahtar çifti yükleme: OneSignal’in genel anahtarını ~/.ssh/authorized_keys dosyasına ekleyin
4. Bağlantıyı test etme: Tünel bağlantısını doğrulayın

​

VPC Dağıtımı

1. AWS Console’da VPC hizmetine gidin
2. S3 hizmeti için VPC Uç Noktası oluşturun
3. Redshift alt ağınızla ilişkilendirin
4. Yönlendirme tablolarını yapılandırın

​

Performans Optimizasyonu

​

Dağıtım ve Sıralama Anahtarları

-- Distribute by user_id for user-centric queries
CREATE TABLE analytics.user_events (
    -- columns
)
DISTKEY(user_id)
SORTKEY(event_timestamp, event_name);

​

Sütunsal Depolama

• Sıkıştırma: Redshift sütunları otomatik olarak sıkıştırır
• Bölge Haritaları: Sıralanmış verilerle sorgu performansını artırır
• Sütun odaklı: Etkinlik verileri üzerindeki analitik sorgular için verimlidir

​

Sınırlamalar

• Birden fazla şema ayrı izin verilmesini gerektirir
• Çapraz şema tablolarına referans veren görünümler ek izinler gerektirir
• Karmaşık saklı yordam erişimi ek kurulum gerektirebilir
• VPC dağıtımları S3 VPC Uç Noktası yapılandırması gerektirir

​

SSS

​

OneSignal büyük etkinlik veri kümelerini nasıl işler?

​

Salt okunur modu kullanabilir miyim?

​

dbt uyumluluğu ne durumda?