Skip to content

ベストプラクティス

Braze クラウドデータ取り込みを使用すると、データウェアハウスやファイルストレージシステムから Braze への直接接続を設定して、関連するユーザーデータやカタログデータを同期できます。このデータをBraze に同期すると、パーソナライゼーション、トリガー ing、セグメンテーション などのユースケースに利用できます。

UPDATED_AT カラムについて

同期が実行されると、Braze はデータウェアハウスインスタンスに直接接続し、指定されたテーブルからすべての新しいデータを取得し、Braze ダッシュボードの対応するデータを更新します。同期が実行されるたびに、Braze は更新d データを反映します。

例: 定期的な同期

CDI 同期でUPDATED_AT がどのように使用されるかを説明するために、ユーザー 属性s を更新するための繰り返し同期の例を考えてみます。

  • ファイルストレージソース
    • Amazon S3

サポートされるデータ型

クラウドデータ取り込みは、次のデータ型をサポートします。

  • ユーザー属性、含む：
    • 階層化カスタム属性
    • オブジェクト配列
    • サブスクリプションステータス
  • カスタムイベント
  • 購入イベント
  • カタログ項目
  • ユーザー削除リクエスト

外部ID、ユーザー別名、Braze ID、メール、または電話番号で更新 ユーザーデータできます。ユーザーは、外部ID、ユーザー別名、またはBraze ID で削除できます。

同期されるデータ

同期が実行されるたびに Braze では、以前に同期されていない行が調べられます。このときに、テーブルまたはビューの UPDATED_AT 列がチェックされます。Braze は、UPDATED_AT が最後に成功した同期ジョブの最後のUPDATED_AT タイムスタンプと等しいかそれより後の行を選択してインポートします。

データウェアハウスで、次のユーザーと属性をテーブルに追加し、UPDATED_AT の時間をこのデータを追加する時間に設定します。

次回のスケジュールされたシンク時に、Braze は、UPDATED_AT のタイムスタンプを持つすべての行を、s をユーザープロファイルする最新のタイムスタンプと同じかそれよりも後のタイムスタンプで同期します。s をBraze 更新するか、フィールドs を追加するので、毎回フルユーザープロファイルを同期する必要はありません。同期後、ユーザープロファイルは新しい更新s を反映します。

繰り返し同期、2022年7月20日午後12時に2回目の実行

行が追加されましたが、UPDATED_AT の値は2022-07-19 09:07:23 よりも前です(最初の実行から保存されます)。その結果、この実行ではこれらの行は同期されません。同期の最後のUPDATED_AT は、この実行によって変更されず、2022-07-19 09:07:23 のままです。

定期的な同期、2022年7 月21 日午後12 時に3 回目実行

この3 回目の実行では、別の新しい行が追加されました。これで、1 つの行のUPDATED_AT 値が2022-07-19 09:07:23 より後になり、1 つの行のみが同期することになります。最後のUPDATED_AT が2022-07-21 08:30:00 に設定されました。

UPDATED_AT列にUTCタイムスタンプを使用します

夏時間に関する問題を防ぐために、UPDATED_AT 列は UTC にする必要があります。できる限り、CURRENT_DATE() ではなく SYSDATE() など、UTC のみの関数を優先します。

UPDATED_AT の時刻が同期と同じでないことを確認します

UPDATED_AT フィールドs のいずれかが、前の正常な同期ジョブの最後のUPDATED_AT タイムスタンプとまったく同じ時刻にある場合、CDI 同期に重複データがある可能性があります。これは、CDI は以前の同期と同じ時刻の行を特定すると「包含境界」を選択し、それらの行を同期可能にするためです。CDI は、これらの行を再取り込みし、重複データを作成します。

データの重複を避けるための推奨事項を次に示します。

  • VIEW に対して同期を設定する場合は、CURRENT_TIMESTAMP をデフォルトとして使用しないでください。使用すると、同期が実行されるたびにすべてのデータが同期されます。これは、UPDATED_AT フィールドの評価結果がクエリの実行時間になるためです。
  • 非常に長時間実行されるパイプラインやクエリがソーステーブルにデータを書き込んでいる場合、同期と同時に実行することを避けるか、挿入される各行に同じタイムスタンプを使用することを避けてください。
  • トランザクションを使用して、同じタイムスタンプを持つすべての行を書き込みます。

例: 以降の更新の管理

この例では、最初にデータを同期し、その後の更新では変更されたデータ (差分) のみを更新する一般的なプロセスを説明します。いくつかのユーザーデータを含むテーブル EXAMPLE_DATA があるとします。1 日目のテーブルには次の値があります。

external_id attribute_1 attribute_2 attribute_3 attribute_4
12345 823 blue 380 FALSE
23456 28 blue 823 TRUE
34567 234 blue 384 TRUE
45678 245 red 349 TRUE
56789 1938 red 813 FALSE

このデータを CDI の必要とする形式に変換するには、次のクエリを実行します。

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

SELECT
    CURRENT_TIMESTAMP AS UPDATED_AT,
    EXTERNAL_ID AS EXTERNAL_ID,
    TO_JSON(
        OBJECT_CONSTRUCT(
            'attribute_1', attribute_1,
            'attribute_2', attribute_2,
            'attribute_3', attribute_3,
            'attribute_4', attribute_4
        )
    ) AS PAYLOAD
FROM EXAMPLE_DATA;

このデータはどれも Braze に同期されていないため、CDI のソーステーブルにすべて追加されます。

同期が実行され、Braze により「2023-03-16 15:00:00」まで利用可能なすべてのデータを同期したと記録されます。次に、2 日目の朝に ETL が実行され、ユーザーテーブルの一部のフィールドが更新されます(強調表示)。

external_id attribute_1 attribute_2 attribute_3 attribute_4
12345 145 red 380 TRUE
23456 15 blue 823 TRUE
34567 234 blue 495 FALSE
45678 245 green 349 TRUE
56789 1938 red 693 FALSE

ここで、変更された値のみを CDI ソーステーブルに追加する必要があります。古い行を更新するのではなく、これらの行を追加することができます。そのテーブルは次のようになります。

CDI は新しい行だけを同期するので、次に実行される同期では最後の 5 行のみが同期されます。

追加のヒント

消費を最小限に抑えるために、新規の属性または更新された属性のみを書き込む

同期が実行されるたびに Braze では、以前に同期されていない行が調べられます。このときに、テーブルまたはビューの UPDATED_AT 列がチェックされます。Braze は、UPDATED_AT が最後に成功したUPDATED_AT タイムスタンプと同じかそれより前の行を選択してインポートします。これは、ユーザープロファイル上の現在のものと同じかどうかに関係なく、最後に成功した同期ジョブのタイムスタンプと同じです。そのため、追加または更新を行う属性のみを同期することをお勧めします。

データポイントの使用方法は、REST API やSDK s などの他の取り込み方法と同じであるため、ソーステーブルに新しいまたは更新 d 属性 s のみを追加するようにしてください。

EXTERNAL_ID をPAYLOAD カラムから分離します

PAYLOAD オブジェクトには、external IDまたは他のIDタイプを含めないでください。

属性を削除する

ユーザーのプロファイルから属性を省略する場合は、null に設定できます。属性を変更せずに残す場合は、更新されるまで Braze に送信しないでください。属性を完全に削除するには、TO_JSON(OBJECT_CONSTRUCT_KEEP_NULL(...)) を使用します。

増分更新を行う

データのインクリメンタル更新を行うことで、同時更新時の意図しない上書きを防ぐことができます。

次の例では、ユーザーに2 つの属性があります。

  • 色:”グリーン&クォート;
  • サイズ:「大」

次に、Braze は、そのユーザに対して次の2 つの更新を同時に受信します。

  • リクエスト1:色を「赤」に変更する
  • リクエスト2:サイズを「中」に変更する

Request 1 が最初に発生するため、ユーザーの属性は次のように更新されます。

  • 色:「赤」
  • サイズ:「大」

ただし、リクエスト2が発生すると、Braze は元の属性値 (「グリーン」および「大」) で開始し、ユーザーの属性を次のように更新します。

  • 色:”グリーン&クォート;
  • サイズ:「中」

リクエストが完了すると、Request 2 はRequest 1 からの更新を上書きします。そのため、リクエストが上書きされないように更新をずらすことをお勧めします。

別のテーブルからのJSON 文字列の作成

各属性を内部的に独自の列に格納する場合は、それらの列を JSON 文字列に変換して、Braze との同期を取り込む必要があります。そのために、次のようなクエリを使用できます。

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,
    TO_JSON(
        OBJECT_CONSTRUCT (
            'attribute_1',
            attribute_1,
            'attribute_2',
            attribute_2,
            'yet_another_attribute',
            attribute_3)
    )as PAYLOAD FROM "EXAMPLE_USER_DATA";

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";

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

CREATE OR REPLACE TABLE BRAZE.EXAMPLE_USER_DATA (attribute_1 string,
     attribute_2 STRING,
     attribute_3 NUMERIC,
     my_user_id STRING);

SELECT
    CURRENT_TIMESTAMP as UPDATED_AT,
    my_user_id as EXTERNAL_ID,
    TO_JSON(
      STRUCT(
        'attribute_1' AS attribute_1,
        'attribute_2'AS attribute_2,
        'yet_another_attribute'AS attribute_3
      )
    ) as PAYLOAD 
  FROM BRAZE.EXAMPLE_USER_DATA;

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

CREATE OR REPLACE TABLE BRAZE.EXAMPLE_USER_DATA (
    attribute_1 string,
    attribute_2 STRING,
    attribute_3 NUMERIC,
    my_user_id STRING
);

SELECT
    CURRENT_TIMESTAMP as UPDATED_AT,
    my_user_id as EXTERNAL_ID,
    TO_JSON(
      STRUCT(
        attribute_1,
        attribute_2,
        attribute_3
      )
    ) as PAYLOAD 
  FROM BRAZE.EXAMPLE_USER_DATA;

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

CREATE TABLE [braze].[users] (
    attribute_1 VARCHAR,
    attribute_2 VARCHAR,
    attribute_3 VARCHAR,
    attribute_4 VARCHAR,
    user_id VARCHAR
)
GO

CREATE VIEW [braze].[user_update_example]
AS SELECT 
    user_id as EXTERNAL_ID,
    CURRENT_TIMESTAMP as UPDATED_AT,
    JSON_OBJECT('attribute_1':attribute_1, 'attribute_2':attribute_2, 'attribute_3':attribute_3, 'attribute_4':attribute_4) as PAYLOAD

FROM [braze].[users] ;

UPDATED_AT タイムスタンプを使用する

Braze に正常に同期されたデータの追跡には、UPDATED_AT タイムスタンプを使用します。同期の実行中に同じタイムスタンプを持つ多くの行が書き込まれると、データが重複して Braze に同期される可能性があります。データの重複を回避するための推奨事項をいくつか示します。

  • VIEW に対して同期を設定する場合は、CURRENT_TIMESTAMP をデフォルト値として使用しないでください。使用すると、同期が実行されるたびにすべてのデータが同期されます。これは、UPDATED_AT フィールドの評価結果がクエリの実行時間になるためです。
  • 非常に長時間実行されるパイプラインやクエリがソーステーブルにデータを書き込んでいる場合、同期と同時に実行することを避けるか、挿入される各行に同じタイムスタンプを使用することを避けてください。
  • トランザクションを使用して、同じタイムスタンプを持つすべての行を書き込みます。

テーブル構成

お客様がベストプラクティスやコードスニペットを共有できるように、GitHub リポジトリを公開しています。独自のスニペットを投稿するには、プルリクエストを作成してください。

データのフォーマット

階層化カスタム属性の更新、サブスクリプションステータスの追加、カスタムイベントまたは購入の同期など、Braze の /users/track エンドポイントを通じて可能な操作はすべて、クラウドデータ取り込みでサポートされます。

ペイロード内のフィールドは、対応する/users/trackエンドポイントと同じ形式に従う必要があります。詳細な書式設定の要件については、次を参照してください。

ネストされた属性で日付をキャプチャするための特別な要件に注意してください。

カスタム属性を同期するために、階層化カスタム属性をペイロード列に含めることができます。

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

{
      "most_played_song": {
        "song_name": "Solea",
        "artist_name": "Miles Davis",
        "album_name": "Sketches of Spain",
        "genre": "Jazz",
        "play_analytics": {
            "count": 1000,
            "top_10_listeners": true
        }
      }
}

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

同期できるのは、行ごとに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": "Dan Alexander"
    }
}

購入イベントを同期するには、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, }
        ]
    }
}

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

{
    "subscription_groups" : [
        {
            "subscription_group_id": "subscription_group_identifier_1",
            "subscription_state": "unsubscribed"
        },
        {
            "subscription_group_id": "subscription_group_identifier_2",
            "subscription_state": "subscribed"
        },
        {
            "subscription_group_id": "subscription_group_identifier_3",
            "subscription_state": "subscribed"
        }
      ]
}

データウェアハウスクエリーのタイムアウトを回避する

最適なパフォーマンスを実現し、潜在的なエラーを回避するために、クエリは 1 時間以内に完了することをお勧めします。クエリがこの時間枠を超える場合は、データウェアハウスの構成を見直すことを検討してください。倉庫に割り当てられたリソースを最適化することで、クエリ実行速度を向上させることができます。

製品の制限事項
Github   GitHub でこのページを編集
New Stuff!