カタログデータの同期と削除

ステップ 1: 新規カタログの作成

カタログ用の新しいクラウドデータ取り込み (CDI) の連携を作成する前に、連携に使用する新規カタログを作成するか、既存のカタログを指定する必要があります。新規カタログを作成する方法はいくつかあり、いずれも CDI 連携に使用できます。

• CSV をアップロードする
• Braze ダッシュボードでカタログを作成する
• カタログ作成エンドポイントを使用してカタログを作成する

カタログスキーマへの変更 (新しいフィールドの追加、フィールドタイプの変更など) は、更新されたデータが CDI を通じて同期される前に、カタログダッシュボードから行う必要があります。データウェアハウスのデータと Braze のスキーマとの競合を避けるために、同期が一時停止されているとき、または実行がスケジュールされていないときにこれらの更新を行うことをお勧めします。

ステップ 2: クラウドデータ取り込みとカタログデータの連携

カタログ同期の設定は、ユーザーデータ CDI 連携のプロセスに厳密に従います。

• snowflake
• redshift
• bigquery
• databricks

連携の仕組み

同期が実行されるたびに、Braze は、UPDATED_AT が最後に同期されたタイムスタンプ以降にあるすべての行を取得します。同期が実行されるたびに完全に更新されるソーステーブルを設定するには、カタログデータからビューを作成することをお勧めします。例えば、product_id、price を含む製品データ (product_catalog_1) のテーブルと 3 つの追加属性がある場合、以下のビューを同期できます。

• snowflake
• redshift
• bigquery
• databricks

1
2
3
4
5
6
7
8
9
10
11
12
13
CREATE VIEW BRAZE_CLOUD_PRODUCTION.INGESTION.CATALOGS_SYNC AS 
SELECT
    CURRENT_TIMESTAMP as UPDATED_AT,
    product_id as id,
    TO_JSON(
        OBJECT_CONSTRUCT (
            '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
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
10
11
CREATE view IF NOT EXISTS BRAZE_CLOUD_PRODUCTION.INGESTION.CATALOGS_SYNC AS (SELECT
    last_updated as UPDATED_AT,
    product_id as ID,
    TO_JSON(
      STRUCT(
      attribute_1,
      attribute_2,
      attribute_3,
      )
    ) as PAYLOAD 
  FROM `BRAZE_CLOUD_PRODUCTION.INGESTION.product_catalog_1`);

1
2
3
4
5
6
7
8
9
10
11
CREATE view IF NOT EXISTS BRAZE_CLOUD_PRODUCTION.INGESTION.CATALOGS_SYNC AS (SELECT
    last_updated as UPDATED_AT,
    product_id as ID,
    TO_JSON(
      STRUCT(
      attribute_1,
      attribute_2,
      attribute_3,
      )
    ) as PAYLOAD 
  FROM `BRAZE_CLOUD_PRODUCTION.INGESTION.product_catalog_1`);

• 連携からフェッチされたデータは、指定した id に基づいて、ターゲットカタログ内のアイテムの作成または更新に使用されます。
• DELETED が true に設定されている場合、対応するカタログアイテムが削除されます。
• 同期でデータポイントは消費されませんが、同期されたすべてのデータはカタログの合計使用量にカウントされます。この使用量は保存されている合計データに基づいて測定されるため、変更されたデータのみの同期について心配する必要はありません。