> ## 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 Enterprise

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

export const PLATFORM_0 = "Starburst Enterprise"

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

export const COLUMN_HEADER_0 = "Starburstカラム"

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

## 概要

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

Starburst Enterpriseは、複数のソースにわたるエンタープライズ分析とデータレイククエリ向けに設計された、Trinoの商用ディストリビューションです。

***

## 要件

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

### Starburst Enterprise

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

***

## セットアップ

<Steps>
  <Step title="JDBC接続の詳細を取得する">
    Starburstのドキュメントに従って、目的のクラスタのJDBC URLを取得します。

    **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 Enterpriseに接続します。JDBC URLのホスト名部分のみが必要です。
    </Info>
  </Step>

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

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

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

  <Step title="高度な同期エンジンを設定する（オプション）">
    パフォーマンスを向上させるために、専用の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 Delta Lakeコネクタが含まれます。
    </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 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
    'enterprise_activity' as event_name,
    u.user_id,
    current_timestamp as event_timestamp,
    JSON_FORMAT(JSON_OBJECT(
        'crm_interactions', c.interaction_count,
        'warehouse_orders', w.order_count,
        'lake_analytics', l.score_value
    )) as event_properties
FROM salesforce_catalog.users.accounts u
LEFT JOIN crm_catalog.interactions.summary c ON u.user_id = c.user_id
LEFT JOIN warehouse_catalog.orders.summary w ON u.user_id = w.user_id
LEFT JOIN datalake_catalog.analytics.scores l ON u.user_id = l.user_id
WHERE u.created_date >= current_date - INTERVAL '30' DAY;
```

***

## 同期エンジンオプション

### 基本同期エンジン

* 任意のStarburstカタログとコネクタで動作します
* OneSignalインフラストラクチャによって管理される状態追跡
* 追加要件のないシンプルなセットアップ

### 高度な同期エンジン

* ローカル状態追跡による強化されたパフォーマンス
* 専用の `CENSUS.CENSUS` カタログとスキーマが必要
* テーブル書き込み操作をサポートするコネクタに対応
* 大量のエンタープライズイベント処理に推奨

***

## サポートされているコネクタ

OneSignalの高度な同期エンジンは、以下でテスト済みです：

* **MySQLコネクタ**（読み取り/書き込みモード）
* **PostgreSQLコネクタ**（読み取り/書き込みモード）
* **Snowflakeコネクタ**（読み取り/書き込みモード）
* **Icebergコネクタ**（S3およびAWS Glue使用）
* **Starburst Delta Lakeコネクタ**（AWS Glueカタログ使用）

***

## エンタープライズ機能

### マルチソースフェデレーション

* 単一の同期でエンタープライズデータソース全体をクエリ
* CRM、ウェアハウス、データレイクのイベントデータを組み合わせ
* 異種システムからの統合された顧客イベントプロファイル

### セキュリティとコンプライアンス

* エンタープライズグレードの認証と承認
* 行レベルセキュリティとカラムマスキングのサポート
* データアクセス追跡のための監査ログ

***

## 制限事項

* TLS接続が必要（OneSignalのセキュリティ要件）
* 高度な同期エンジンには `CREATE OR REPLACE TABLE` サポートが必要
* ウェアハウスライトバックはまだサポートされていません（近日公開予定）
* `WITH` 句でカスタムテーブルオプションを提供できません

***

## FAQ

### Starburst Enterpriseのホスト名を取得するにはどうすればよいですか？

StarburstのドキュメントでJDBC URLを取得し、OneSignalで使用するために（`jdbc:trino://` プレフィックスなしで）ホスト名部分のみを抽出します。

### 複数のエンタープライズデータソースをクエリできますか？

はい！Starburst Enterpriseのフェデレーテッドクエリ機能により、単一のクエリで複数のエンタープライズソース（Salesforce、SAP、Oracleなど）からのイベントデータを組み合わせることができます。

### 高度な同期エンジンをサポートするStarburstリリースはどれですか？

高度な同期エンジン機能に必要な `CREATE OR REPLACE TABLE` サポートについては、Starburst Enterpriseのリリースノートを確認してください。