> ## Documentation Index
> Fetch the complete documentation index at: https://documentation.onesignal.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Starburst Galaxy

> Starburst GalaxyからOneSignalにカスタムイベントを同期して、ユーザー行動に基づいた自動化されたJourneysとパーソナライズされたメッセージングキャンペーンをトリガーします。

export const PLATFORM_0 = "Starburst Galaxy"

export const DATA_TYPE_0 = "イベントデータ"

export const COLUMN_HEADER_0 = "Galaxyカラム"

export const PROPERTIES_DESCRIPTION_0 = "JSONとしてのイベントメタデータ"

## 概要

OneSignal + Starburst Galaxy統合により、Starburst GalaxyクラスタからOneSignalにカスタムイベントを同期して、ユーザー行動に基づいた自動化されたメッセージングキャンペーンとJourneysをトリガーできます。

Starburst Galaxyは、Trinoをベースとしたフルマネージドクラウド分析プラットフォームで、クラウドデータレイクとウェアハウス全体での高速SQLクエリ向けに設計されています。

***

## 要件

* アウトバウンドメッセージイベント用の[Event Streams](/docs/ja/event-streams)へのアクセス（プランの制限と超過料金が適用されます）
* インバウンドイベント同期用の[Custom Events](/docs/ja/custom-events)へのアクセス（プランの制限と超過料金が適用されます）
* [更新されたアカウントプラン](https://onesignal.com/pricing)（無料アプリでは利用できません）

### Starburst Galaxy

* ネットワークアクセスを持つ**Starburst Galaxyクラスタ**
* 適切な権限を持つ**ユーザー認証情報**
* **TLS接続**サポート（Galaxyに組み込み）
* Galaxyカタログを通じてアクセス可能な**イベントデータ**

***

## セットアップ

<Steps>
  <Step title="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
    ```

    <Info>
      OneSignalはJDBCを使用してStarburst Galaxyに接続します。GalaxyのJDBC URLからホスト名部分のみが必要です。
    </Info>
  </Step>

  <Step title="Starburst Galaxy接続を設定する">
    OneSignalで、**Data > Integrations**に移動し、**Add Integration**をクリックします。

    **Starburst Galaxy**を選択し、以下の接続詳細を入力します：

    * **Host：** Galaxyクラスタのホスト名（ステップ1から）
    * **Username：** Galaxyのユーザー名
    * **Password：** Galaxyのパスワード
    * **Port：** 443（Galaxyのデフォルト）
  </Step>

  <Step title="高度な同期エンジンを設定する（オプション）">
    パフォーマンスを向上させるために、Galaxy内に専用のCENSUSカタログをセットアップします：

    1. `CENSUS` という名前のスキーマを含む `CENSUS` という名前のカタログを作成します
    2. コネクタが以下をサポートしていることを確認します：
       * `CREATE TABLE` および `DROP TABLE` 操作
       * テーブル書き込み（INSERT、DELETE、UPDATE）
       * `CREATE OR REPLACE TABLE` ステートメント
    3. OneSignalユーザーに `CENSUS.CENSUS` スキーマの完全な権限を付与します

    <Info>
      テスト済みの構成には、MySQL、PostgreSQL、Snowflake、Iceberg、およびStarburst Galaxyカタログが含まれます。
    </Info>
  </Step>
</Steps>

***

### イベントデータマッピング

{PLATFORM_0} {DATA_TYPE_0}をOneSignalのカスタムイベント形式にマッピングします：

| OneSignalフィールド | {COLUMN_HEADER_0} | 説明                         | 必須  |
| -------------- | ----------------- | -------------------------- | --- |
| `name`         | `event_name`      | イベント識別子                    | はい  |
| `external_id`  | `user_id`         | ユーザー識別子                    | はい  |
| `timestamp`    | `event_timestamp` | イベントが発生した時刻                | いいえ |
| `properties`   | `event_data`      | {PROPERTIES_DESCRIPTION_0} | いいえ |

### イベントクエリの例

```sql theme={null}
-- 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;
```

### クラウドデータレイククエリ

```sql theme={null}
-- 例：クラウドデータソース全体のフェデレーテッドクエリ
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イベント処理の最適なパフォーマンスを保証します。