Skip to content

ETL 이벤트 파이프라인 설정

이 파트너 페이지에서는 자체 쿼리를 설정할 때 참조할 수 있는 이메일 클릭 수 쿼리의 예시 설정을 제공합니다.

이 이메일 클릭 수 쿼리를 사용하여 Braze Campaigns 및 Canvases의 특정 이메일과의 상호작용을 분석할 수 있습니다.

이 쿼리 설정하기

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;

다음 명령을 사용하여 테이블을 생성합니다:

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

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

다음 명령을 사용하여 파이프를 생성하거나 교체합니다:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

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로 수동 동기화합니다:

1
2
3

ALTER PIPE
  pipe_users_messages_email_click
  refresh ;

파이프 상태를 확인합니다. 이를 통해 메시지가 S3에서 Snowflake로 전달된 시점을 확인할 수 있습니다:

1
2
3
4

SELECT
  SYSTEM$PIPE_STATUS(
    'pipe_users_messages_email_click'
  )

마지막으로, 다음에서 *를 선택하여 테이블의 복사 기록을 확인합니다:

1

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