Amazon Redshiftのクラウドデータ取り込み

このページでは、クラウドデータ取り込み (CDI) を使用してAmazon RedshiftからBrazeにデータを同期するために必要なすべての情報を説明します。Redshiftで作成するリソース、ソースを接続してBrazeで同期を作成する方法、データタイプごとのソーステーブル、Redshift固有のトラブルシューティングを扱います。

設定の概要

1. Redshiftインスタンスで、Brazeに同期するテーブルまたはビューを設定します。
2. サポートされている認証方法のいずれかを使用してBraze用のRedshiftユーザーを作成し、テーブルへのアクセス権を付与します。
3. 同期するRedshiftテーブルへのBrazeのアクセスが許可されていることを確認します。Brazeはインターネット経由でRedshiftに接続します。
4. Brazeダッシュボードで新しいソースと同期を作成します。
5. 統合を検証し、同期を開始します。

注

同期ごとに処理される行数は、ウェアハウスのパフォーマンス、ネットワークの遅延、同期クエリに一致する新しいデータの量によって異なります。ダッシュボードの統合の同期履歴を使用すると、最近の実行の所要時間と行数を確認できます。

ステップ 1: ソーステーブルを設定する

このセクションの手順では、PAYLOAD 列を持つテーブルを作成します。データ定義ステップでビジュアルを使用して列をマッピングする場合や、SQLでクエリを記述する場合は、代わりに既存のテーブルまたはビューを使用できます。その場合はテーブル作成の手順をスキップし、同期するテーブルまたはビューへの読み取りアクセス権をBrazeに付与してください。オプションの比較については、データ定義オプションを選択するを参照してください。

データベース、スキーマ、テーブルには任意の名前を付けられますが、列名は以下のタブの定義と一致させる必要があります。テーブルの代わりにビューやマテリアライズドビューを使用することもできます。

必要に応じて、ソーステーブルを格納する新しいデータベースとスキーマを設定します。

1
2

CREATE DATABASE BRAZE_CLOUD_PRODUCTION;
CREATE SCHEMA BRAZE_CLOUD_PRODUCTION.INGESTION;

注

PAYLOAD 列を使用する場合、ソーステーブルまたはビューには以下のタブに記載されていない列 (監査用やハッシュ用など) を含めることができます。Brazeはこれらのタブで説明されている列のみを読み取り、その他の列はクラウドデータ取り込みの同期では使用されません。

同期するデータタイプのタブを選択してください。

• user attributes
• custom events
• purchase events
• catalog items
• キャンバス triggers
• user deletions

ユーザー属性、カスタムイベント、購入イベントはすべて同じ形式のソーステーブルを使用します。異なるのは PAYLOAD の内容だけです。

1
2
3
4
5
6
7
8
9
10
11
12
13
14

CREATE TABLE BRAZE_CLOUD_PRODUCTION.INGESTION.USERS_ATTRIBUTES_SYNC (
   updated_at timestamptz default sysdate,
   --at least one of external_id, alias_name and alias_label, or braze_id is required
   external_id varchar,
   --if using user alias, both alias_name and alias_label are required
   alias_label varchar,
   alias_name varchar,
   --braze_id can only be used to update existing users created through the Braze SDK
   braze_id varchar,
   --If you include both email and phone, email is used as the primary identifier
   email varchar,
   phone varchar,
   payload varchar(max)
)

• UPDATED_AT - この行がテーブルで更新または追加された時刻です。Brazeは、UPDATED_AT が最後に同期された値より後の行を同期します。境界となるタイムスタンプとまったく同じ時刻の行は、新しい行が同じタイムスタンプを共有している場合、再同期されることがあります。
• ユーザー識別子列 - テーブルには、1つ以上のユーザー識別子列を含めることができます。各行には識別子を1つだけ含めてください (external_id、alias_name と alias_label の組み合わせ、braze_id、email、phone のいずれか)。ソーステーブルには、1つ、2つ、3つ、4つ、または5つすべての識別子タイプの列を含めることができます。
  • EXTERNAL_ID - 更新するユーザーを識別します。Brazeで使用されている external_id の値と一致している必要があります。
  • ALIAS_NAME と ALIAS_LABEL - この2つの列でユーザーエイリアスオブジェクトを作成します。alias_name は一意の識別子である必要があり、alias_label はエイリアスのタイプを指定します。ユーザーは異なるラベルを持つ複数のエイリアスを持つことができますが、alias_label ごとに持てる alias_name は1つだけです。
  • BRAZE_ID - Brazeのユーザー識別子です。これはBraze SDKによって生成されるもので、Cloud Data Ingestionを通じてBraze IDを使用して新しいユーザーを作成することはできません。新しいユーザーを作成するには、外部ユーザー IDまたはユーザーエイリアスを指定してください。
  • EMAIL - ユーザーのメールアドレスです。同じメールアドレスを持つプロファイルが複数存在する場合、最後に更新されたプロファイルが優先的に更新されます。メールと電話番号の両方を含める場合は、メールがプライマリ識別子として使用されます。
  • PHONE - ユーザーの電話番号です。同じ電話番号を持つプロファイルが複数存在する場合、最後に更新されたプロファイルが優先的に更新されます。
• PAYLOAD - Brazeのユーザーに同期するフィールドのJSON文字列です。

属性の同期では、PAYLOAD はユーザー属性オブジェクトの形式に従います。階層化カスタム属性、オブジェクトの配列、購読グループのステータスを含めることができます。ペイロードの例については、テーブルの設定を参照してください。

カスタムイベントは、ユーザー属性と同じソーステーブルを使用します。User attributes タブに示されているテーブルを作成し、PAYLOAD にイベントオブジェクトを入力します。

イベントを同期するには、イベント名が必要です。time フィールドは、ISO 8601文字列または yyyy-MM-dd'T'HH:mm:ss:SSSZ 形式で指定します。time フィールドがない場合、Brazeは UPDATED_AT 列の値をイベント時刻として使用します。app_id や properties などのその他のフィールドはオプションです。

1行につき1つのイベントを同期できます。

1
2
3
4
5
6
7
8
9

{
    "app_id" : "your-app-id",
    "name" : "rented_movie",
    "time" : "2013-07-16T19:20:45+01:00",
    "properties": {
        "movie": "The Sad Egg",
        "director": "Alex Smith"
    }
}

購入イベントは、ユーザー属性と同じソーステーブルを使用します。User attributes タブに示されているテーブルを作成し、PAYLOAD に購入オブジェクトを入力します。

購入イベントを同期するには、product_id、currency、price が必要です。オプションの time フィールドは、ISO 8601文字列または yyyy-MM-dd'T'HH:mm:ss:SSSZ 形式で指定します。time フィールドがない場合、Brazeは UPDATED_AT 列の値をイベント時刻として使用します。app_id、quantity、properties などのその他のフィールドはオプションです。

1行につき1つの購入イベントを同期できます。

1
2
3
4
5
6
7
8
9
10
11
12

{
    "app_id" : "11ae5b4b-2445-4440-a04f-bf537764c9ad",
    "product_id" : "Completed Order",
    "currency" : "USD",
    "price" : 219.98,
    "time" : "2013-07-16T19:20:30+01:00",
    "properties" : {
        "products" : [ { "name": "Monitor", "category": "Gaming", "product_amount": 19.99 },
        { "name": "Gaming Keyboard", "category": "Gaming ", "product_amount": 199.99 }
        ]
    }
}

カタログ同期を作成する前に、Brazeで対象のカタログを作成してください。カタログのワークフロー全体については、カタログデータの同期と削除を参照してください。

1
2
3
4
5
6
7
8
9

CREATE TABLE BRAZE_CLOUD_PRODUCTION.INGESTION.CATALOGS_SYNC (
   updated_at timestamptz default sysdate not null,
   --ID of the catalog item to be created or updated
   id varchar not null,
   --Catalog fields and values that should be added or updated
   payload varchar(max),
   --The catalog item associated with this ID should be deleted
   deleted boolean
)

他のソーステーブルと同様に、このテーブルへのアクセス権をBrazeユーザーに付与します。

1

GRANT SELECT ON TABLE CATALOGS_SYNC TO braze_user;

統合の名前は、Brazeで作成したカタログの名前と完全に一致している必要があります。

同期を実行するたびにソーステーブルが完全に更新されるよう、カタログデータからビューを作成することをお勧めします。たとえば、product_id と3つの追加属性を持つ商品データのテーブル (product_catalog_1) がある場合、次のように同期できます。

1
2
3
4
5
6
7
8
9
10
11
12
13

CREATE TABLE BRAZE_CLOUD_PRODUCTION.INGESTION.CATALOGS_SYNC AS
SELECT
    CURRENT_TIMESTAMP as UPDATED_AT,
    Product_id as id,
    JSON_SERIALIZE(
        OBJECT (
            'attribute_1',
            attribute_1,
            'attribute_2',
            attribute_2,
            'attribute_3',
            attribute_3)
    ) as PAYLOAD FROM "product_catalog_1";

キャンバストリガーは、ゼロコピーパーソナライゼーションを実現します。送信先キャンバスの設定と考慮事項については、ゼロコピーパーソナライゼーションを参照してください。

1
2
3
4
5
6
7
8
9

CREATE TABLE BRAZE_CLOUD_PRODUCTION.INGESTION.CANVAS_TRIGGERS_SYNC (
    updated_at timestamptz default sysdate not null,
    --at least one of external_id or alias_name and alias_label is required
    external_id varchar not null,
    --if using user alias, both alias_name and alias_label are required
    alias_label varchar,
    alias_name varchar,
    properties varchar(max)
 );

キャンバストリガーの同期は、他のユーザーデータの同期と次の3点で異なります。

• external ID またはユーザーエイリアスの識別子のみがサポートされています。メールアドレスと電話番号は識別子としてサポートされていません。
• 同期できるのは既存の Braze ユーザーのみです。新しいユーザーを作成することはできません。
• PAYLOAD 列の代わりに PROPERTIES 列を使用します。これは、パーソナライゼーション用のキャンバスエントリプロパティとして使用するフィールドの JSON 文字列です。

キャンバストリガーテーブルには、次の列が必要です。

• UPDATED_AT - この行がテーブルで更新または追加された時刻です。Brazeは、UPDATED_AT が最後に同期された値よりも後の行を同期します。境界となるタイムスタンプとまったく同じタイムスタンプを持つ行は、新しい行が同じタイムスタンプを持つ場合に再同期されることがあります。
• ユーザー識別子の列として、EXTERNAL_ID、または ALIAS_NAME と ALIAS_LABEL のいずれか。これらの列は、キャンバスメッセージングをトリガーする対象のユーザーを識別します。
  • EXTERNAL_ID - キャンバスにエントリさせるユーザーを識別します。この値は、Brazeで使用される external_id の値と一致する必要があります。
  • ALIAS_NAME と ALIAS_LABEL - これらの列はユーザーエイリアスオブジェクトを作成します。alias_name は一意の識別子である必要があり、alias_label はエイリアスのタイプを指定します。ユーザーは異なるラベルを持つ複数のエイリアスを持つことができますが、1つの alias_label につき alias_name は1つのみです。
• PROPERTIES - キャンバスでパーソナライゼーションプロパティとして使用できるようにするフィールドの JSON 文字列です。ユーザー固有の情報を含める必要があります。

注

プロパティは、すべての行やユーザーに必須というわけではありません。ただし、プロパティの値は有効な JSON 文字列である必要があります。行にプロパティがない場合は、空の {} 文字列を入力してください。

このテーブルへのアクセス権をBrazeユーザーに付与します。

1

GRANT SELECT ON TABLE CANVAS_TRIGGERS_SYNC TO braze_user;

開始するには、新しい同期を作成するときにキャンバストリガーデータタイプを選択します。

ユーザー削除用のソーステーブルには、1つ以上のユーザー識別子タイプと UPDATED_AT タイムスタンプを含める必要があります。ユーザー削除データでは、ペイロード列はサポートされていません。

• UPDATED_AT - この行がテーブルで更新または追加された時刻です。Braze は、UPDATED_AT が最後に同期された値よりも後の行を同期します。新しい行が境界のタイムスタンプとまったく同じタイムスタンプを持つ場合、その境界タイムスタンプの行が再同期されることがあります。
• ユーザー識別子列 - 各行には識別子を1つだけ含める必要があります。external_id、alias_name と alias_label の組み合わせ、または braze_id のいずれかです。ソーステーブルには、1つ、2つ、または3つすべての識別子タイプの列を含めることができます。
  • EXTERNAL_ID - 更新するユーザーを識別します。これは、Braze で使用されている external_id の値と一致する必要があります。
  • ALIAS_NAME と ALIAS_LABEL - これら2つの列によってユーザーエイリアスオブジェクトが作成されます。alias_name は一意の識別子である必要があり、alias_label はエイリアスのタイプを指定します。ユーザーは異なるラベルを持つ複数のエイリアスを持つことができますが、alias_label ごとに持てる alias_name は1つだけです。
  • BRAZE_ID - Braze のユーザー識別子です。これは Braze SDKによって生成されるもので、Cloud Data Ingestion を通じて Braze ID を使用して新しいユーザーを作成することはできません。新しいユーザーを作成するには、外部ユーザー ID またはユーザーエイリアスを指定してください。

重要

ユーザー削除用のテーブルには PAYLOAD 列を含めないでください。ユーザーが誤って完全に削除されるのを防ぐため、ソーステーブルにペイロード列が含まれている場合、同期は失敗します。その他の列は含めてもかまいませんが、Braze では無視されます。

1
2
3
4
5
6
7
8
9
10

CREATE TABLE BRAZE_CLOUD_PRODUCTION.INGESTION.USERS_DELETES (
   updated_at timestamptz default sysdate,
   --at least one of external_id, alias_name and alias_label, or braze_id is required
   external_id varchar,
   --if using user alias, both alias_name and alias_label are required
   alias_label varchar,
   alias_name varchar,
   --braze_id can only be used to update existing users created through the Braze SDK
   braze_id varchar
);

統合の実行時に適切なアクションが行われるよう、インポート同期を作成ページでデータタイプをユーザーを削除に設定します。詳細については、クラウドデータ取り込みでユーザーを削除するを参照してください。

警告

ユーザープロファイルの削除は元に戻せません。削除アクションはユーザーを完全に削除するため、データに不整合が生じる可能性があります。詳細については、ユーザープロファイル削除の影響を参照してください。

ステップ 2: 認証を設定する

Brazeはデータベースユーザーとして Redshiftに接続します。次のいずれかの認証方法でユーザーを作成してください。

Username and password

BrazeはパスワードをもつデータベースユーザーとしてRedshiftに接続します。Braze用のユーザーを作成してください。

1

CREATE USER braze_user PASSWORD '{password}';

ユーザー名とパスワードは、ソースを作成する際にBrazeダッシュボードで入力するまで、安全な場所に保管してください。

ステップ 3: ユーザーに権限を付与する

Braze用に作成したユーザーに、ソーステーブルへのアクセス権を付与します。

1
2

GRANT USAGE ON SCHEMA BRAZE_CLOUD_PRODUCTION.INGESTION to braze_user;
GRANT SELECT ON TABLE USERS_ATTRIBUTES_SYNC TO braze_user;

これらはこのユーザーに必要な最小限の権限です。複数のCDI統合を作成する場合は、スキーマに権限を付与するか、グループを使用して権限を管理することをお勧めします。

ステップ 4: Braze IPへのアクセスを許可する

ファイアウォールやその他のネットワークポリシーがある場合は、Redshiftインスタンスへのネットワークアクセスを Brazeに許可する必要があります。RedshiftのURLエンドポイントの例は「example-cluster.ap-northeast-2.redshift.amazonaws.com」です。

重要な注意点:

• BrazeがRedshift内のデータにアクセスできるよう、セキュリティグループの変更が必要になる場合もあります。
• 表に記載されているIPと、Redshiftクラスターへのクエリに使用するポート (デフォルトは5439) で、インバウンドトラフィックを明示的に許可してください。インバウンドルールが「すべて許可」に設定されている場合でも、このポートでのRedshift TCP接続を明示的に許可する必要があります。
• Brazeがクラスターに接続するには、Redshiftクラスターのエンドポイントがパブリックにアクセス可能である必要があります。
  • Redshiftクラスターをパブリックにアクセス可能にしたくない場合は、VPCとEC2インスタンスを設定し、SSHトンネルを使用してRedshiftのデータにアクセスできます。詳細については、AWSナレッジセンターの投稿を参照してください。

Brazeダッシュボードのリージョンに対応する以下のIPからのアクセスを許可してください。

• united states (us)
• european union (eu)
• australia (au)
• indonesia (id)
• japan (jp)
• south korea (kr)

ステップ 5: Brazeダッシュボードで新しいソースを作成する

Brazeダッシュボードで、データ設定 > クラウドデータ取り込み > ソースに移動し、データソースを追加を選択してから、Amazon Redshiftを選択します。

ステップ 5.1: Redshiftの接続情報とソーステーブルを追加する

ソースの名前を選択し、Redshiftの認証情報と設定を入力します。ステップ 2で設定した認証方法を選択し、その認証情報を入力します。

• Username and password: Username and Password

プライベートネットワークトンネルを使用している場合は、スライダーを切り替えてトンネル情報を入力します。その後、次のステップに進みます。

注

Amazon Redshiftではデータベース識別子に追加の文字を使用できますが、Brazeダッシュボードのデータベース名フィールドには英字 (A–Z、a–z)、数字 (0–9)、アンダースコア (_) のみを入力できます。

ステップ 5.2: 接続をテストしてソースに接続する

次に、接続をテストを選択します。成功したら残りの設定を完了し、ソースに接続をクリックします。接続に失敗した場合は、問題のトラブルシューティングに役立つエラーメッセージが表示されます。

ステップ 6: Brazeダッシュボードで新しい同期を作成する

データ設定 > クラウドデータ取り込み > 同期に移動し、データ同期を作成を選択します。

同期の詳細を設定してデータを定義する

同期の名前を入力します。次に、アクティブなソースと同期データタイプを選択します。続いてビジュアルまたはテーブルを選択してソーステーブルを入力するか、SQLを選択してカスタムSQLクエリを記述します。最後に、プレビューと検証を選択します。

検証が成功すると、データのプレビューが表示されます。次へ: 通知を選択して続行します。検証に失敗した場合は、問題のトラブルシューティングに役立つエラーメッセージが表示されます。

注

次のステップに進む前に、同期の検証を成功させる必要があります。同期の作成ページを閉じる必要がある場合は、下書きとして保存を選択して作業中の内容を保存してください。

通知設定を追加する

同期エラー通知を受け取る連絡先メールアドレスを入力します。Brazeはこの連絡先情報を使用して、テーブルアクセスの予期しない喪失などの統合エラーに関する通知を送信します。

連絡先メールアドレスには、テーブルの欠落や権限の問題など、グローバルエラーまたは同期レベルのエラーの通知のみが送信されます。行レベルの問題は通知されません。グローバルエラーは、同期の実行を妨げる接続上の重大な問題を示しています。

このような問題には、次のようなものがあります。

• 接続の問題
• リソースの不足
• 権限の問題
• カタログ階層の容量不足 (カタログ同期のみ)

スケジュールを設定する

最後に、同期を非定期または定期として設定します。

非定期の同期は、ダッシュボードで 今すぐ同期 を選択するか、同期をトリガーするエンドポイントを呼び出したときにのみ実行されます。

定期的な同期は、最短で5分ごと、最長で月1回の間隔で実行できます。デフォルトでは、ダッシュボードで設定できる最短の間隔は15分です。これにより、ウェアハウスのコンピューティングコストとリクエスト量を管理しやすくなります。最短5分ごとに同期するには、Brazeサポートまたはカスタマーサクセスマネージャーにお問い合わせください。Brazeは定期的な同期をUTCでスケジュールします。

注

統合を下書きからアクティブ状態に移行するには、統合の検証を成功させる必要があります。作成ページを閉じた場合でも統合は保存されるため、詳細ページに戻って変更を加え、検証できます。

同期を実行する

有効化すると、同期は設定時に構成したスケジュールで実行されます。スケジュール外で同期を実行したい場合や最新のデータを取得したい場合は、今すぐ同期を選択します。この実行は、今後定期的にスケジュールされている同期には影響しません。データの更新時に自動的に同期を開始するには、パイプラインから同期のトリガーエンドポイントを呼び出します。

追加の統合またはユーザーを設定する (オプション)

Brazeでは複数の統合を設定できます。追加の同期を作成する際、同じRedshiftアカウントに接続する場合は既存の認証情報を再利用できます。

複数の統合で同じユーザーを再利用している場合、すべてのアクティブな同期からそのユーザーが削除されるまで、Brazeダッシュボードでユーザーを削除することはできません。

Redshiftを接続されたソースとして使用する

接続されたソースは、Brazeへのデータ同期に代わるゼロコピーの手段です。BrazeはRedshiftインスタンスに直接クエリを実行してCDIセグメントを構築するため、基盤となるデータはコピーされません。概念、制限事項、コストへの影響については、接続されたソースを参照してください。

ステップ 1: ユーザーを作成して権限を付与する

ステップ 2: 認証を設定するのいずれかの方法でBraze用のユーザーを作成します。その後、次の権限を付与します。

1
2
3

GRANT USAGE ON SCHEMA BRAZE_CLOUD_PRODUCTION.INGESTION to braze_user;
GRANT CREATE ON SCHEMA BRAZE_CLOUD_PRODUCTION.INGESTION to braze_user;
GRANT SELECT ON TABLE USERS_ATTRIBUTES_SYNC TO braze_user;

接続されたソースで使用するユーザーを作成します。このユーザーは、CDIセグメントエクステンションで使用可能なテーブルのリストを生成し、ソーステーブルにクエリを実行して新しいセグメントを作成するために使用されます。接続されたソースの作成後、Brazeはソーススキーマ内でユーザーが使用できるすべてのテーブルの名前と説明を検出します。複数のCDI統合を作成する場合は、スキーマに権限を付与するか、グループを使用して権限を管理することをお勧めします。

スキーマ内のすべてのテーブルへのアクセス権を付与することも、特定のテーブルにのみ権限を付与することもできます。Brazeロールがアクセスできるテーブルはすべて、CDIセグメントエクステンションでクエリに使用できます。新しいテーブルを作成したときは必ずユーザーにアクセス権を付与するか、ユーザーにデフォルトの権限を設定してください。

create table 権限は、Brazeでセグメントを更新する前に、BrazeがCDIセグメントエクステンションのクエリ結果を含むテーブルを作成するために必要です。Brazeはセグメントごとに一時テーブルを作成し、このテーブルはBrazeがセグメントを更新している間のみ保持されます。

ネットワークアクセスの設定はステップ 4と同じです。

ステップ 2: Brazeで接続されたソースを作成する

データ設定 > クラウドデータ取り込み > 接続されたソースに移動し、データソースを追加を選択してから、Amazon Redshiftを選択します。

ソースを設定で、次の項目を入力します。

• 認証情報: Redshift Host URL、ポート、および認証方法のフィールド。Username and Passwordを入力します。
• 設定: データベースとスキーマ

必要に応じてSSHトンネルで接続を有効にし、トンネルホスト、トンネルポート、トンネルユーザー名を入力します。

接続されたソースの名前を選択します。この名前は、新しいCDIセグメントエクステンションを作成するときに、使用可能なソースのリストで使用されます。

このソースの最大実行時間を設定します。Brazeは最大実行時間を超えたクエリを自動的に中止します。許可される最大実行時間は60分です。実行時間を短くすると、Redshiftアカウントで発生するコストを削減できます。この設定は、このソースを使用する同期やCDIセグメントエクステンションなど、このソースを通じて実行されるクエリに適用されます。

ステップ 3: Redshiftの設定を完了する

認証情報でSSHトンネルで接続が選択されている場合は、接続をテストステップでRSA公開キーを控え、SSHトンネルユーザーに追加します。

ユーザーにキーを追加したら、Brazeで接続をテストを選択し、完了を選択します。これで接続されたソースが作成され、CDIセグメントエクステンションで使用できるようになります。

Brazeでは複数の接続されたソースを設定できますが、各ソースはそれぞれ異なるスキーマに接続するように設定する必要があります。追加のソースを作成する際、同じRedshiftアカウントに接続する場合は既存の認証情報を再利用できます。

既存の列からペイロードを作成する

社内で各属性を個別の列に保存したい場合は、それらの列をJSON文字列に変換してBrazeとの同期に入力する必要があります。Redshiftで次のクエリを使用して、ソース列をCDIフィールドに整形します。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

CREATE TABLE "EXAMPLE_USER_DATA"
    (attribute_1 string,
     attribute_2 string,
     attribute_3 number,
     my_user_id string);

SELECT
    CURRENT_TIMESTAMP as UPDATED_AT,
    my_user_id as EXTERNAL_ID,
    JSON_SERIALIZE(
        OBJECT (
            'attribute_1',
            attribute_1,
            'attribute_2',
            attribute_2,
            'yet_another_attribute',
            attribute_3)
    ) as PAYLOAD FROM "EXAMPLE_USER_DATA";

最適化に関するその他のガイダンスについては、クラウドデータ取り込みのベストプラクティスを参照してください。

トラブルシューティング

接続テストの実行が遅い

接続テストはデータウェアハウス上で実行されるため、ウェアハウスの容量を増やすと速度が向上する可能性があります。サーバーレスSQLインスタンスを使用すると、ウォームアップ時間が最小限に抑えられ、クエリのスループットが向上しますが、統合コストがわずかに高くなる場合があります。

リレーション {table_name} に対する権限が拒否される

このエラーが発生した場合:

• そのユーザーに、スキーマに対する usage 権限を付与します。
• そのユーザーに、テーブルに対する select 権限を付与します。

接続作成エラー

このエラーが発生した場合は、Redshiftのエンドポイントとポートが正しいことを確認してください。

SSHトンネル作成エラー

このエラーが発生した場合:

• Brazeダッシュボードの公開キーが、SSHトンネリングに使用するEC2ホストにあることを確認します。
• ユーザー名が正しいことを確認します。
• SSHトンネルが正しいことを確認します。

無効なスナップショット識別子

接続をテストまたは同期の設定中にBrazeが Invalid snapshot identifier エラーを返す場合、ソースオブジェクトへのクエリ時に使用されるスナップショット参照をRedshiftが解決できていません。

Redshiftにおけるスナップショットとは、クラスターの特定時点のバックアップです。各スナップショットには一意の識別子があり、Redshiftはこれを使用してそのバックアップ状態を参照します。詳細については、Amazon Redshiftのスナップショットとバックアップを参照してください。

このエラーは、スナップショットのコピー、復元、レプリケーション関連の操作中など、Brazeがソースオブジェクトを検証している間にメタデータが変更された場合に発生することがあります。詳細については、スナップショットを別のAWSリージョンにコピーするおよびスナップショットからクラスターを復元するを参照してください。

トラブルシューティングの手順:

1. クラスターのエンドポイント、データベース、スキーマ、オブジェクト名など、Brazeのソース設定を確認します。
2. Redshiftで同じクエリを直接実行し、テーブルまたはビューが読み取り可能で安定していることを確認します。
3. 進行中のスナップショット、復元、サイズ変更、レプリケーションのアクティビティが完了してから再試行します。
4. 問題が解決しない場合は、頻繁に変更されるベーステーブルではなく、マテリアライズドビューにクエリを実行します。

マテリアライズドビューは、スケジュールに沿って更新できる事前計算済みのクエリ結果を保存するため、CDI同期での読み取りをより安定させることができます。詳細については、Amazon Redshiftのマテリアライズドビューを参照してください。

例:

1
2
3
4
5

CREATE MATERIALIZED VIEW ingestion.users_attributes_mv AS
SELECT updated_at, external_id, alias_label, alias_name, braze_id, email, phone, payload
FROM ingestion.users_attributes_sync;

REFRESH MATERIALIZED VIEW ingestion.users_attributes_mv;

マテリアライズドビューを作成したら、BrazeのCDI同期のソースオブジェクトとして、ベーステーブルの代わりにマテリアライズドビューの名前を使用します。

SQLチェックの実行場所

検証チェックは、CDI統合で使用しているのと同じテーブルまたはビューに対して、RedshiftのSQLエディターで直接実行します。Query Editor v2を使用してください。詳細については、Amazon Redshift Query Editor v2の使用を参照してください。

関連ページ

• 必須の列とペイロードの形式については、テーブルの設定を参照してください。
• 同期のスケジュール設定とデータポイントの効率化については、ベストプラクティスを参照してください。
• 同期実行のモニタリングについては、同期ログとオブザーバビリティを参照してください。
• すべてのソースに共通する質問については、よくある質問を参照してください。