ETLイベントパイプラインの設定

このパートナーページでは、独自のクエリを設定する際に参照できるメールクリッククエリの設定例を紹介します。

このメールクリッククエリを使用して、Braze キャンペーンおよびキャンバスの特定のメールに対するインタラクションを分析できます。

このクエリを設定する

BRAZE のデータベースを作成し、次に BRAZE_CURRENTS; のデータベースが存在しない場合はそのデータベースを作成します。

1
2
3
4
5
6
7
8
9
10
11
use schema BRAZE_CURRENTS.public;

create or replace stage braze_currents.public.braze_data
url='s3://tl-braze/'
credentials = (AWS_KEY_ID = 'XXXXXXXXX' AWS_SECRET_KEY = 'YYYYYY' );

create file format braze_currents.public.currents_avro type = 'avro' compression = 'auto';

alter stage braze_currents.public.braze_data set file_format = braze_currents.public.currents_avro;

show stages;

テーブルを作成するには、次のコマンドを使用します。

CREATE TABLE
  braze_currents.public.users_messages_email_click (
    id STRING,
    user_id STRING,
    external_user_id STRING,
    time INT,
    timezone STRING,
    campaign_id STRING,
    campaign_name STRING,
    message_variation_id STRING,
    canvas_id STRING,
    canvas_name STRING,
    canvas_variation_id STRING,
    canvas_step_id STRING,
    send_id STRING,
    dispatch_id STRING,
    email_address STRING,
    url STRING,
    sending_ip STRING,
    user_agent STRING
  );

パイプを作成または置換するには、次のコマンドを使用します。

CREATE OR REPLACE PIPE
  pipe_users_messages_email_click
    auto_ingest=true AS

COPY INTO
  braze_currents.public.users_messages_email_click
  FROM
  (select
    $1:id::STRING,
    $1:user_id::STRING,
    $1:external_user_id::STRING,
    $1:time::INT,
    $1:timezone::STRING,
    $1:campaign_id::STRING,
    $1:campaign_name::STRING,
    $1:message_variation_id::STRING,
    $1:canvas_id::STRING,
    $1:canvas_name::STRING,
    $1:canvas_variation_id::STRING,
    $1:canvas_step_id::STRING,
    $1:send_id::STRING,
    $1:dispatch_id::STRING,
    $1:email_address::STRING,
    $1:url::STRING,
    $1:sending_ip::STRING,
    $1:user_agent::STRING

    FROM
    @braze_currents.public.braze_data/currents/dataexport.prod-03.S3.integration.YOUR_INTEGRATION_ID_HERE/event_type=users.messages.email.click/);

show pipes;

このクエリの例を活用する

前述のコマンドの出力から notification_channel をコピーし、S3バケット通知を設定する際に使用します。

指定された以下のパイプ名について、S3からSnowflakeに手動で同期します。

ALTER PIPE
  pipe_users_messages_email_click
  refresh ;

パイプのステータスを確認します。これにより、S3からSnowflakeにメッセージが転送されたタイミングが表示されます。

SELECT
  SYSTEM$PIPE_STATUS(
    'pipe_users_messages_email_click'
  )

最後に、以下から * を選択して、テーブルのコピー履歴を表示します。

table(braze_currents.information_schema.copy_history(table_name=>'users_messages_email_click', start_time=> dateadd(hours, -1, current_timestamp())));