메인 콘텐츠로 건너뛰기

​
개요

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

​
요구사항

​
Starburst Galaxy

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

​
설정

1

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에서 호스트 이름 부분만 필요합니다.
2

Starburst Galaxy 연결 구성

OneSignal에서 Data > Integrations으로 이동하여 Add Integration을 클릭합니다.Starburst Galaxy를 선택하고 다음 연결 세부정보를 제공하세요:
  • 호스트: Galaxy 클러스터 호스트 이름(1단계에서)
  • 사용자 이름: Galaxy 사용자 이름
  • 비밀번호: Galaxy 비밀번호
  • 포트: 443(Galaxy 기본값)
3

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

향상된 성능을 위해 Galaxy에 전용 CENSUS 카탈로그를 설정하세요:
  1. CENSUS라는 스키마를 포함하는 CENSUS라는 카탈로그를 생성하세요
  2. 커넥터가 다음을 지원하는지 확인하세요:
    • CREATE TABLE 및 DROP TABLE 작업
    • 테이블 쓰기(INSERT, DELETE, UPDATE)
    • CREATE OR REPLACE TABLE 문
  3. OneSignal 사용자에게 CENSUS.CENSUS 스키마에 대한 전체 권한을 부여하세요
테스트된 구성에는 MySQL, PostgreSQL, Snowflake, Iceberg 및 Starburst Galaxy 카탈로그가 포함됩니다.

​
이벤트 데이터 매핑

를 OneSignal의 사용자 지정 이벤트 형식에 매핑합니다:
OneSignal 필드설명필수
nameevent_name이벤트 식별자Yes
external_iduser_id사용자 식별자Yes
timestampevent_timestamp이벤트가 발생한 시간No
propertiesevent_dataNo

​
예시 이벤트 쿼리

-- 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 이벤트 처리에 최적의 성능을 보장합니다.