Starburst Galaxy

개요

OneSignal + Starburst Galaxy 통합을 통해 Starburst Galaxy 클러스터에서 OneSignal로 사용자 지정 이벤트를 동기화하여 사용자 행동을 기반으로 자동화된 메시징 캠페인 및 저니를 트리거할 수 있습니다. Starburst Galaxy는 클라우드 데이터 레이크 및 웨어하우스에 걸친 빠른 SQL 쿼리를 위해 설계된 Trino 기반의 완전 관리형 클라우드 분석 플랫폼입니다.

요구사항

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)

네트워크 액세스 권한이 있는 Starburst Galaxy 클러스터
적절한 권한이 있는 사용자 자격 증명
TLS 연결 지원(Galaxy에 내장)
Galaxy 카탈로그를 통해 액세스할 수 있는 이벤트 데이터

설정

Galaxy JDBC 연결 세부정보 가져오기

Starburst Galaxy 콘솔에서 클러스터의 연결 세부정보로 이동하세요.JDBC URL 예시:

jdbc:trino://census-example-cluster.trino.galaxy.starburst.io:[email protected]/accountadmin

OneSignal용 호스트 이름 추출:

census-example-cluster.trino.galaxy.starburst.io

OneSignal은 JDBC를 사용하여 Starburst Galaxy에 연결합니다. Galaxy의 JDBC URL에서 호스트 이름 부분만 필요합니다.

Starburst Galaxy 연결 구성

OneSignal에서 Data > Integrations으로 이동하여 Add Integration을 클릭합니다.Starburst Galaxy를 선택하고 다음 연결 세부정보를 제공하세요:

호스트: Galaxy 클러스터 호스트 이름(1단계에서)
사용자 이름: Galaxy 사용자 이름
비밀번호: Galaxy 비밀번호
포트: 443(Galaxy 기본값)

고급 동기화 엔진 구성(선택 사항)

향상된 성능을 위해 Galaxy에 전용 CENSUS 카탈로그를 설정하세요:

CENSUS라는 스키마를 포함하는 CENSUS라는 카탈로그를 생성하세요
커넥터가 다음을 지원하는지 확인하세요:
- CREATE TABLE 및 DROP TABLE 작업
- 테이블 쓰기(INSERT, DELETE, UPDATE)
- CREATE OR REPLACE TABLE 문
OneSignal 사용자에게 CENSUS.CENSUS 스키마에 대한 전체 권한을 부여하세요

테스트된 구성에는 MySQL, PostgreSQL, Snowflake, Iceberg 및 Starburst Galaxy 카탈로그가 포함됩니다.

이벤트 데이터 매핑

를 OneSignal의 사용자 지정 이벤트 형식에 매핑합니다:

OneSignal 필드	설명	필수
`name`	`event_name`	이벤트 식별자	Yes
`external_id`	`user_id`	사용자 식별자	Yes
`timestamp`	`event_timestamp`	이벤트가 발생한 시간	No
`properties`	`event_data`	No

예시 이벤트 쿼리

-- Example: Recent high-value events across Galaxy catalogs
SELECT
    event_name,
    user_id,
    event_timestamp,
    CAST(event_properties AS JSON) as event_properties
FROM catalog.schema.user_events
WHERE event_timestamp >= current_timestamp - INTERVAL '7' DAY
    AND JSON_EXTRACT_SCALAR(event_properties, '$.value') > '100'
ORDER BY event_timestamp DESC;

클라우드 데이터 레이크 쿼리

-- Example: Federated query across cloud data sources
SELECT
    'cloud_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        's3_interactions', s.interaction_count,
        'snowflake_orders', sf.order_count,
        'bigquery_analytics', bq.score_value
    )) as event_properties
FROM s3_catalog.users.profiles u
LEFT JOIN s3_catalog.interactions.summary s ON u.user_id = s.user_id
LEFT JOIN snowflake_catalog.orders.summary sf ON u.user_id = sf.user_id
LEFT JOIN bigquery_catalog.analytics.scores bq ON u.user_id = bq.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;

동기화 엔진 옵션

기본 동기화 엔진

모든 Galaxy 카탈로그 및 커넥터와 작동
OneSignal 인프라에서 관리하는 상태 추적
추가 요구사항 없이 더 간단한 설정

고급 동기화 엔진

로컬 상태 추적으로 향상된 성능
전용 CENSUS.CENSUS 카탈로그 및 스키마 필요
테이블 쓰기 작업이 있는 커넥터 지원
대용량 클라우드 이벤트 처리에 권장

지원되는 커넥터

OneSignal의 고급 동기화 엔진은 다음으로 테스트되었습니다:

MySQL 커넥터(읽기-쓰기 모드)
PostgreSQL 커넥터(읽기-쓰기 모드)
Snowflake 커넥터(읽기-쓰기 모드)
Iceberg 커넥터(S3 및 AWS Glue 포함)
Starburst Galaxy 카탈로그(네이티브 Galaxy 스토리지)

클라우드 플랫폼 기능

다중 클라우드 페더레이션

AWS, Azure 및 GCP 데이터 소스 간 쿼리
S3, Snowflake, BigQuery 및 Azure 데이터 결합
클라우드 제공업체 간 통합 이벤트 분석

관리형 인프라

자동 확장 기능이 있는 완전 관리형 Trino 클러스터
내장된 보안 및 규정 준수 기능
인프라 관리 불필요

Galaxy 네이티브 카탈로그

고성능 네이티브 Galaxy 스토리지
Galaxy 에코시스템과 원활한 통합
클라우드 분석 워크로드에 최적화

제한사항

TLS 연결 필요(Galaxy에 내장)
고급 동기화 엔진은 CREATE OR REPLACE TABLE 지원 필요
웨어하우스 라이트백은 아직 지원되지 않음(곧 출시 예정)
WITH 절에서 사용자 지정 테이블 옵션을 제공할 수 없음

FAQ

Galaxy 클러스터 호스트 이름을 어떻게 얻나요?

Starburst Galaxy 콘솔에서 클러스터의 연결 세부정보로 이동하고 JDBC URL을 복사하세요. OneSignal에서 사용하기 위해 호스트 이름 부분만(jdbc:trino:// 접두사 제외) 추출하세요.

여러 클라우드 데이터 소스를 쿼리할 수 있나요?

예! Starburst Galaxy의 페더레이션 쿼리 기능을 사용하면 단일 쿼리에서 여러 클라우드 소스(S3, Snowflake, BigQuery 등)의 이벤트 데이터를 결합할 수 있습니다.

Galaxy는 OneSignal 워크로드에 대한 자동 확장을 지원하나요?

예, Starburst Galaxy는 쿼리 로드에 따라 클러스터를 자동으로 확장하여 수동 개입 없이 OneSignal 이벤트 처리에 최적의 성능을 보장합니다.

시작하기 & 설정

메시지 채널

Journeys

오디언스 & 사용자 지정 이벤트

분석 & 통합

개인 정보 보호 & 보안

Starburst Galaxy

개요

요구사항